本文介绍如何利用 Go 官方扩展库 errgroup 实现并发任务的统一错误捕获与自动协程清理，避免 goroutine 泄漏，写出符合 Go 惯用法（idiomatic）的并发代码。
本文介绍如何利用 go 官方扩展库 `errgroup` 实现并发任务的统一错误捕获与自动协程清理，避免 goroutine 泄漏，写出符合 go 惯用法（idiomatic）的并发代码。
在 Go 并发编程中，「启动多个 goroutine 并行执行、任一失败即快速返回、其余任务自动取消」是一个高频场景。但手动管理 sync.WaitGroup、错误通道、取消信号和资源清理极易出错——如原示例所示，未及时退出的 goroutine 会持续运行直至完成，造成泄漏和逻辑竞态。
golang.org/x/sync/errgroup 正是为此类模式量身打造的标准工具：它封装了上下文传播、错误收集、goroutine 生命周期协同与自动取消，使代码既简洁又健壮。
核心优势
- ✅ 自动错误短路：首个非 nil 错误被立即返回，其余 goroutine 在收到
ctx.Done()后可主动退出； - ✅ 零泄漏保障：
errs.Wait()阻塞至所有子 goroutine 结束（成功或因 cancel 退出），无需手动 close channel 或 defer 清理； - ✅ 上下文集成：天然支持超时、取消与传递，便于与 HTTP 客户端、数据库等上下文感知组件协同；
- ✅ 语义清晰：
errs.Go(f)明确表达“此任务属于该错误组”，远胜裸go f()+ 手动 channel 管理。
示例代码（生产就绪版）
package main
import (
"context"
"fmt"
"math/rand"
"time"
"golang.org/x/sync/errgroup"
)
func fetchAll(ctx context.Context) error {
// 创建带上下文的 errgroup；所有子 goroutine 共享同一 ctx
g, ctx := errgroup.WithContext(ctx)
// 启动 4 个并行 fetch 任务
for i := 0; i < 4; i++ {
i := i // 必须捕获循环变量！
g.Go(func() error {
// 模拟网络请求：支持 ctx 超时检查（关键！）
select {
case <-time.After(time.Duration(rand.Intn(100)) * time.Millisecond):
// 请求完成
case <-ctx.Done():
return ctx.Err() // 上下文已取消，提前退出
}
// 模拟某次请求失败
if i == 2 {
return fmt.Errorf("fetch failed for resource %d", i)
}
return nil
})
}
// 阻塞等待所有任务结束，并返回首个非 nil 错误（或 nil）
return g.Wait()
}
func main() {
// 带 500ms 超时的调用示例
ctx, cancel := context.WithTimeout(context.Background(), 500*time.Millisecond)
defer cancel()
if err := fetchAll(ctx); err != nil {
fmt.Printf("Operation failed: %v\n", err) // 输出：Operation failed: fetch failed for resource 2
} else {
fmt.Println("All fetched successfully")
}
}关键注意事项
-
务必捕获循环变量：
for i := range ... { g.Go(func(){...}) }中需显式i := i，否则所有 goroutine 共享同一个i的最终值（常见陷阱）； -
主动响应
ctx.Done()：在耗时操作（如http.Get、time.Sleep、数据库查询）中应通过select检查上下文状态，避免忽略取消信号； -
错误类型一致性：
errgroup仅返回第一个非 nil 错误，因此业务逻辑中应确保关键错误优先返回（如认证失败 > 解析失败）； -
依赖引入：需执行
go get golang.org/x/sync/errgroup，该包由 Go 团队维护，稳定可靠，广泛用于 Kubernetes、Docker 等项目。
总结
告别手动 WaitGroup + chan error + context.WithCancel 的胶水代码。errgroup 是 Go 生态中处理「并行任务 + 快速失败 + 自动清理」这一经典模式的惯用解法。它让并发逻辑回归业务本质，同时提供生产级的可靠性与可观测性。对于任何需要并发执行且要求强错误语义的场景，errgroup 都应是你的首选工具。
