在 go 中并发执行函数时处理错误：使用管道在协程间传递错误信息。使用返回值通道检查错误。从函数返回错误，在调用协程时使用。

在 Golang 中并发执行函数时的错误处理

在 Golang 中，使用并发性可以提高程序的性能和响应能力。但是，当并行执行任务时，处理潜在错误尤为重要。本文将介绍在 Go 中并发执行函数时处理错误的有效技术。

协程

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

在 Go 中，协程（goroutine）是一种轻量级线程，它允许我们将代码并发执行为一组独立的任务。协程通过使用 go 关键字创建：

Golang Uber Dig

使用 uber-go/dig 在 Golang 中实现依赖注入——基于反射容器，提供 Provide/Invoke、dig.In/dig.Out 参数与结果对象，支持命名依赖等

下载

go func() {
    // 执行任务
}

错误处理

当并发执行任务时，可能会发生错误。有几种方法可以处理这些错误：

• 管道： 使用管道在协程之间传递错误信息。
• 结果通道： 返回值的一个通道，可以用来检查错误。
• 返回错误： 从函数中返回一个错误，在调用协程时使用。

实战案例：执行函数并收集错误

以下是一个函数并发的实战案例，其中日志记录错误并通过管道收集结果：

package main

import (
    "fmt"
    "sync"
)

func main() {
    // 创建信道
    resultChan := make(chan error)

    // 创建等待组
    var wg sync.WaitGroup

    // 并发执行 5 个函数
    for i := 0; i < 5; i++ {
        wg.Add(1)
        go func(i int) {
            defer wg.Done()

            // 模拟函数执行
            if i%2 == 0 {
                fmt.Printf("任务 %d 成功执行\n", i)
                resultChan <- nil
            } else {
                fmt.Printf("任务 %d 发生错误\n", i)
                resultChan <- fmt.Errorf("error in function %d", i)
            }
        }(i)
    }

    // 等待所有协程完成
    wg.Wait()

    // 收集所有错误
    errors := []error{}
    close(resultChan)
    for err := range resultChan {
        if err != nil {
            errors = append(errors, err)
        }
    }

    // 打印错误
    for _, err := range errors {
        fmt.Println(err)
    }
}

结论

通过了解如何处理并发函数中的错误，我们可以构建健壮且可靠的 Go 程序。管道、结果通道和返回错误等技术提供了灵活且有效的错误处理方法。