Go语言并发编程死锁：如何避免`all goroutines are asleep

Go语言并发编程死锁：如何避免`all goroutines are asleep - deadlock!`错误？

花韻仙語

发布： 2025-03-09 08:42:20

原创

745人浏览过

go语言并发编程死锁：如何避免`all goroutines are asleep - deadlock!`错误？

Go并发编程中的死锁陷阱及规避方法

在Go语言并发编程中，fatal error: all goroutines are asleep - deadlock!错误是常见的死锁现象。本文通过一个示例代码，分析死锁原因并提供有效的解决方法。

以下代码片段演示了死锁场景：

package main

import (
    "fmt"
)

var foo6Chan = make(chan int, 10)

func foo6() {
    for val := range foo6Chan {
        go func() {
            fmt.Printf("foo6 val = %d\n", val)
        }()
    }
}

func main() {
    foo6Chan <- 1
    foo6Chan <- 2
    foo6Chan <- 3
    foo6() // 死锁发生在此处
}

登录后复制

这段代码的死锁原因在于：foo6函数中的for...range循环阻塞在foo6Chan的接收操作上，等待新的数据。而main函数在发送数据后，直接调用foo6函数，导致main函数等待foo6函数结束，foo6函数又等待foo6Chan有数据，形成循环依赖，最终造成死锁。

立即学习“go语言免费学习笔记（深入）”；

简单地将foo6()改为go foo6()虽然可以避免立即报错，但只是掩盖了问题，并非正确的解决方法。 main函数仍然可能在foo6函数处理完数据之前结束，导致数据丢失或程序不稳定。

正确的解决方法是显式地关闭foo6Chan通道。在main函数发送完所有数据后，使用close(foo6Chan)关闭通道，通知foo6函数循环结束。修改后的代码如下：

package main

import (
    "fmt"
)

var foo6Chan = make(chan int, 10)

func foo6() {
    for val := range foo6Chan {
        go func() {
            fmt.Printf("foo6 val = %d\n", val)
        }()
    }
}

func main() {
    foo6Chan <- 1
    foo6Chan <- 2
    foo6Chan <- 3
    go foo6() // 将foo6函数放入goroutine中并发执行
    close(foo6Chan) // 关闭通道，避免死锁
}

登录后复制

通过显式关闭通道，for...range循环能够正确结束，从而有效避免了死锁，确保程序的稳定性和可靠性。这才是处理Go并发编程中死锁问题的最佳实践。

以上就是Go语言并发编程死锁：如何避免`all goroutines are asleep - deadlock!`错误？的详细内容，更多请关注php中文网其它相关文章！