在 Go 语言中，errgroup 是一个非常有用的包，用于在并发操作中集中处理错误。它属于 golang.org/x/sync/errgroup 包，专门设计用来协调多个 Goroutine，并处理可能发生的错误。
Life is like a journey
errgroup？当你在 Go 中启动多个 Goroutine 并希望等待它们全部完成时，通常你会使用 sync.WaitGroup 来做同步工作。然而，在多 Goroutine 运行的过程中，你也可能希望捕获其中一个或多个 Goroutine 中发生的错误。errgroup 的作用就是帮助你简化错误处理，它允许你在等待所有 Goroutine 完成时集中管理和返回错误。
errgroup 会立刻停止其他 Goroutine 的执行（可以选择是否停止）。Go(func() error)：启动一个新的 Goroutine 并指定该 Goroutine 的错误返回值。Wait()：等待所有 Goroutine 完成，如果有错误，返回第一个遇到的错误。errgroup 并不是 Go 标准库的一部分，因此需要单独安装：
go get golang.org/x/sync/errgroup
以下是使用 errgroup 来启动多个并发任务并处理错误的一个示例：
package main
import (
"fmt"
"golang.org/x/sync/errgroup"
"net/http"
"time"
)
func fetchURL(url string) error {
// 模拟网络请求
time.Sleep(2 * time.Second)
resp, err := http.Get(url)
if err != nil {
return fmt.Errorf("failed to fetch %s: %w", url, err)
}
defer resp.Body.Close()
if resp.StatusCode != 200 {
return fmt.Errorf("non-200 response for %s: %d", url, resp.StatusCode)
}
fmt.Printf("Successfully fetched %s\n", url)
return nil
}
func main() {
var g errgroup.Group
urls := []string{
"https://example.com",
"https://google.com",
"https://nonexistenturl.com", // This will fail
}
// 启动多个 Goroutine 来并发地抓取网页
for _, url := range urls {
url := url // 捕获变量
g.Go(func() error {
return fetchURL(url)
})
}
// 等待所有 Goroutine 完成，并检查是否有错误
if err := g.Wait(); err != nil {
fmt.Printf("Error encountered: %v\n", err)
} else {
fmt.Println("All URLs fetched successfully!")
}
}
errgroup.Group：首先，我们创建了一个 errgroup.Group 实例 g，它用来管理多个并发任务和处理它们的错误。g.Go(func() error {...})：通过调用 Go 方法，我们将每个任务添加到 errgroup 中。这里的每个任务都是一个返回 error 的函数。当某个任务返回错误时，errgroup 会记录下第一个错误并终止其他 Goroutine（默认情况下）。g.Wait()：调用 Wait() 来等待所有任务完成。如果有任何错误发生，Wait() 会返回第一个错误。g.Wait() 会立即返回这个错误并停止等待其他 Goroutine。如果你希望所有 Goroutine 都执行完毕，即使有错误发生，可以通过自定义错误处理来实现。errgroup 适用于以下场景：
errgroup 包是 Go 中用于并发编程时处理多个 Goroutine 错误的高效工具。它让我们能够更清晰地组织并发任务，并确保错误能够被正确处理，同时不必为每个 Goroutine 单独管理错误。