使用channel和WaitGroup可安全汇总goroutine错误，示例中通过带缓冲的error channel收集各任务错误，wg确保等待所有协程完成，最后遍历channel获取全部错误；若用errgroup则更简洁，但需注意返回nil以避免提前终止。
在Golang中，"多线程"通常指的是使用goroutine实现并发。由于每个goroutine是独立执行的，如何安全地收集它们运行过程中产生的错误是一个常见需求。下面介绍一种简洁、实用的错误汇总方式。
使用channel汇总错误
最自然的方式是通过一个专门用于传递错误的channel来收集各个goroutine的错误信息。为了保证并发安全和正确等待所有任务完成，结合sync.WaitGroup使用是标准做法。
步骤说明：
- 创建一个buffered channel，类型为error，用于接收各goroutine的错误
- 使用sync.WaitGroup确保主协程等待所有任务结束
- 每个goroutine执行完成后，若出错，将错误发送到error channel
- 所有goroutine启动后，关闭error channel（在WaitGroup Done后）
- 从channel中读取所有错误并汇总
示例代码：
立即学习“go语言免费学习笔记（深入）”；
func doWork(id int) error {
if id == 2 {
return fmt.Errorf("工作 %d 执行失败", id)
}
return nil
}
func main() {
var wg sync.WaitGroup
errors := make(chan error, 10) // buffered避免阻塞
for i := 0; i
wg.Add(1)
go func(i int) {
defer wg.Done()
if err := doWork(i); err != nil {
errors
}
}(i)
}
// 单独起一个goroutine等待完成并关闭channel
go func() {
wg.Wait()
close(errors)
}()
// 收集所有错误
var allErrors []error
for err := range errors {
allErrors = append(allErrors, err)
}
if len(allErrors) > 0 {
fmt.Printf("共发生 %d 个错误：\n", len(allErrors))
for _, e := range allErrors {
fmt.Println(e)
}
} else {
fmt.Println("全部成功")
}
}
使用errgroup简化错误处理
如果项目中使用了golang.org/x/sync/errgroup，可以更简洁地实现带错误传播的并发控制。errgroup会在某个goroutine返回非nil错误时自动取消其他任务（配合context使用）。
优点： 自动取消、语法简洁、支持上下文超时控制
import "golang.org/x/sync/errgroup"
func main() {
var g errgroup.Group
var mu sync.Mutex
var allErrors []error
for i := 0; i
i := i
g.Go(func() error {
err := doWork(i)
if err != nil {
mu.Lock()
allErrors = append(allErrors, err)
mu.Unlock()
}
return nil // 注意：我们不希望g.Go中断整个组
})
}
g.Wait()
fmt.Printf("共收集到 %d 个错误\n", len(allErrors))
}
注意：如果你调用return err，errgroup会提前终止其他任务。若要收集所有错误，应让每个任务返回nil，并自行记录错误。
关键注意事项
- error channel建议设为buffered，避免因无接收方导致goroutine阻塞
- 不要在主goroutine中直接关闭channel，应在wg.Wait()之后由单独goroutine关闭
- 多个goroutine写入slice时必须加锁（sync.Mutex）
- 根据业务需求决定是否允许部分失败，还是任一错误就整体失败
基本上就这些。核心是利用channel通信 + WaitGroup同步，再辅以必要的并发保护。
