本文详解 go 程序中 “all goroutines are asleep - deadlock” 错误的根本原因，指出缓冲通道误用、waitgroup 传值陷阱及通道关闭时机不当等关键问题，并提供符合 go 并发哲学的无缓冲通道 + 协程化关闭方案。
本文详解 go 程序中 “all goroutines are asleep - deadlock” 错误的根本原因，指出缓冲通道误用、waitgroup 传值陷阱及通道关闭时机不当等关键问题，并提供符合 go 并发哲学的无缓冲通道 + 协程化关闭方案。
在 Go 并发编程中，fatal error: all goroutines are asleep - deadlock! 是一个典型且令人困惑的运行时错误。它并非源于语法或类型错误，而是由协程间通信逻辑阻塞且无任何协程可继续推进所导致。你提供的代码看似合理：使用了容量为 2 的缓冲通道、启用了多个 goroutine 写入、调用 wg.Wait() 同步、最后遍历通道——但恰恰在这些环节中埋下了死锁隐患。
? 死锁根源分析
sync.WaitGroup被值传递（致命错误）doSomething(c, wg)中将wg作为参数传入，而sync.WaitGroup是非线程安全的值类型。每个 goroutine 实际操作的是wg的副本，wg.Done()不会影响主 goroutine 中的原始实例。因此wg.Wait()将永远阻塞，主 goroutine 无法继续执行close(c)和后续for range，而所有写 goroutine 在尝试向已满缓冲通道（容量为 2，却启动 3 个写操作）发送数据时也会阻塞——全部协程陷入休眠，触发死锁。缓冲通道容量与写操作数量不匹配
即使WaitGroup修复，make(chan int, 2)仅能暂存 2 个值，但 3 个 goroutine 同时执行c 。前两个可立即写入，第三个将永久阻塞（因无读取者在运行），直到有 goroutine 开始从通道读取——而读取逻辑被卡在 <code>wg.Wait()之后。这是典型的生产者超前、消费者滞后导致的隐式阻塞。close(c)位置错误且缺乏同步保障close(c)放在wg.Wait()之后看似“安全”，但此时写操作早已全部阻塞或完成；更严重的是，若wg.Wait()永不返回（如上所述），close(c)根本不会执行，for v := range c将无限等待通道关闭，进一步加剧死锁。
✅ 正确解法：无缓冲通道 + 关闭协程化
遵循 Go 的并发信条——“不要通过共享内存来通信，而应通过通信来共享内存”，我们应让通道成为协调的核心枢纽，而非依赖外部同步原语控制时序：
package main
import "fmt"
func main() {
c := make(chan int) // 使用无缓冲通道，强制写操作等待读者就绪
var wg sync.WaitGroup
wg.Add(3)
// 启动 3 个写 goroutine（注意：wg 仅在声明作用域内使用）
go func() { doSomething(c); wg.Done() }()
go func() { doSomething(c); wg.Done() }()
go func() { doSomething(c); wg.Done() }()
// 单独协程负责等待并关闭通道——解耦同步与通信
go func() {
wg.Wait()
close(c) // 确保所有写入完成后才关闭
}()
// 立即开始消费！range 会自动等待新值并感知关闭
for v := range c {
fmt.Print(v)
}
}
func doSomething(c chan<- int) {
c <- 1 // 写入将阻塞，直到 for range 取走该值（体现背压）
}✅ 在线验证链接
? 关键设计原则说明
-
WaitGroup不跨作用域传递：始终在定义它的 goroutine 内完成Add/Done/Wait，避免副本失效问题； - 通道类型选择依据语义而非“防阻塞”：无缓冲通道天然实现同步（sender 等待 receiver），是构建响应式流水线的基础；缓冲通道仅适用于明确需要解耦突发写入与稳定消费的场景（如日志缓冲），且容量需严格评估；
-
关闭通道的责任单一化：由唯一确定所有写操作已完成的协程执行
close()，且必须确保在所有c 之后（本例中由 <code>wg.Wait()保证）； -
消费逻辑前置：
for range c可立即启动，无需等待所有生产者结束——这正是 Go 通道“流式处理”的优势：数据一就绪即可处理，降低端到端延迟。
⚠️ 注意事项
- 切勿在多个 goroutine 中重复调用
close(c)，会导致 panic； - 向已关闭的通道发送数据会 panic，务必确保
close()时机绝对晚于最后一次写入； - 若需在
for range中提前退出（如错误处理），应使用break并确保其他 goroutine 能被取消（可通过 context 实现）； - 对于复杂管道，推荐使用
errgroup.Group或context统一管理生命周期，而非手动组合sync.WaitGroup与通道。
通过以上重构，代码不仅消除了死锁，更体现了 Go 并发模型的简洁性与健壮性：以通道为纽带，用 goroutine 分工协作，让同步逻辑自然融入数据流之中。
