使用errgroup.Group可实现并发任务的错误聚合，遇到首个错误即返回；若需收集所有错误，可用带缓冲channel或sync.WaitGroup配合互斥锁保护错误切片，推荐优先使用errgroup或channel以避免竞态条件。
在 Golang 的并发任务中，多个 goroutine 可能同时出错，如何有效地收集并处理这些错误是一个常见问题。直接从多个 goroutine 返回错误需要合理的设计模式，避免竞态条件，并确保所有错误都被捕获。
使用 errgroup.Group（推荐方式）
errgroup.Group 是 golang.org/x/sync/errgroup 提供的工具，能自动等待一组 goroutine 完成，并聚合其中任意一个返回的非 nil
错误。
它适合用于“只要有一个任务失败就整体失败”的场景，也支持通过配置实现所有任务运行完成后再汇总错误。
示例代码：
package mainimport ( "fmt" "net/http" "golang.org/x/sync/errgroup" )
func fetchURL(g *errgroup.Group, url string) { g.Go(func() error { resp, err := http.Get(url) if err != nil { return fmt.Errorf("failed to fetch %s: %v", url, err) } defer resp.Body.Close() if resp.StatusCode != http.StatusOK { return fmt.Errorf("non-200 status for %s: %d", url, resp.StatusCode) } fmt.Printf("Success: %s\n", url) return nil }) }
func main() { var g errgroup.Group urls := []string{ "https://www./link/7929d0c1c363d229873f32a2364556f9", "https://www./link/765be53f0233ac540e58b3a6c1ffdecb", "https://www./link/aedc756071fdab015aea24980d0d248e", }
for _, url := range urls { fetchURL(&g, url) } if err := g.Wait(); err != nil { fmt.Println("Error occurred:", err) } else { fmt.Println("All requests succeeded") }}
上面的例子中，只要有任意一个请求失败，g.Wait() 就会返回第一个非 nil 错误。如果你想收集所有错误，可以结合上下文自己实现。
使用 channel 收集多个错误
如果你希望收集所有 goroutine 的错误（而不是遇到第一个就停止），可以使用带缓冲的 channel 来接收每个任务的错误。
示例：通过 error channel 聚合所有错误
func doWork(taskID int) error { // 模拟某些任务可能失败 if taskID%2 == 0 { return fmt.Errorf("task %d failed", taskID) } return nil }func runAllTasks() { tasks := 5 errCh := make(chan error, tasks) // 缓冲 channel 防止阻塞
for i := 0; i < tasks; i++ { go func(id int) { errCh <- doWork(id) }(i) } close(errCh) var errors []error for err := range errCh { if err != nil { errors = append(errors, err) } } if len(errors) > 0 { fmt.Printf("Encountered %d errors:\n", len(errors)) for _, e := range errors { fmt.Println("-", e) } } else { fmt.Println("All tasks completed successfully") }}
这种方式能收集全部错误，适用于需要完整错误报告的场景，比如批量校验或数据导入。
使用 sync.WaitGroup + Mutex 保护错误切片
如果想把错误追加到公共的 slice 中，必须使用互斥锁防止竞态条件。
示例：用 mutex 保护错误列表
func runWithWaitGroup() { tasks := 5 var wg sync.WaitGroup var mu sync.Mutex var allErrors []errorfor i := 0; i < tasks; i++ { wg.Add(1) go func(id int) { defer wg.Done() err := doWork(id) if err != nil { mu.Lock() allErrors = append(allErrors, err) mu.Unlock() } }(i) } wg.Wait() if len(allErrors) > 0 { fmt.Printf("Collected %d errors:\n", len(allErrors)) for _, e := range allErrors { fmt.Println("-", e) } }}
这种方法灵活但稍显繁琐，需手动管理同步。相比 channel 更容易出错，建议优先使用 channel 或 errgroup。
总结与建议
不同场景下选择合适的错误收集方式：
- 想快速失败、代码简洁 → 使用 errgroup.Group
- 需收集全部错误信息 → 使用 error channel 或 mutex + slice
- 配合 context 控制超时 → errgroup.WithContext 是理想选择
基本上就这些。关键是避免竞态，清晰表达错误语义，按需决定是否聚合全部错误。
