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:
go语言参考手册 中文CHM版
Go 是一个开源的编程语言,它能让构造简单、可靠且高效的软件变得容易。本文给大家带来Go参考手册,需要的可以来下载! Go是从2007年末由Robert Griesemer, Rob Pike, Ken Thompson主持开发,后来还加入了Ian Lance Taylor, Russ Cox等人,并最终于2009年11月开源,在2012年早些时候发布了Go 1稳定版本。现在Go的开发已经是完全开放的,并且拥有一个活跃的社区。 Go 语言特色 简洁、快速、安全 并行、有趣、开源 内存管理、v数组安全、编译
下载
?
关键要点总结:
for range ch 仅在通道
关闭后自动退出
,它不会因“暂无数据”而停止,也不会感知发送者是否存活;
关闭通道的责任应由
协调者
(通常是启动 goroutine 的一方)承担,而非发送者——因为单个发送者无法知道其他发送者是否已完成;
使用 defer wg.Done() 可提升代码健壮性,避免 panic 时漏掉计数;
切勿在多个 goroutine 中重复调用 close(ch),会导致 panic;确保仅关闭一次(本例中由 wg.Wait() 后的唯一 goroutine 执行);
若需带超时或更复杂控制,可结合 select + time.After 或 context,但本场景 WaitGroup + close 是最简洁、标准的解决方案。
遵循这一模式,即可安全、清晰地实现多生产者 → 单消费者通道遍历,彻底规避此类死锁问题。
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")
}