当前位置：首页 > 文章列表 > Golang > Go教程 > Golang并发错误处理全攻略

Golang并发错误处理全攻略

2025-10-30 20:28:29 0浏览收藏

学习知识要善于思考，思考，再思考！今天golang学习网小编就给大家带来《Golang并发错误处理技巧》，以下内容主要包含等知识点，如果你正在学习或准备学习Golang，就都不要错过本文啦~让我们一起来看看吧，能帮助到你就更好了！

使用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
}
func runTasks() error {
var wg sync.WaitGroup
errCh := make(chan error, 10) // 缓冲 channel 避免阻塞
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
}

使用 errgroup 简化错误处理

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

优势：

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

示例代码：

import "golang.org/x/sync/errgroup"
func runWithErrgroup() error {
var g errgroup.Group
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
}