Method run

pkg/util/worker_pool.go:76–85

()

}

func (s *workerPoolExecutor) run() {
	for range serverWorkerResetThreshold {
		f, ok := <-s.serverWorkerChannel
		if !ok {
			return
		}
		f()
	}
	go s.run()
}