Golang并发错误收集与处理技巧

在Go语言并发编程中，如何优雅地收集和处理多个goroutine的错误是一大痛点：既要避免因单个任务失败而盲目中断全部执行，又不能忽略任何错误信息。本文深入剖析两种主流策略——使用官方errgroup自动传播首个错误并协同取消其余任务，适用于追求快速失败与响应的场景；以及通过带缓冲的error通道配合WaitGroup手动收集全部错误，确保所有任务完整执行后统一分析与上报，满足强可观测性与容错需求。无论你侧重效率还是完整性，都能从中获得即开即用的实战方案。

在Go语言的并发任务处理中，错误收集与汇总是一个常见但容易被忽视的问题。当多个goroutine同时执行时，如果某个任务出错，不能因为一个错误就中断整个流程，也不能直接忽略。正确的做法是安全地收集所有子任务的错误，并在适当的时候统一处理或上报。

使用errgroup进行错误收集

errgroup.Group 是官方提供的并发控制工具，封装了WaitGroup和Context，能自动传播第一个错误并取消其他任务。

适合场景：希望任一任务失败时快速退出，同时获取首个错误信息。

示例：

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，主协程等待所有完成后再分析。

示例：

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         }
    }(task)
}

wg.Wait()
close(errCh)

var allErrors []error
for err := range errCh {
    allErrors = append(allErrors, err)
}

结构化错误汇总与上下文增强

原始错误往往缺乏上下文，不利于排查。建议在错误传递时附加任务标识、时间戳等信息。

可以定义带元数据的错误结构体，或使用支持wrapped error的库（如pkg/errors）。

例如：

if err := doWork(id); err != nil {
    return fmt.Errorf("worker-%d: %w", id, err)
}

基本上就这些。选择哪种方式取决于业务需求：要快速失败就用errgroup；要全量反馈就用手动channel收集。关键是不让错误丢失，也不让panic蔓延。

文中关于的知识介绍，希望对你的学习有所帮助！若是受益匪浅，那就动动鼠标收藏这篇《Golang并发错误收集与处理技巧》文章吧，也可关注golang学习网公众号了解相关技术文章。