channel用于并发写、顺序读,收集多goroutine结果;需用sync.WaitGroup配合显式close确保安全遍历,推荐缓冲通道+结构体封装结果与错误,避免漏数据或panic。

channel 用来收集多协程结果,本质是「并发写 + 顺序读」
Go 中用 channel 收集多个 goroutine 的结果,核心不是“怎么启动协程”,而是确保所有结果能安全、完整、按需地被主协程拿到。最常见错误是:忘了关闭 channel 导致 range 卡死,或没做同步直接读空 channel。
典型场景是「发多个 HTTP 请求」「查多个数据库表」「并行计算分片数据」——每个子任务产出一个值(或结构体),主协程等全部完成再统一处理。
- 必须用
close()显式关闭发送端,否则for range ch永远阻塞 - 不要在多个 goroutine 里都调
close(ch),会 panic:close of closed channel - 如果某个 goroutine 可能 panic 或提前退出,需用
recover或defer确保关闭逻辑执行
用 sync.WaitGroup 配合 channel 关闭最稳妥
靠超时或计数器判断完成不可靠;WaitGroup 是 Go 官方推荐的等待协程结束的方式,它和 channel 关闭天然契合:所有任务结束 → 关闭 channel → 主协程退出 range。
results := make(chan int, 10)
var wg sync.WaitGroup
<p>for i := 0; i < 5; i++ {
wg.Add(1)
go func(n int) {
defer wg.Done()
results <- n * n // 模拟计算
}(i)
}</p><p>// 单独 goroutine 等待并关闭
go func() {
wg.Wait()
close(results)
}()</p><p>for res := range results {
fmt.Println(res) // 输出 0 1 4 9 16
}- 缓冲区大小建议设为任务数(如
make(chan T, N)),避免发送阻塞影响协程退出 - 关闭操作必须在独立 goroutine 里做,不能放循环后——否则主协程还没开始
range就关了 - 不用
select+default读 channel,那会漏数据;range是唯一安全遍历方式
带错误的结果收集:用结构体封装 value 和 error
实际业务中,不是所有子任务都成功。若用两个 channel 分别传结果和错误,主协程要同时 select,逻辑复杂且易漏处理。更简洁的做法是定义结果结构体,统一走一个 channel。
type Result struct {
Value int
Err error
}
<p>results := make(chan Result, 5)
// ... 启动 goroutine,每个都 send Result{Value: x, Err: err}
// 主协程:
for r := range results {
if r.Err != nil {
log.Printf("task failed: %v", r.Err)
continue
}
process(r.Value)
}- 避免用
interface{}或map[string]interface{}做泛型结果,类型丢失导致后续难维护 - 如果错误需要中断整个流程(比如认证失败),可在发送前加判断,或让主协程收到特定错误后 break
- 注意:
nilerror 在 struct 里默认就是nil,不用额外初始化
当结果量大或耗时长时,考虑带超时的 select 读取
如果某些子任务可能卡住(如网络请求 hang 住),不能无限制等下去。这时要在主协程用 select 控制单次读取时间,而不是依赖 range ——因为 range 无法中断。
timeout := time.After(3 * time.Second)
for i := 0; i < 5; i++ {
select {
case r := <-results:
handle(r)
case <-timeout:
log.Println("timeout waiting for result")
return // 或继续收剩余结果
}
}- 用
time.After而非time.NewTimer,简单场景够用;注意它是一次性 timer - 如果只是防止单个结果延迟,用这个模式;如果要整体超时(比如最多等 3 秒收齐所有结果),则应在
WaitGroup等待时加超时 - 不要在 select 里重复使用同一个
timeoutchannel,它会只触发一次;需要重置就用time.AfterFunc或新建 timer
关键点其实就两个:谁关 channel、什么时候关。很多人卡在“为什么 range 不退出”,答案往往就藏在 close() 是否被执行、是否被执行了多次、是否在正确时机执行。


















