
当对未关闭的无缓冲通道使用 `for range` 时,循环会在所有值被读取后持续阻塞,等待更多数据或通道关闭;若无人关闭通道,主 goroutine 将永远等待,而其他 goroutine 已执行完毕并退出,最终触发“all goroutines are asleep”死锁。
在 Go 中,for v := range ch 语句的本质是持续从通道接收值,直到通道被显式关闭。它不会因“当前无数据”而退出,也不会自动感知“发送方已全部结束”——Go 没有内置机制让接收方推断发送是否完成。因此,若通道保持开启状态,range 循环将无限期阻塞,导致程序卡死。
你的代码中,三个 sum_up goroutine 分别向 my_channel 发送 1、3、6 后正常退出,但没有任何 goroutine 负责关闭通道。此时主 goroutine 在打印完三个值后,继续执行 range 的下一次迭代,试图接收第四个值,却始终无法从已无发送者的通道中获得数据或关闭信号,于是永久阻塞。而其他 goroutine 已全部终止,整个程序陷入死锁。
✅ 正确做法是:在确认所有发送操作完成后,由某个 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() // 确保即使 panic 也能通知 WaitGroup
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 自动退出
}()
// 安全遍历:range 在收到 close() 后自然结束
for ele := range my_channel {
fmt.Println(ele)
}
fmt.Println("Done")
}⚠️ 注意事项:
- 不要在发送 goroutine 内直接 close(ch):多个 goroutine 同时关闭同一通道会 panic;
- close() 应由单一协调者(如本例中的匿名 goroutine)调用,且必须在所有发送完成之后;
- 使用 defer wg.Done() 可提升健壮性;
- 若通道为带缓冲且容量足够,仍需关闭才能让 range 终止——缓冲区满/空不影响 range 对关闭状态的依赖。
总结:for range ch 不是“读完现有数据就停”,而是“读到通道关闭才停”。牢记「谁发送,谁不关;谁协调,谁关闭」的原则,即可避免此类经典死锁。









