使用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 []string for 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会导致死锁。
