```go var wg sync.WaitGroup pool := makePool(pollSize) func() { for i := 0; i < runTimes; i++ { select { case <-errChan: fmt.Println("error") pool.Stop() return default: wg.Add(1) poll.Submit(task) } } }() if pool.IsRunning() wg.Wait() ``` 我觉得核心就是这样一个结构,不过 go 没用过线程池,可以看看有什么库