使用channel和WaitGroup聚合并发结果：启动多个goroutine将Result写入缓冲channel，wg确保所有任务完成，主协程range读取结果并处理错误。
在Go语言中处理并发任务的结果聚合，核心在于合理使用goroutine、channel和sync包。当多个任务并行执行后，需要将它们的结果安全地收集并整合，常见于爬虫、批量请求、数据计算等场景。关键点是避免竞态条件，确保所有任务完成后再进行结果处理。
使用channel接收并发结果
最常用的方式是通过带缓冲的channel传递每个任务的返回值。每个goroutine执行完后将结果写入channel，主协程从channel读取并聚合。
定义一个结果结构体，包含数据和可能的错误信息，便于统一处理：
type Result struct { Data string Err error}
启动多个goroutine，将结果发送到同一channel：
立即学习“go语言免费学习笔记（深入）”；
创建缓冲channel，容量等于任务数，避免阻塞每个任务完成后调用resultCh 主协程循环读取channel，直到所有结果到达
结合WaitGroup控制任务生命周期
sync.WaitGroup用于等待所有goroutine结束。它不传递数据，但能确保所有任务完成后再关闭channel，防止读取未完成的结果。
典型流程如下：
在启动goroutine前调用wg.Add(1)每个goroutine执行完后执行defer wg.Done()另起一个goroutine等待wg完成，并关闭结果channel
这样主协程可以用for result := range resultCh安全遍历所有结果。
错误处理与超时控制
实际应用中需考虑失败任务和执行时间过长的情况。可通过context.WithTimeout设置全局超时，所有goroutine监听ctx.Done()信号提前退出。
错误聚合建议单独收集，例如定义error切片或计数器，不影响正常结果的汇总。
若某个任务失败不需要中断整体流程，可在Result结构中包含Err字段，在聚合阶段统一判断。
实际聚合示例
假设发起5个HTTP请求并收集响应体：
resultCh := make(chan Result, 5)var wg sync.WaitGroupfor i := 0; i < 5; i++ {wg.Add(1)go func(id int) {defer wg.Done()data, err := fetchURL(fmt.Sprintf("https://www.php.cn/link/a999280d94b62f32e136b75017a67a85", id))resultCh <- Result{Data: string(data), Err: err}}(i)}
go func() {wg.Wait()close(resultCh)}()
var results []stringfor result := range resultCh {if result.Err != nil {log.Printf("Task failed: %v", result.Err)continue}results = append(results, result.Data)}
最终results切片即为所有成功任务的返回值集合。
基本上就这些。channel负责传数据，WaitGroup保完成，context管超时，结构清晰且易于扩展。不复杂但容易忽略细节，比如忘记关闭channel会导致死锁。
以上就是Golang如何处理并发任务的结果聚合_Golang并发结果聚合实践详解的详细内容，更多请关注创想鸟其它相关文章！
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。
如发现本站有涉嫌抄袭侵权/违法违规的内容， 请发送邮件至 chuangxiangniao@163.com 举报，一经查实，本站将立刻删除。
发布者：程序猿，转转请注明出处：https://www.chuangxiangniao.com/p/1422563.html
微信扫一扫 
支付宝扫一扫 
