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 </p><div class="aritcle_card flexRow artxards">
<div class="artcardd flexRow">
<a class="aritcle_card_img" rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件"><img
src="https://img.php.cn/upload/webcode/000/000/164/636a2b4d84031727.png" alt="使用Go语言搭建家庭相册系统-相关课件" onerror="this.onerror='';this.src='/static/lhimages/moren/morentu.png'" ></a>
<div class="aritcle_card_info flexColumn">
<a rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件" class="overflowclass">使用Go语言搭建家庭相册系统-相关课件</a>
<p class="overflowclass">使用Go语言搭建家庭相册系统-相关课件</p>
</div>
<a rel="nofollow" href="/xiazai/learn/7564" title="使用Go语言搭建家庭相册系统-相关课件" class="aritcle_card_btn flexRow flexcenter"><b></b><span>下载</span>
</a>
</div>
</div><p>// 单独 goroutine 等待并关闭
go func() {
wg.Wait()
close(results)
}()</p><p>for res := range results {
fmt.Println(res) // 输出 0 1 4 9 16
}</p>
- 缓冲区大小建议设为任务数（如
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)
}</p>
- 避免用
interface{}或map[string]interface{}做泛型结果，类型丢失导致后续难维护 - 如果错误需要中断整个流程（比如认证失败），可在发送前加判断，或让主协程收到特定错误后 break
- 注意：
nilerror 在 struct 里默认就是nil，不用额外初始化
当结果量大或耗时长时，考虑带超时的 select 读取
如果某些子任务可能卡住（如网络请求 hang 住），不能无限制等下去。这时要在主协程用 select 控制单次读取时间，而不是依赖 range ——因为 range 无法中断。
timeout := time.After(3 * time.Second) for i := 0; i
- 用
time.After而非time.NewTimer，简单场景够用；注意它是一次性 timer - 如果只是防止单个结果延迟，用这个模式；如果要整体超时（比如最多等 3 秒收齐所有结果），则应在
WaitGroup等待时加超时 - 不要在 select 里重复使用同一个
timeoutchannel，它会只触发一次；需要重置就用time.AfterFunc或新建 timer
关键点其实就两个：谁关 channel、什么时候关。很多人卡在“为什么 range 不退出”，答案往往就藏在 close() 是否被执行、是否被执行了多次、是否在正确时机执行。
