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
}
<p>func main() {
n := 5
errCh := make(chan error, n)</p><pre class='brush:php;toolbar:false;'>for i := 0; i < n; i++ {
go worker(i, errCh)
}
var errors []error
for i := 0; i < n; i++ {
if err := <-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)
<p>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)
}</p><p>go func() {
wg.Wait()
close(errCh)
}()</p><p>var errs []error
for err := range errCh {
if err != nil {
errs = append(errs, err)
}
}</p>这种结构适用于任务数量已知且需等待全部完成的场景。
使用errgroup包简化错误聚合
golang.org/x/sync/errgroup 提供了更高阶的抽象。它封装了WaitGroup和错误传播逻辑，支持上下文取消，适合HTTP服务等需要快速失败的场景。
特点：
- 任一任务返回非nil错误，其他任务可通过context被取消
- 自动等待所有任务结束
- 只返回第一个发生的错误（可扩展记录所有）
import "golang.org/x/sync/errgroup"
<p>func main() {
var g errgroup.Group
var mu sync.Mutex
var allErrors []error</p><pre class='brush:php;toolbar:false;'>for i := 0; i < 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中“丢失”，确保主流程能感知并发执行结果。设计时提前考虑错误处理路径，系统会更可靠。
