
go 中对未关闭的无缓冲通道执行 `for range` 会永久阻塞,导致所有 goroutine 休眠而触发死锁;必须在所有发送者完成写入后显式关闭通道,才能让 range 循环正常退出。
在 Go 并发编程中,for ele := range ch 是遍历通道的惯用写法,但它有一个关键前提:该通道必须被关闭(closed),否则循环将永远等待下一个值——即使所有生产者 goroutine 已执行完毕并退出。
你遇到的死锁正是源于此:程序启动了 3 个 sum_up goroutine 向 my_channel 发送数据(对应 i=2,3,4,结果分别为 1, 3, 6),主 goroutine 通过 for range 成功读取这 3 个值并打印。但此时通道仍处于打开状态,range 循环继续尝试接收第 4 个值,而所有 sum_up goroutine 已结束、无其他 goroutine 向通道写入,也无人关闭通道——于是主 goroutine 阻塞,其余 goroutine 全部退出,最终触发 fatal error: all goroutines are asleep - deadlock!。
✅ 正确解法是:确保通道在所有发送操作完成后被关闭。由于发送操作在多个 goroutine 中异步进行,不能由主 goroutine 直接判断何时关闭,因此需借助同步原语协调。常用且推荐的方式是 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() {
wg := &sync.WaitGroup{}
my_channel := make(chan int)
// 启动 3 个并发任务
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 安全遍历(自动在 close 后终止)
for ele := range my_channel {
fmt.Println(ele)
}
fmt.Println("Done")
}? 关键要点总结:
- for range ch 仅在通道 关闭后自动退出,它不会因“暂无数据”而停止,也不会感知发送者是否存活;
- 关闭通道的责任应由协调者(通常是启动 goroutine 的一方)承担,而非发送者——因为单个发送者无法知道其他发送者是否已完成;
- 使用 defer wg.Done() 可提升代码健壮性,避免 panic 时漏掉计数;
- 切勿在多个 goroutine 中重复调用 close(ch),会导致 panic;确保仅关闭一次(本例中由 wg.Wait() 后的唯一 goroutine 执行);
- 若需带超时或更复杂控制,可结合 select + time.After 或 context,但本场景 WaitGroup + close 是最简洁、标准的解决方案。
遵循这一模式,即可安全、清晰地实现多生产者 → 单消费者通道遍历,彻底规避此类死锁问题。









