跳转到主内容
新派编程网 - 新潮编程理念,全新技术课堂!

如何正确使用 for-range 遍历 Go 中的无缓冲通道以避免死锁

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数组安全、编译 下载
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 是最简洁、标准的解决方案。 遵循这一模式,即可安全、清晰地实现多生产者 → 单消费者通道遍历,彻底规避此类死锁问题。

相关文章