求 go 并发限制的最佳实现

context 不就可以实现吗

errgroup 了解一下

一起探讨，如果 M 不是大到离谱，是否需要控制 M ？还是无脑 go 就好了，因为这样感觉就是 go 程池 /线程池了，有点像把 go 程当线程用了？

不是 channel 就可以实现了吗？

@ToPoGE context 实现不了等待任务全部执行完成吧

@xylophone21 现在就是 M 如果太大了服务器会顶不住，比如并发查询 sql

@cloudfstrife errgroup 我试了下，第一不能限制并发数，第二不能在发生错误时立即返回。

借楼问一下，我怎么不能发帖了。。

@baodaren8 我也不能发了

@monkeyWie context 配合 waitGRoup，就可以做到失败一个全干掉，全完成，返回

一个 err chan 用来通知 root goroutine 发生错误，然后 root context 退出； wait group 用来做全部完成检查。
这样何如？

可以参考或者直接用 https://github.com/kubernetes/client-go/blob/master/util/workqueue/parallelizer.go#L46

哦还有并发控制。
taskChannel + workerChannel，这样 wait group 也不需要了

线程池+channel，收到错误消息停止向队列里发送消息。
想要立刻回收，主线程直接 stop 线程池里所有线程，否则等待运行中线程跑完

@ToPoGE @MadbookPro @mogg
直接上代码吧，这样说不明白🤣

errgroup + 1

并发控制：协程池
消息传递：channel
还有等待协程结束再结束 main 函数：sync.
甚至可以子任务报错直接 exit

@monkeyWie 那你用 errgroup 把，go 官方标准库中的，看文档直接用，就是 context 和 waitGroup 结合的

看不到代码。。。我的思路是，for 循环几个 goroutine，select 的时候，先从 errchannel 里看 err，然后 default 里从 taskchannel 里拿 task

```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 没用过线程池，可以看看有什么库