如何在 Go 中使用 x/sync/errgroup.SetLimit 限制并发数-Golang-PHP中文网

errgroup.Group 本身不提供并发数限制，SetLimit 方法并不存在；正确做法是用 golang.org/x/sync/semaphore.Weighted 配合 errgroup.Go 实现限流，先 Acquire 再执行任务，完成后 Release。

如何在 go 中使用 x/sync/errgroup.setlimit 限制并发数

errgroup.SetLimit 并不存在 —— Go 官方 x/sync/errgroup 包里根本没有这个方法。你查文档、补全、IDE 提示看到的 SetLimit，大概率是误把 errgroup.Group 和第三方库（比如 golang.org/x/sync/errgroup 的 fork 或 github.com/uber-go/goleak 相关工具）混淆了，或者参考了过时的博客/示例。

为什么 errgroup.Group 没有 SetLimit 方法

官方 errgroup.Group 的设计目标是“传播错误 + 等待所有 goroutine 结束”，它本身不负责并发控制。并发数限制属于调度逻辑，应由调用方显式管理。

源码可见：errgroup.Group 只有两个导出字段：ctx 和未导出的 cancel；唯一导出方法是 Go、Wait、TryGo
TryGo 是唯一带“节流”语义的方法：它在 ctx 已取消时跳过启动 goroutine，但不阻塞、也不限并发数
如果你需要限速，必须自己套一层信号量（如 semaphore.Weighted）或 channel 控制

正确做法：用 semaphore.Weighted 配合 errgroup.Go

标准库 golang.org/x/sync/semaphore 提供了轻量级、无锁的信号量实现，和 errgroup.Group 组合使用最自然。

关键点：

先创建一个 *semaphore.Weighted，容量即最大并发数（如 5）
每个任务在 errgroup.Go 启动前，先 Acquire(ctx, 1)；完成后 Release(1)
务必检查 Acquire 返回的 error（比如 ctx 被 cancel），否则可能 panic 或漏执行

import (
    "context"
    "golang.org/x/sync/errgroup"
    "golang.org/x/sync/semaphore"
)
<p>func doWork(ctx context.Context, urls []string) error {
g, ctx := errgroup.WithContext(ctx)
sem := semaphore.NewWeighted(5) // 最大并发 5</p><pre class="brush:php;toolbar:false;">for _, url := range urls {
    url := url // 避免循环变量捕获
    g.Go(func() error {
        if err := sem.Acquire(ctx, 1); err != nil {
            return err // ctx canceled 或其他中断
        }
        defer sem.Release(1)

        return fetchAndProcess(url) // 你的实际工作
    })
}

return g.Wait()

}

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

常见踩坑点：channel 控制 vs semaphore.Weighted

有人用 make(chan struct{}, N) 做并发控制，看似简单，但容易出错：

忘记 defer close(ch)？不会直接 crash，但会泄漏 goroutine 等待
在 errgroup.Go 内部直接 ch + <code>？如果某个任务 panic，<code> 永远不执行，信号量卡死，后续所有任务 hang 住
semaphore.Weighted 是原子操作 + context-aware，Acquire 可被 cancel，Release 可重入，更健壮
性能上：channel 控制有额外 goroutine 调度开销；semaphore.Weighted 是纯内存 CAS 操作，更轻量