Golang并发错误处理 goroutine错误收集方案-Golang-PHP中文网

Golang并发错误处理 goroutine错误收集方案

P粉602998670

发布： 2025-08-27 12:58:01

原创

705人浏览过

使用channel或errgroup收集goroutine错误：通过带缓冲channel配合WaitGroup收集所有错误，或用errgroup自动处理首个错误并取消其余任务，根据是否需收集全部错误及上下文控制需求选择方案。

golang并发错误处理 goroutine错误收集方案

在Go语言中，goroutine 是实现并发的核心机制，但一旦涉及多个并发任务，错误处理就变得复杂。因为每个 goroutine 是独立执行的，直接从 goroutine 中返回错误是不可行的。如何有效收集和处理这些错误，是构建健壮并发程序的关键。

使用 channel 收集错误

最常见且推荐的方式是通过 error channel 收集来自各个 goroutine 的错误。定义一个专门用于传递错误的 channel，在每个 goroutine 执行完成后，将错误发送到该 channel。

关键点：

使用带缓冲的 channel 或在单独的 goroutine 中接收，避免发送阻塞
配合 sync.WaitGroup 确保所有任务完成后再关闭 error channel

示例代码：

func doWork() error {
    // 模拟任务执行
    return nil
}
<p>func runTasks() error {
var wg sync.WaitGroup
errCh := make(chan error, 10) // 缓冲 channel 避免阻塞</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">tasks := []func() error{doWork, doWork, doWork}

for _, task := range tasks {
    wg.Add(1)
    go func(t func() error) {
        defer wg.Done()
        if err := t(); err != nil {
            errCh <- err
        }
    }(task)
}

go func() {
    wg.Wait()
    close(errCh)
}()

var errors []error
for err := range errCh {
    errors = append(errors, err)
}

if len(errors) > 0 {
    return fmt.Errorf("有 %d 个任务失败: %v", len(errors), errors)
}
return nil

登录后复制

}

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

使用 errgroup 简化错误处理

golang.org/x/sync/errgroup 提供了更简洁的并发控制方式，能自动传播第一个非 nil 错误，并取消其他任务（如果使用了 context）。

优势：

挖错网

一款支持文本、图片、视频纠错和AIGC检测的内容审核校对平台。

查看详情

自动等待所有 goroutine 结束
支持 context 控制超时或取消
遇到第一个错误即可中断所有任务

示例代码：

import "golang.org/x/sync/errgroup"
<p>func runWithErrgroup() error {
var g errgroup.Group</p><pre class="brush:php;toolbar:false;"><pre class="brush:php;toolbar:false;">tasks := []func() error{
    func() error { return doWork() },
    func() error { return doWork() },
    func() error { return fmt.Errorf("任务失败") },
}

for _, task := range tasks {
    g.Go(task)
}

if err := g.Wait(); err != nil {
    return fmt.Errorf("任务组执行失败: %w", err)
}
return nil

登录后复制

}

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