Go errgroup 怎么处理并发任务

Go 里的 errgroup 是 `golang.org/x/sync` 下封装好的并发任务管理工具，基于原生的 `sync.WaitGroup` 做了功能扩展，不用你自己手动维护协程计数、错误传递、上下文取消的逻辑，就能很方便地批量管理一组异步执行的任务。

做批量并发处理场景用 errgroup，可以自动捕获首个返回的非 nil 错误、自动触发上下文取消剩下的未执行任务，还能很方便地限制最大并发协程数，比裸写 WaitGroup + 自定义错误变量的代码要简洁很多，也能少踩很多并发安全的坑。

用 Go 的 errgroup 处理一批并发任务，关键不是把循环改成 goroutine，而是同时解决三个问题：任务数量要受控，某个任务失败后要能取消后续工作，最后还要统一等待并拿到错误。实际项目里可以用 WithContext 建组，用 SetLimit 限制活跃任务数，再用 Wait 收口。

先分清 errgroup 解决了什么

errgroup.Group 可以看作带错误传播能力的任务组。普通的 sync.WaitGroup 只负责等待，而 errgroup 的任务函数返回 error 后，Wait 能拿到第一个非空错误；配合 WithContext，错误还会取消派生上下文。

它适合“同一批输入分别读取、转换，再汇总”的场景。它不会自动保护你写入共享 map，也不会替你决定失败后是否重试；数据竞争、重试策略和结果顺序仍然要由代码明确处理。

用 SetLimit 给读取任务加上并发上限

下面的例子把字符串输入转换成大写结果。SetLimit(4) 让最多四个任务同时运行；第五个任务提交时，g.Go 会等待空位，而不是继续创建无限 goroutine。每个任务只写自己的 results[i]，因此不需要多个 goroutine 同时写同一槽位。

package main

import (
	"context"
	"fmt"
	"strings"

	"golang.org/x/sync/errgroup"
)

func upperAll(ctx context.Context, inputs []string) ([]string, error) {
	// 派生上下文会在某个任务返回错误时被取消。
	g, ctx := errgroup.WithContext(ctx)
	// 只允许四个转换任务同时活跃，避免输入变大后 goroutine 无限增长。
	g.SetLimit(4)
	results := make([]string, len(inputs))

	for i, input := range inputs {
		i, input := i, input // 固定本轮循环的索引和值，避免闭包读到下一轮变量。
		g.Go(func() error {
			select {
			case 

这里的取消检查只是示例。真正的文件读取、HTTP 请求或数据库调用，还要把 ctx 继续传入支持上下文的 API，例如 http.NewRequestWithContext。如果底层调用不读取 ctx.Done()，上层取消也不能强行中断它。

Wait 负责收口，TryGo 负责判断是否接纳任务

Go 和 TryGo 的选择取决于队列语义：前者适合输入必须处理完的批次，后者适合“当前忙就交给上层稍后重试”的入口。TryGo 返回 false 时，函数根本没有启动，不能把它当成任务执行失败。

// 只有拿到并发额度才启动任务；false 由调用方决定如何重试。
accepted := g.TryGo(func() error {
	// 长任务应继续使用 ctx，让错误取消可以传递到更深层。
	return handle(ctx, item)
})
if !accepted {
	// 这里可以放回队列、延迟重试，或记录一次被限流的任务。
	return fmt.Errorf("任务暂时未接纳")
}

三个容易误判的边界

1. 限制不是速率。 SetLimit(4) 控制同时活跃数量，不保证每秒只启动四个任务；任务很快结束时，启动速度仍可能很高。
2. 不要在运行中改限制。 官方文档要求活跃任务存在时不要修改 limit。若并发度需要动态变化，应在外层做队列或重新创建任务组。
3. Group 不要复用。 一个 Group 对应一批相关任务；下一批输入应新建 Group，别在同一个实例上跨批次混用。

还要留意结果容器：不同 goroutine 写不同索引通常是清晰的做法；如果改成共享 map、追加同一个 slice 或更新统计对象，就需要额外同步。并发上限解决的是资源压力，不等于自动解决数据竞争。

常见问题

SetLimit(0) 会发生什么？

它会阻止新的 goroutine 被加入；如果业务需要继续提交任务，应该设置正数，或者明确使用负数表示不限制。

Wait 返回的是所有错误吗？

不是。Wait 返回第一个非空错误。需要保留每个输入的错误时，应在结果槽位中按索引记录，或在任务外设计专门的错误收集结构。

TryGo(false) 算失败吗？

它表示任务没有启动，不是任务函数返回了错误。调用方应根据队列策略重试、延迟或丢弃，并记录原因。