
当对未关闭的无缓冲通道使用 `for range` 时,循环会在所有已发送值被读取后持续阻塞,等待更多数据或通道关闭;若无 goroutine 再向通道写入且通道未关闭,程序将因所有 goroutine 休眠而触发死锁。
在 Go 中,for ele := range ch 是一种简洁遍历通道的方式,但它隐含一个重要前提:该通道最终必须被关闭。否则,一旦所有已发送的数据被消费完毕,range 循环会无限期阻塞,等待下一次接收——而此时若所有生产者 goroutine 已退出、且无人负责关闭通道,主 goroutine 就会永远卡住,运行时检测到“所有 goroutine 处于休眠状态”,从而 panic 报出 fatal error: all goroutines are asleep - deadlock!。
你的代码中,三个 sum_up goroutine 分别向 my_channel 发送 1、3、6(对应 i=2,3,4 的前 i 个自然数之和),并成功完成退出。但主 goroutine 的 for range 在读完这三个值后,并未终止,而是继续尝试从通道接收——而此时已无任何 goroutine 向该通道发送新值,且通道未被关闭,因此陷入永久阻塞。
关键点在于:range 不会因“发送端退出”自动结束,只响应“通道关闭”事件。即使所有写入 goroutine 执行完毕,只要通道未显式关闭,range 就不会退出。
✅ 正确做法是:在确认所有生产者完成写入后,由某个 goroutine(通常是协调者)调用 close(ch)。常见模式是结合 sync.WaitGroup 追踪活跃的生产者:
package main
import (
"fmt"
"sync"
)
func sum_up(my_int int, cs chan int, wg *sync.WaitGroup) {
defer wg.Done() // 确保无论何处返回都计数减一
my_sum := 0
for i := 0; i < my_int; i++ {
my_sum += i
}
cs <- my_sum
}
func main() {
var wg sync.WaitGroup
my_channel := make(chan int)
// 启动 3 个生产者 goroutine
for i := 2; i < 5; i++ {
wg.Add(1)
go sum_up(i, my_channel, &wg)
}
// 单独启动一个 goroutine:等待所有生产者完成,然后关闭通道
go func() {
wg.Wait()
close(my_channel) // ✅ 关键:通知 range 循环可以安全退出
}()
// 主 goroutine 安全遍历 —— 收到所有值后,遇到 closed channel 自动退出
for ele := range my_channel {
fmt.Println(ele)
}
fmt.Println("Done")
}⚠️ 注意事项:
- 不要在多个 goroutine 中重复调用 close(),会导致 panic;
- close() 只能用于 发送端已明确不再写入 的场景(通常由生产者方或协调者调用);
- 若使用带缓冲通道(如 make(chan int, 3)),仍需关闭才能让 range 正常退出;
- 替代方案包括:使用 select + done channel 实现超时或手动控制;或改用 for i := 0; i
总结:Go 的通道设计强调显式同步语义。for range 是便利语法糖,但绝非“自动感知生产者生命周期”的智能机制。理解“关闭通道 = 终止 range”这一契约,是写出健壮并发程序的基础。










