如何使用 WaitGroups 处理 Go Goroutines 中的错误？

Go 中 WaitGroup 的错误处理

Goroutine、通道和 WaitGroup 是在 Go 中编写并发代码的基本组件。然而，处理这种情况下的错误可能具有挑战性，特别是在使用 WaitGroups 时。

使用 WaitGroups 时，考虑如何处理 goroutine 中发生的错误非常重要。在提供的示例中：

<code class="go">func doSomething(c chan int) {
    for i := 0; i < 10; i++ {
        n, err := someFunctionThatCanError()
        if err != nil {
            // How do I end the routines and WaitGroups here?
        }

        c <- n
        waitGroup.Done()
    }</code>

如果在循环的任何迭代期间发生错误，则不清楚应如何终止 goroutine 并更新 WaitGroup。

解决此问题问题，建议使用 golang.org/x/sync/errgroup 包。以下是使用 errgroup 的示例的修改版本：

<code class="go">import (
    "log"
    "sync"

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

func main() {
    c := make(chan int, 10)

    var g errgroup.Group

    g.Go(func() error {
        return doSomething(c)
    })

    // g.Wait waits for all goroutines to complete
    // and returns the first non-nil error returned
    // by one of the goroutines.
    if err := g.Wait(); err != nil {
        log.Fatal(err)
    }
}

func doSomething(c chan int) error {
    defer close(c)
    for i := 0; i < 10; i++ {
        n, err := someFunctionThatCanError()
        if err != nil {
            return err
        }
        c <- n
    }
    return nil
}</code>

在此示例中，我们创建一个 errgroup.Group 并将一个函数传递给其 Go 方法。如果 errgroup.Group 启动的任何 goroutine 返回错误，errgroup.Wait 方法将返回该错误，可以进行适当的处​​理。

使用 errgroup 提供了一种更健壮、更方便的方法来处理 goroutine 中的错误同时保持 WaitGroups 的优势。

以上是如何使用 WaitGroups 处理 Go Goroutines 中的错误？的详细内容。更多信息请关注PHP中文网其他相关文章！