如何在Golang中实现多线程错误汇总-Golang-PHP中文网

如何在Golang中实现多线程错误汇总

P粉602998670

发布： 2025-10-27 12:32:01

原创

452人浏览过

使用channel和WaitGroup可安全汇总goroutine错误，示例中通过带缓冲的error channel收集各任务错误，wg确保等待所有协程完成，最后遍历channel获取全部错误；若用errgroup则更简洁，但需注意返回nil以避免提前终止。

如何在golang中实现多线程错误汇总

在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 < 5; i++ {
    wg.Add(1)
    go func(i int) {
      defer wg.Done()
      if err := doWork(i); err != nil {
        errors <- err
      }
    }(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使用）。

如知AI笔记

如知笔记——支持markdown的在线笔记，支持ai智能写作、AI搜索，支持DeepseekR1满血大模型

查看详情

优点： 自动取消、语法简洁、支持上下文超时控制

import "golang.org/x/sync/errgroup"

func main() {
  var g errgroup.Group
  var mu sync.Mutex
  var allErrors []error

  for i := 0; i < 5; 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))
}