本文深入剖析 go 官方 codewalk 示例中“通过通信共享资源”的设计思想，重点解释为何 poller goroutine 能持续运行、channel 的生命周期如何决定循环行为，以及为何程序看似“停止响应”实则符合预期——关键在于理解 channel 的阻塞语义与未关闭状态下的无限读取语义。
本文深入剖析 go 官方 codewalk 示例中“通过通信共享资源”的设计思想，重点解释为何 poller goroutine 能持续运行、channel 的生命周期如何决定循环行为，以及为何程序看似“停止响应”实则符合预期——关键在于理解 channel 的阻塞语义与未关闭状态下的无限读取语义。
Go 官方文档中的
Codewalk: Sharing Resources by Communicating
是理解 Go 并发模型哲学的经典范例。它摒弃了传统“共享内存 + 锁”的思路，转而采用“通过通信共享资源”（Share Memory By Communicating）的信条，用 channel 作为协调枢纽，构建出简洁、可扩展的并发工作流。
该示例包含三个核心组件：
pending：输入通道，接收待轮询的 URL 资源；
complete：输出通道，接收已完成轮询的资源；
status：状态通道，向监控器（StateMonitor）广播当前健康状态。
主函数启动固定数量的 Poller goroutine（例如 numPollers = 2），并一次性将初始 URL 列表推入 pending：
关键点在于 Poller 函数的主体逻辑：
这里常被误解的是：for r := range in 看似在遍历一个“有限集合”，实则它是一个
阻塞式无限迭代器
——只要 in 通道未被显式关闭（close(in)），该循环就永不停止；每次迭代都阻塞等待下一个值到达。in 在此即为 pending 通道本身，而非其副本或快照。
因此，整个流程是
生产者-消费者流水线
：
主 goroutine 是初始生产者（发 3 个 URL），但后续仍可继续发送；
每个 Poller 是并发消费者：一旦完成一次 r.Poll()，即刻返回 out 并立即准备接收下一个 pending 中的任务；
StateMonitor 从 status 持续消费状态，实时更新日志。
✅ 正确理解：range ch 的终止条件
唯一且明确
——仅当 ch 被 close() 后，循环才会自然退出；否则，它永远等待新值，goroutine 保持活跃。
你观察到“Wi-Fi 开关后日志只更新几轮就停滞”，并非程序 bug，而是因为：
示例中主函数
未实现动态重投任务
：初始 3 个 URL 发送完毕后，pending 再无新数据；
所有 Poller 在处理完这 3 个任务后，全部阻塞在 for r := range pending 上，等待下一个 URL —— 而这个“下一个”永远不会到来；
StateMonitor 同样阻塞在 for s := range status，但由于 Poller 已停止发送新状态，它也静默等待。
✅
修复方法很简单
：在主 goroutine 中添加一个定时重发逻辑，使 pending 持续有新任务：
此时，Poller 将真正实现“无限轮询”，StateMonitor 也能持续刷新日志，完整体现“通信驱动并发”的设计威力。
总结
：
Go 中 for v := range ch 不是遍历容器，而是监听通道生命周期；
未关闭的 channel = 永不结束的阻塞读取；
“无限循环”本质是并发系统对持续输入的自然响应，而非代码缺陷；
真正的健壮性来源于明确控制 channel 的创建、使用与关闭时机——这是掌握 Go 并发编程的基石。
for i := 0; i < numPollers; i++ {
go Poller(pending, complete, status)
}
for _, url := range urls {
pending <- &Resource{url: url} // 发送 3 个初始任务
}func Poller(in, out chan *Resource, status chan State) {
for r := range in { // ← 核心：range over unbuffered/un-closed channel
s := r.Poll()
status <- State{r.url, s}
out <- r
}
}go func() {
ticker := time.NewTicker(5 * time.Second)
defer ticker.Stop()
for range ticker.C {
for _, url := range urls {
pending <- &Resource{url: url} // 循环注入，维持 pipeline 活性
}
}
}()