Golang并发错误处理技巧分享

使用channel收集并发错误，通过errCh := make(chan error, 3)定义缓冲通道，各goroutine出错时向其发送错误，主协程接收并处理汇总。

在Go语言中处理并发任务的错误传播，关键在于使用合适的同步机制和错误收集方式。直接从多个goroutine传递错误给主流程，需要借助channel、sync.WaitGroup以及上下文控制（如context）来实现可靠通信。

通过Channel收集错误

最常见的方式是创建一个专门用于接收错误的channel，每个并发任务在出错时向该channel发送错误信息。

定义一个error类型的channel，长度可设为并发数，避免阻塞：

启动多个goroutine执行任务，遇到错误就写入errCh：

func doTask(errCh chan<- error) { // 模拟任务逻辑 if someFailure { errCh <- fmt.Errorf("task failed") return } errCh <- nil }

主协程等待所有任务完成，并检查是否有任意错误：

for i := 0; i < 3; i++ { go doTask(errCh) }

var hasError bool
for i := 0; i < 3; i++ {
if err := <-errCh; err != nil {
log.Printf("got error: %v", err)
hasError = true
}
}
if hasError {
// 处理整体失败
}

使用Context提前取消任务

当某个任务出错后，你可能希望立即停止其他正在运行的任务。这时应结合context.WithCancel或context.WithTimeout。

初始化带取消功能的context：

将ctx传入每个任务，在发生错误时调用cancel()：

go func() { if err := longRunningTask(ctx); err != nil { log.Println("task failed:", err) cancel() // 触发其他任务退出 } }()

任务内部定期检查ctx.Done()是否被关闭，及时退出：

select { case <-ctx.Done(): return ctx.Err() default: // 继续执行 }

封装多个错误：使用errors.Join或自定义结构

有时你需要保留所有子任务的错误，而不是只返回第一个。Go 1.20+提供了errors.Join函数，可以合并多个错误：

var errs []error for i := 0; i < 3; i++ { if err := <-errCh; err != nil { errs = append(errs, err) } } if len(errs) > 0 { return errors.Join(errs...) }

若版本较低，可手动构建包含多个错误的结果：

type MultiError struct { Errors []error }

func (m MultiError) Error() string { var buf strings.Builder for i, e := range m.Errors { if i > 0 { buf.WriteString("; ") } buf.WriteString(e.Error()) } return buf.String() }

基本上就这些。核心是利用channel传递错误，配合context控制生命周期，再根据需求决定是一旦出错就终止，还是收集全部错误。模式虽简单，但组合起来很灵活。