使用errgroup可自动传播首个错误并取消其他任务;2. 自定义通道能收集全部错误,适用于需运行所有任务的场景。

在Go语言的并发任务处理中,错误收集与汇总是一个常见但容易被忽视的问题。当多个goroutine同时执行时,如果某个任务出错,不能因为一个错误就中断整个流程,也不能直接忽略。正确的做法是安全地收集所有子任务的错误,并在适当的时候统一处理或上报。
使用errgroup进行错误收集
errgroup.Group 是官方提供的并发控制工具,封装了WaitGroup和Context,能自动传播第一个错误并取消其他任务。
适合场景:希望任一任务失败时快速退出,同时获取首个错误信息。
- 调用errgroup.WithContext()创建Group实例 - 每个任务在独立goroutine中执行,返回error - 所有任务结束后,接收第一个非nil错误(若有) - 利用Context实现任务间取消联动
示例:
立即学习“go语言免费学习笔记(深入)”;
ctx := context.Background()
g, ctx := errgroup.WithContext(ctx)
tasks := []func() error{task1, task2, task3}
for _, task := range tasks {
g.Go(task)
}
if err := g.Wait(); err != nil {
log.Printf("执行出错: %v", err)
}
自定义通道收集全部错误
有时需要运行完所有任务,无论是否出错,都要知道完整的结果。这时应避免使用errgroup的短路机制。
核心思路:通过buffered channel收集每个任务的error,主协程等待所有完成后再分析。
- 创建容量等于任务数的error channel - 每个任务执行完毕后将error发送到channel - 使用WaitGroup确保所有任务结束 - 主协程从channel读取所有结果,合并处理示例:
立即学习“go语言免费学习笔记(深入)”;
var wg sync.WaitGroup
errCh := make(chan error, len(tasks))
for _, task := range tasks {
wg.Add(1)
go func(t func() error) {
defer wg.Done()
if err := t(); err != nil {
errCh <- err
}
}(task)
}
wg.Wait()
close(errCh)
var allErrors []error
for err := range errCh {
allErrors = append(allErrors, err)
}
结构化错误汇总与上下文增强
原始错误往往缺乏上下文,不利于排查。建议在错误传递时附加任务标识、时间戳等信息。
可以定义带元数据的错误结构体,或使用支持wrapped error的库(如pkg/errors)。
- 错误包装:fmt.Errorf("task %s failed: %w", name, err) - 记录发生错误的任务名、输入参数等 - 统一格式输出多个错误,便于日志分析例如:
if err := doWork(id); err != nil {
return fmt.Errorf("worker-%d: %w", id, err)
}
基本上就这些。选择哪种方式取决于业务需求:要快速失败就用errgroup;要全量反馈就用手动channel收集。关键是不让错误丢失,也不让panic蔓延。










