使用errgroup可实现并发任务的错误收集与快速失败，通过WithContext支持取消机制；若需汇总所有错误，则可用带缓冲channel配合WaitGroup，避免阻塞并确保正确关闭。
在Go语言中处理并发任务时，经常会遇到多个goroutine同时执行并可能返回错误的情况。如何安全地收集这些错误，并在所有任务完成或任意一个任务出错时做出响应，是编写健壮并发程序的关键。下面是一个实用的错误收集与处理示例。
使用errgroup.Group（推荐方式）
errgroup 是官方扩展包 golang.org/x/sync/errgroup 提供的工具，能简化并发任务的错误传播和等待逻辑。
它允许你启动多个goroutine，并在任意一个返回非nil错误时自动取消其他任务（如果配合context使用），同时只返回第一个发生的错误。
示例代码：
package mainimport ("context""fmt""time"
"golang.org/x/sync/errgroup"
)
立即学习“go语言免费学习笔记（深入）”；
func main() {ctx := context.Background()g, ctx := errgroup.WithContext(ctx)
urls := []string{ "https://httpbin.org/status/200", "https://www.php.cn/link/874b2add857bd9bcc60635a51eb2b697", // 模拟失败 "https://httpbin.org/status/200",}for _, url := range urls { url := url // 注意变量捕获 g.Go(func() error { return fetchURL(ctx, url) })}if err := g.Wait(); err != nil { fmt.Printf("请求失败: %vn", err)} else { fmt.Println("所有任务成功完成")}
}
func fetchURL(ctx context.Context, url string) error {select {case https://www.php.cn/link/874b2add857bd9bcc60635a51eb2b697" {return fmt.Errorf("请求 %s 失败，服务器错误", url)}fmt.Printf("成功获取: %sn", url)return nilcase
在这个例子中，只要有一个fetchURL返回错误，g.Wait() 就会立即返回该错误，其余正在运行的任务也会因context被取消而尽快退出。
手动通过channel收集所有错误
如果你希望收集所有任务的错误而不是仅第一个，可以使用带缓冲的error channel。
这种方式适合需要汇总全部结果的场景，比如批量任务中统计成功与失败数量。
示例代码：
package mainimport ("fmt""sync")
func main() {var wg sync.WaitGrouperrCh := make(chan error, 3) // 缓冲channel，避免阻塞
tasks := []string{"task-1", "task-2", "task-3"}for _, task := range tasks { wg.Add(1) go func(t string) { defer wg.Done() err := processTask(t) if err != nil { errCh 0 { fmt.Printf("共发生 %d 个错误:n", len(errors)) for _, e := range errors { fmt.Println(e) }} else { fmt.Println("所有任务成功")}
}
func processTask(name string) error {if name == "task-2" {return fmt.Errorf("模拟处理失败")}fmt.Printf("任务 %s 成功完成n", name)return nil}
注意：errCh 必须有足够容量或由独立goroutine接收，否则发送错误可能导致goroutine阻塞，进而引发deadlock。
选择合适的策略
选择哪种方式取决于你的业务需求：
想在第一个错误发生时快速失败？用 errgroup需要知道所有任务的执行结果？用 error channel + WaitGroup任务间有关联且需取消机制？结合 context 使用 errgroup
基本上就这些。实际项目中推荐优先使用 errgroup，简洁且语义清晰。手动管理错误channel则提供更大的灵活性，但要注意资源释放和channel关闭问题。
以上就是Golang并发任务错误收集与处理示例的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1411175.html
微信扫一扫 
支付宝扫一扫 
