Golang怎么用errgroup限制并发数_Golang如何用SetLimit控制同时执行的协程上限【技巧】-Golang-PHP中文网

errgroup.WithContext 默认不限制并发，仅聚合错误；需配合 semaphore.Weighted 才能实现安全限流，且 Acquire/Release 必须成对使用，避免漏释放或死锁。

golang怎么用errgroup限制并发数_golang如何用setlimit控制同时执行的协程上限【技巧】

errgroup.WithContext 默认不限制并发，必须手动包装

直接用 errgroup.WithContext 创建的组，本质只是协程错误聚合工具，完全不控制并发数。它内部没有队列、没有信号量、也不检查当前运行数量——所有 Go 调用会立刻启动 goroutine，等同于裸写 go fn()。

常见错误现象：errgroup.Wait() 返回超时或 OOM，日志显示瞬间拉起上千 goroutine；压测时 QPS 猛涨但下游服务被打挂。

真正限制并发，得靠 semaphore.Weighted 或自己实现计数信号量
别被 “group” 这个词误导——它和 “worker pool” 是两回事
如果只是想等全部完成且捕获任一错误，用原生 errgroup 没问题；一旦涉及资源节流（数据库连接、HTTP 客户端、文件句柄），就必须加限流层

用 semaphore.Weighted + errgroup.Go 实现安全限流

golang.org/x/sync/semaphore 是官方推荐的轻量信号量实现，配合 errgroup.Go 才能既保错误传播，又控并发上限。

关键点：每个任务执行前先 Acquire，完成后必须 Release，且 Acquire 可能阻塞——这正是限流生效的位置。

sem := semaphore.NewWeighted(int64(maxConcurrent))
g, ctx := errgroup.WithContext(ctx)

for _, item := range items {
    item := item // 避免循环变量复用
    g.Go(func() error {
        if err := sem.Acquire(ctx, 1); err != nil {
            return err
        }
        defer sem.Release(1) // 即使 panic 也要释放

        return processItem(item)
    })
}

if err := g.Wait(); err != nil {
    return err
}