使用channel或errgroup收集goroutine错误：通过带缓冲channel配合WaitGroup收集所有错误，或用errgroup自动处理首个错误并取消其余任务，根据是否需收集全部错误及上下文控制需求选择方案。
在Go语言中，goroutine 是实现并发的核心机制，但一旦涉及多个并发任务，错误处理就变得复杂。因为每个 goroutine 是独立执行的，直接从 goroutine 中返回错误是不可行的。如何有效收集和处理这些错误，是构建健壮并发程序的关键。
使用 channel 收集错误
最常见且推荐的方式是通过 error channel 收集来自各个 goroutine 的错误。定义一个专门用于传递错误的 channel，在每个 goroutine 执行完成后，将错误发送到该 channel。
关键点：
- 使用带缓冲的 channel 或在单独的 goroutine 中接收，避免发送阻塞
- 配合 sync.WaitGroup 确保所有任务完成后再关闭 error channel
func doWork() error {
// 模拟任务执行
return nil
}
func runTasks() error {
var wg sync.WaitGroup
errCh := make(chan error, 10) // 缓冲 channel 避免阻塞
tasks := []func() error{doWork, doWork, doWork}
for _, task := range tasks {
wg.Add(1)
go func(t func() error) {
defer wg.Done()
if err := t(); err != nil {
errCh <- err
}
}(task)
}
go func() {
wg.Wait()
close(errCh)
}()
var errors []error
for err := range errCh {
errors = append(errors, err)
}
if len(errors) > 0 {
return fmt.Errorf("有 %d 个任务失败: %v", len(errors), errors)
}
return nil}
立即学习“go语言免费学习笔记（深入）”；
使用 errgroup 简化错误处理
golang.org/x/sync/errgroup 提供了更简洁的并发控制方式，能自动传播第一个非 nil 错误，并取消其他任务（如果使用了 context）。
优势：
- 自动等待所有 goroutine 结束
- 支持 context 控制超时或取消
- 遇到第一个错误即可中断所有任务
import "golang.org/x/sync/errgroup"func runWithErrgroup() error { var g errgroup.Group
tasks := []func() error{ func() error { return doWork() }, func() error { return doWork() }, func() error { return fmt.Errorf("任务失败") }, } for _, task := range tasks { g.Go(task) } if err := g.Wait(); err != nil { return fmt.Errorf("任务组执行失败: %w", err) } return nil}
立即学习“go语言免费学习笔记（深入）”；
选择合适策略的关键因素
实际开发中，应根据业务需求选择错误收集方式：
- 需要收集所有错误？用 error channel + WaitGroup
- 只需知道是否成功，或第一个错误即可中断？用 errgroup
- 任务依赖 context 控制生命周期？errgroup.WithContext 更合适
注意：不要让 goroutine 泄露，确保所有发送到 error channel 的操作不会因 channel 无接收者而阻塞。
基本上就这些。关键是理解并发错误不是“忽略”，而是“有组织地收集和响应”。
