Golang并发任务:errgroup收集协程结果
一分耕耘,一分收获!既然打开了这篇文章《Golang并发任务编排:errgroup收集goroutine结果》,就坚持看下去吧!文中内容包含等等知识点...希望你能在阅读本文后,能真真实实学到知识或者帮你解决心中的疑惑,也欢迎大佬或者新人朋友们多留言评论,多给建议!谢谢!
errgroup是Golang中用于并发任务编排的工具,它简化了goroutine的错误处理和同步。1. 导入errgroup包;2. 使用errgroup.WithContext创建Group实例并绑定context;3. 通过g.Go启动返回error的goroutine执行任务;4. 所有任务通过select监听ctx.Done()响应取消信号;5. 调用g.Wait()等待所有任务完成并返回第一个出现的错误。相较于WaitGroup,errgroup支持错误收集与context取消机制,在多个goroutine同时出错时仅返回首个错误,若需收集全部错误,可结合channel自定义MultiError类型实现。正确使用时应确保goroutine及时清理资源并传播ctx.Err()。
Golang实现并发任务编排,核心在于有效管理和同步多个goroutine。errgroup
是一个强大的工具,可以帮助我们启动一组goroutine,并等待它们完成,同时收集它们的错误信息。它简化了错误处理,避免了手动管理channel和WaitGroup的复杂性。

解决方案
要使用errgroup
收集多个goroutine的结果,你需要做以下几步:

导入
errgroup
包: 在你的Go代码中,首先导入golang.org/x/sync/errgroup
包。创建
errgroup.Group
实例: 使用errgroup.WithContext(ctx)
创建一个新的errgroup.Group
实例。你可以传递一个context.Context
来控制整个goroutine组的生命周期。使用
Go
方法启动goroutine: 对于每个需要并发执行的任务,使用g.Go(func() error { ... })
启动一个新的goroutine。g.Go
接受一个返回error
的函数作为参数。在goroutine中执行任务并返回错误: 在每个goroutine中,执行你的任务逻辑。如果发生错误,返回该错误;否则,返回
nil
。使用
Wait
方法等待所有goroutine完成: 调用g.Wait()
方法来等待所有goroutine完成。Wait
方法会阻塞,直到所有goroutine都返回,或者context被取消。处理错误:
Wait
方法返回一个error
。如果任何一个goroutine返回了错误,Wait
会返回该错误。 如果多个goroutine返回错误,Wait
只会返回第一个遇到的错误。
下面是一个简单的例子:
package main import ( "context" "fmt" "golang.org/x/sync/errgroup" "log" "time" ) func main() { ctx := context.Background() g, ctx := errgroup.WithContext(ctx) var urls = []string{ "https://example.com", "https://www.google.com", "https://www.baidu.com", } results := make(chan string, len(urls)) // 创建一个channel来收集结果 for _, url := range urls { url := url // capture range variable g.Go(func() error { // 模拟一个耗时操作 time.Sleep(time.Second) // 模拟一个错误,例如url为空 if url == "" { return fmt.Errorf("url is empty") } result := fmt.Sprintf("Successfully fetched: %s", url) select { case results <- result: // 将结果发送到channel case <-ctx.Done(): // 如果context被取消,则退出 return ctx.Err() } return nil }) } if err := g.Wait(); err != nil { log.Fatalf("encountered error: %v\n", err) } close(results) // 关闭channel for result := range results { fmt.Println(result) } fmt.Println("Successfully fetched all URLs.") }
副标题1
errgroup
的Context取消机制是什么?如何正确使用?
errgroup
与 context.Context
紧密集成,提供了一种方便的方式来取消所有正在运行的 goroutine。当你使用 errgroup.WithContext(ctx)
创建 errgroup.Group
时,每个通过 g.Go
启动的 goroutine 都会继承这个 context。
当 context 被取消时(例如,通过调用 cancel()
函数),所有正在运行的 goroutine 都会收到取消信号。 这意味着你需要在你的 goroutine 中检查 ctx.Done()
channel,并在收到信号时停止执行。 上面的例子中 select
语句就演示了如何监听 ctx.Done()
。
正确使用 Context 取消机制的关键在于:
- 在每个 goroutine 中检查
ctx.Done()
: 确保你的 goroutine 能够响应取消信号。 - 及时清理资源: 在 goroutine 退出之前,释放任何已分配的资源(例如,关闭文件、释放内存)。
- 传播错误: 如果 goroutine 因为 context 取消而退出,返回
ctx.Err()
。
副标题2
errgroup
和 WaitGroup
的区别是什么?何时应该使用 errgroup
?
WaitGroup
和 errgroup
都是用于同步 goroutine 的工具,但它们有不同的侧重点:
WaitGroup
: 主要用于等待一组 goroutine 完成。你需要手动增加计数器 (Add
),在 goroutine 完成时减少计数器 (Done
),并使用Wait
方法阻塞直到计数器为零。它不提供内置的错误处理机制。errgroup
: 在WaitGroup
的基础上,增加了错误处理和 context 管理功能。它能够收集 goroutine 的错误,并在发生错误时取消所有正在运行的 goroutine。
何时使用 errgroup
:
- 需要并发执行多个任务,并且希望在任何一个任务失败时取消所有任务。
- 需要收集 goroutine 的错误信息。
- 需要使用 context 来控制 goroutine 的生命周期。
如果你只需要简单地等待一组 goroutine 完成,而不需要错误处理或 context 管理,那么 WaitGroup
可能更适合。 但是,在大多数并发任务编排场景中,errgroup
提供了更强大的功能和更方便的错误处理。
副标题3
errgroup
如何处理多个goroutine同时返回错误的情况?
errgroup
的设计理念是“快速失败”。 当多个goroutine同时返回错误时,errgroup
只会返回第一个遇到的错误。 其他的错误会被丢弃。
这种行为的原因是,通常情况下,并发任务编排的目标是尽快完成任务。 如果一个任务失败了,通常没有必要继续执行其他任务。 返回第一个错误可以帮助我们快速诊断问题并采取纠正措施。
如果你需要收集所有 goroutine 的错误信息,你需要自己实现一个错误收集机制。 例如,你可以创建一个 channel 来收集错误,并在每个 goroutine 中将错误发送到 channel。 然后,在 Wait
方法返回后,你可以从 channel 中读取所有错误。
需要注意的是,即使你收集了所有错误,你也只能返回其中一个错误。 你可以选择返回第一个错误,或者创建一个包含所有错误的自定义错误类型。
package main import ( "context" "fmt" "golang.org/x/sync/errgroup" "log" "time" ) type MultiError struct { Errors []error } func (m *MultiError) Error() string { if len(m.Errors) == 0 { return "no errors" } msg := "multiple errors occurred:\n" for _, err := range m.Errors { msg += fmt.Sprintf("- %v\n", err) } return msg } func main() { ctx := context.Background() g, ctx := errgroup.WithContext(ctx) var urls = []string{ "https://example.com", "invalid-url", // 故意制造一个错误 "https://www.baidu.com", "", // 故意制造一个错误 } errChan := make(chan error, len(urls)) // 创建一个channel来收集错误 var allErrors MultiError for _, url := range urls { url := url // capture range variable g.Go(func() error { // 模拟一个耗时操作 time.Sleep(time.Millisecond * 100) // 模拟一个错误,例如url为空 if url == "" { err := fmt.Errorf("url is empty") select { case errChan <- err: case <-ctx.Done(): return ctx.Err() } return err } if url == "invalid-url" { err := fmt.Errorf("invalid url format") select { case errChan <- err: case <-ctx.Done(): return ctx.Err() } return err } fmt.Printf("Successfully fetched: %s\n", url) return nil }) } if err := g.Wait(); err != nil { log.Printf("encountered error: %v\n", err) } close(errChan) for err := range errChan { allErrors.Errors = append(allErrors.Errors, err) } if len(allErrors.Errors) > 0 { log.Fatalf("%v", &allErrors) } fmt.Println("Successfully finished processing all URLs (with some errors).") }
这个例子演示了如何创建一个 MultiError
类型来收集所有错误,并在最后将它们打印出来。 注意,即使我们收集了所有错误,g.Wait()
仍然只会返回第一个遇到的错误。 我们使用 errChan
来收集所有错误。
好了,本文到此结束,带大家了解了《Golang并发任务:errgroup收集协程结果》,希望本文对你有所帮助!关注golang学习网公众号,给大家分享更多Golang知识!

- 上一篇
- DeepSeek+VSCode代码辅助配置指南

- 下一篇
- Golang树形结构递归处理解析
-
- Golang · Go教程 | 6小时前 |
- Golang错误处理与HTTP中间件实战解析
- 339浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Golang日志优化:异步缓冲提升效率
- 204浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Cgo性能优化:减少Go与C切换开销
- 144浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- GolangTCP优化与连接池调整技巧
- 307浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Golang优化技巧:TCP\_NODELAY与连接池应用
- 182浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Golang为何适合装饰器模式?函数式优势解析
- 355浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Golang错误处理与HTTP中间件实战解析
- 464浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Golang指针与unsafe.Pointer区别详解
- 363浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Golang模板测试方法与template_test教程
- 173浏览 收藏
-
- Golang · Go教程 | 6小时前 |
- Go和Cython对比:性能与用途解析
- 333浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 509次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 484次学习
-
- 边界AI平台
- 探索AI边界平台,领先的智能AI对话、写作与画图生成工具。高效便捷,满足多样化需求。立即体验!
- 388次使用
-
- 免费AI认证证书
- 科大讯飞AI大学堂推出免费大模型工程师认证,助力您掌握AI技能,提升职场竞争力。体系化学习,实战项目,权威认证,助您成为企业级大模型应用人才。
- 405次使用
-
- 茅茅虫AIGC检测
- 茅茅虫AIGC检测,湖南茅茅虫科技有限公司倾力打造,运用NLP技术精准识别AI生成文本,提供论文、专著等学术文本的AIGC检测服务。支持多种格式,生成可视化报告,保障您的学术诚信和内容质量。
- 540次使用
-
- 赛林匹克平台(Challympics)
- 探索赛林匹克平台Challympics,一个聚焦人工智能、算力算法、量子计算等前沿技术的赛事聚合平台。连接产学研用,助力科技创新与产业升级。
- 638次使用
-
- 笔格AIPPT
- SEO 笔格AIPPT是135编辑器推出的AI智能PPT制作平台,依托DeepSeek大模型,实现智能大纲生成、一键PPT生成、AI文字优化、图像生成等功能。免费试用,提升PPT制作效率,适用于商务演示、教育培训等多种场景。
- 545次使用
-
- Golangmap实践及实现原理解析
- 2022-12-28 505浏览
-
- 试了下Golang实现try catch的方法
- 2022-12-27 502浏览
-
- Go语言中Slice常见陷阱与避免方法详解
- 2023-02-25 501浏览
-
- Golang中for循环遍历避坑指南
- 2023-05-12 501浏览
-
- Go语言中的RPC框架原理与应用
- 2023-06-01 501浏览