当前位置：首页 > 文章列表 > Golang > Go教程 > Golang并发错误处理实例详解

Golang并发错误处理实例详解

2025-10-07 15:26:52 0浏览收藏

**Golang并发错误收集处理实例解析：掌握errgroup与channel的妙用** 在Go语言并发编程中，如何高效、安全地处理多个goroutine可能产生的错误至关重要。本文深入解析了两种常用的错误收集与处理策略，助你编写更健壮的并发程序。首先，推荐使用`errgroup`，它能简化并发任务的错误传播和等待逻辑，支持快速失败和任务取消。其次，如果需要汇总所有错误信息，则可采用带缓冲的channel配合WaitGroup，避免goroutine阻塞，并确保channel正确关闭。文章通过示例代码详细展示了这两种方法的具体实现和适用场景，助你根据实际业务需求选择最合适的策略，提升Golang并发编程的效率和可靠性。

使用errgroup可实现并发任务的错误收集与快速失败，通过WithContext支持取消机制；若需汇总所有错误，则可用带缓冲channel配合WaitGroup，避免阻塞并确保正确关闭。

Golang并发任务错误收集与处理示例

在Go语言中处理并发任务时，经常会遇到多个goroutine同时执行并可能返回错误的情况。如何安全地收集这些错误，并在所有任务完成或任意一个任务出错时做出响应，是编写健壮并发程序的关键。下面是一个实用的错误收集与处理示例。

使用errgroup.Group（推荐方式）

errgroup 是官方扩展包 golang.org/x/sync/errgroup 提供的工具，能简化并发任务的错误传播和等待逻辑。

它允许你启动多个goroutine，并在任意一个返回非nil错误时自动取消其他任务（如果配合context使用），同时只返回第一个发生的错误。

示例代码：

package main
<p>import (
"context"
"fmt"
"time"</p><pre class="brush:php;toolbar:false;">"golang.org/x/sync/errgroup"

)

func main() { ctx := context.Background() g, ctx := errgroup.WithContext(ctx)

urls := []string{
    "https://httpbin.org/status/200",
    "https://httpbin.org/status/500", // 模拟失败
    "https://httpbin.org/status/200",
}

for _, url := range urls {
    url := url // 注意变量捕获
    g.Go(func() error {
        return fetchURL(ctx, url)
    })
}

if err := g.Wait(); err != nil {
    fmt.Printf("请求失败: %v\n", err)
} else {
    fmt.Println("所有任务成功完成")
}

}

func fetchURL(ctx context.Context, url string) error { select { case <-time.After(2 * time.Second): // 模拟网络请求 if url == "https://httpbin.org/status/500" { return fmt.Errorf("请求 %s 失败，服务器错误", url) } fmt.Printf("成功获取: %s\n", url) return nil case <-ctx.Done(): return ctx.Err() } }

在这个例子中，只要有一个fetchURL返回错误，g.Wait() 就会立即返回该错误，其余正在运行的任务也会因context被取消而尽快退出。

手动通过channel收集所有错误

如果你希望收集所有任务的错误而不是仅第一个，可以使用带缓冲的error channel。

这种方式适合需要汇总全部结果的场景，比如批量任务中统计成功与失败数量。

示例代码：

package main
<p>import (
"fmt"
"sync"
)</p><p>func main() {
var wg sync.WaitGroup
errCh := make(chan error, 3) // 缓冲channel，避免阻塞</p><pre class="brush:php;toolbar:false;">tasks := []string{"task-1", "task-2", "task-3"}

for _, task := range tasks {
    wg.Add(1)
    go func(t string) {
        defer wg.Done()
        err := processTask(t)
        if err != nil {
            errCh <- fmt.Errorf("任务 %s 执行失败: %w", t, err)
        }
    }(task)
}

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

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

if len(errors) > 0 {
    fmt.Printf("共发生 %d 个错误:\n", len(errors))
    for _, e := range errors {
        fmt.Println(e)
    }
} else {
    fmt.Println("所有任务成功")
}

}

func processTask(name string) error { if name == "task-2" { return fmt.Errorf("模拟处理失败") } fmt.Printf("任务 %s 成功完成\n", name) return nil }

注意：errCh 必须有足够容量或由独立goroutine接收，否则发送错误可能导致goroutine阻塞，进而引发deadlock。