Go语言死锁及解决方案:fatal error: all goroutines are asleep - deadlock!
在Go语言并发编程中,死锁 (fatal error: all goroutines are asleep - deadlock!) 是一种常见且棘手的问题。本文将通过一个示例代码,深入剖析死锁的成因,并提供有效的解决方法。
示例代码使用带缓冲的通道 foo6chan 实现 Goroutine 间通信。foo6 函数从 foo6chan 读取数据,并启动新的 Goroutine 打印数据。main 函数向 foo6chan 写入数据,然后调用 foo6 函数。
当直接调用 foo6()(而非 go foo6())时,main 函数会阻塞在 foo6 函数的 for...range 循环中,等待 foo6chan 中的数据。由于 foo6chan 没有关闭,循环无限等待,main 函数也无其他操作,导致所有 Goroutine 休眠,从而引发死锁。
即使使用 go foo6(),问题也并未真正解决。foo6 函数在新的 Goroutine 中运行,main 函数继续执行,写入数据后休眠。foo6 Goroutine 消费数据直到 foo6chan 为空并阻塞。2秒后,main 函数结束,强制终止所有 Goroutine,避免了死锁错误,但这只是掩盖了潜在问题。
根本解决死锁的关键在于正确地管理通道。在写入数据后,必须调用 close(foo6chan) 关闭通道,以便 for...range 循环能够正常结束。
改进后的代码如下:
package main import ( "fmt" ) var ( foo6Chan = make(chan int, 10) ) func foo6() { for val := range foo6Chan { go func() { fmt.Printf("foo6 val = %d ", val) }() } } func main() { foo6Chan <- 1 foo6Chan <- 2 foo6Chan <- 3 close(foo6Chan) // 关闭通道 foo6() }
通过显式关闭 foo6Chan,for...range 循环能够检测到通道已关闭并优雅退出,有效避免了死锁。 这才是彻底解决 Go 语言死锁问题的正确方法。