Golang如何处理并发任务错误传播

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

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

通过Channel收集错误

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

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

errCh := make(chan error, 3)

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

立即学习“go语言免费学习笔记（深入）”；

func doTask(errCh chan

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

for i := 0; i 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 := context.WithCancel(context.Background())

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

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

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

select {
case

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

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

var errs []error
for i := 0; i 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控制生命周期，再根据需求决定是一旦出错就终止，还是收集全部错误。模式虽简单，但组合起来很灵活。