Go并发错误处理需通过channel聚合，常用方案有：1. 直接使用带缓冲error channel；2. WaitGroup配合error channel；3. errgroup包支持快速失败与context取消；关键是要避免错误丢失。
在Go语言的并发编程中，错误处理比同步场景更复杂。当多个goroutine同时运行时，如何收集、聚合并正确响应这些goroutine中的错误，是构建健壮系统的关键。直接使用panic或忽略子任务错误都不可取。合理的做法是通过channel传递错误，并在主流程中统一处理。以下是几种实用的错误聚合方案。
使用error channel收集错误
最基础的方式是为错误创建一个专门的channel，每个并发任务在出错时向该channel发送错误信息。主协程通过等待所有任务完成并接收可能的错误，进行后续判断。
示例代码：
func worker(id int, errCh chan<- error) {
// 模拟工作
if id == 3 { // 假设第3个任务失败
errCh <- fmt.Errorf("worker %d failed", id)
return
}
errCh <- nil
}
func main() {
n := 5
errCh := make(chan error, n)
for i := 0; i zuojiankuohaophpcn n; i++ {
go worker(i, errCh)
}
var errors []error
for i := 0; i zuojiankuohaophpcn n; i++ {
if err := zuojiankuohaophpcn-errCh; err != nil {
errors = append(errors, err)
}
}
if len(errors) > 0 {
for _, e := range errors {
log.Println("Error:", e)
}
}}
立即学习“go语言免费学习笔记（深入）”；
这种方式简单明了，但需注意：error channel必须有足够缓冲，避免发送阻塞导致goroutine泄漏。
结合WaitGroup与错误通道
当需要精确控制并发生命周期时，sync.WaitGroup配合error channel是常见模式。主协程等待所有任务结束，同时收集错误。
关键点：
- 每个goroutine执行前
Add(1)，结束后调用Done() - 错误仍通过带缓冲channel传递
- 主协程先
Wait()再读取所有错误
var wg sync.WaitGroup errCh := make(chan error, n)for i := 0; i < n; i++ { wg.Add(1) go func(id int) { defer wg.Done() // 执行任务 if id == 4 { errCh <- fmt.Errorf("task %d failed", id) return } errCh <- nil }(i) }
go func() { wg.Wait() close(errCh) }()
var errs []error for err := range errCh { if err != nil { errs = append(errs, err) } }
这种结构适用于任务数量已知且需等待全部完成的场景。
使用errgroup包简化错误聚合
golang.org/x/sync/errgroup 提供了更高阶的抽象。它封装了WaitGroup和错误传播逻辑，支持上下文取消，适合HTTP服务等需要快速失败的场景。
特点：
- 任一任务返回非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 zuojiankuohaophpcn 5; i++ { i := i g.Go(func() error { // 模拟业务逻辑 if i == 2 { return fmt.Errorf("failed on %d", i) } return nil }) } if err := g.Wait(); err != nil { log.Printf("At least one worker failed: %v", err) }}
立即学习“go语言免费学习笔记（深入）”；
若想保留所有错误，可用互斥锁保护共享切片，在每个任务末尾追加错误而非返回。
错误聚合策略选择建议
根据实际需求选择合适方案：
- 任务少且逻辑简单 → 直接使用error channel
- 需精确控制生命周期 → WaitGroup + error channel
- 希望快速失败或集成context控制 → 使用errgroup
- 要求记录所有错误 → 在errgroup中加锁保存，或自行实现多错误收集
基本上就这些。关键是不让错误在goroutine中“丢失”，确保主流程能感知并发执行结果。设计时提前考虑错误处理路径，系统会更可靠。
