在Go语言的并发编程里,死锁(Deadlock)绝对算得上最让人头疼的错误之一——它极其隐蔽,破坏力又极强。要打个比方的话,就像交通堵塞:每辆车(Goroutine)都死等着别的车先动,结果谁也走不了,整个程序就卡在那儿了。

Go并发编程避坑指南之如何彻底解决死锁Deadlock问题

死锁要是真发生了,你可能会看到类似 fatal error: all goroutines are asleep - deadlock! 这样的错误信息,或者干脆连报错都没有,程序直接卡死,CPU占用率低得可怜。这篇文章就来把这个“老大难”问题掰开揉碎了说清楚,从成因到应对方案,结合 sync 包和 context 包,给出几条真正管用的路径。

一、先搞清楚死锁是怎么来的:四个必要条件

要解决死锁,得先明白它到底是怎么形成的。在Go里,死锁的出现通常离不开下面这四个条件:

  1. 互斥条件:sync.Mutex 这类资源,一次只能被一个 Goroutine 占用。
  2. 持有并等待: 一个 Goroutine 手里攥着资源A,同时还惦记着资源B,不肯松手。
  3. 不可剥夺: 资源只能由持有者主动释放,你没法硬抢。
  4. 循环等待: 比如Goroutine A在等B,B在等A,这就成了一个闭环。

反过来想,只要能打破这四个条件中的任何一个,死锁就不会发生。这是最根本的逻辑。

二、那些常见的死锁场景,以及怎么修

1. 嵌套锁定与顺序不一致,也就是AB-BA问题

这几乎是死锁里最经典的案例了。简单来说,就是两个Goroutine以不同的顺序去获取同一组锁,那结果必然是“撞车”。

看看错误的写法:

var mu1, mu2 sync.Mutex

// Goroutine 1: 先拿 mu1,再拿 mu2
go func() {
    mu1.Lock()
    defer mu1.Unlock()
    time.Sleep(time.Millisecond) // 模拟一点处理时间
    mu2.Lock() // 卡住了!因为 mu2 可能已经被 Goroutine 2 拿走了
    defer mu2.Unlock()
    fmt.Println("G1 done")
}()

// Goroutine 2: 先拿 mu2,再拿 mu1
go func() {
    mu2.Lock()
    defer mu2.Unlock()
    time.Sleep(time.Millisecond)
    mu1.Lock() // 也卡住了!因为 mu1 被 Goroutine 1 拿走了
    defer mu1.Unlock()
    fmt.Println("G2 done")
}()

结果就是,两个Goroutine互相掐着对方想要的锁,谁也动弹不了。这事儿的关键在于,你得给锁定个规矩。

解决办法:固定顺序获取锁
如果业务需要同时拿多个锁,那就定个死规矩:永远按照同一个顺序来。比如可以按内存地址排序,或者代码里定义的先后顺序。

// 统一规定:总是先锁 mu1,再锁 mu2
func safeOperation() {
    mu1.Lock()
    defer mu1.Unlock()
    
    mu2.Lock()
    defer mu2.Unlock()
    
    // 执行临界区代码
}

2. 重复加锁,也就是“自死锁”

必须得记牢一点:Go 的 sync.Mutex不可重入的。换句话说,如果在同一个 Goroutine 里,你已经拿着这把锁了,又想再对它加一次锁,那程序立刻就会死锁。

错误的代码长这样:

var mu sync.Mutex

func outer() {
    mu.Lock()
    defer mu.Unlock()
    inner() // 在还持有锁的时候,调用了 inner
}

func inner() {
    mu.Lock() // 死锁!自己还想再锁自己一次?
    defer mu.Unlock()
}

怎么解:尽量避免嵌套锁定

3. Channel 通信死锁

Channel 这边的死锁,说白了就是“有发无收”或者“有收无发”的问题。

典型场景: 往一个无缓冲的 Channel 里塞数据,但压根儿没人接收;或者反过来,等着从 Channel 里拿数据,但永远没人往里写。

应对思路:

三、最后的防线:用 context.Context 控制生命周期

就算我们把锁处理得再好,复杂业务逻辑里,Goroutine 还是可能莫名其妙地卡住。这时候,context.Context 就是防止死锁和 Goroutine 泄漏的终极武器。

核心思路很直接: 给每个 Goroutine 都设置一个超时时间或者取消信号。只要超时了,Goroutine 就主动放弃等待,这样就能打破死锁的循环。

实战一下:

import (
    "context"
    "fmt"
    "sync"
    "time"
)

var mu sync.Mutex

func processWithTimeout(ctx context.Context, id int) {
    done := make(chan struct{})
    
    go func() {
        mu.Lock()
        defer mu.Unlock()
        close(done)
    }()

    select {
    case <-done:
        fmt.Printf("Goroutine %d: 获取锁成功,执行业务逻辑\n", id)
        time.Sleep(100 * time.Millisecond)
    case <-ctx.Done():
        fmt.Printf("Goroutine %d: 超时或被取消,放弃获取锁,退出\n", id)
        return
    }
}

func main() {
    ctx, cancel := context.WithTimeout(context.Background(), 1*time.Second)
    defer cancel()

    // 模拟一个长时间持有锁的操作
    mu.Lock()
    go func() {
        time.Sleep(2 * time.Second)
        mu.Unlock()
    }()

    for i := 0; i < 3; i++ {
        go processWithTimeout(ctx, i)
    }

    time.Sleep(3 * time.Second)
}

输出结果解读: 主 Goroutine 先占着锁 2 秒钟,而 processWithTimeout 设置的 context 超时只有 1 秒。因此,后面那几个 Goroutine 会在 1 秒后收到 ctx.Done() 信号,然后乖乖打印“放弃获取锁”并退出,彻底避免了永久阻塞。

四、总结一下,到底该怎么干

解决 Go 死锁问题,讲究的是“预防为主,兜底为辅”,两条腿走路才稳。

预防为主:

兜底策略:

调试小技巧:

万一程序真的卡死了,别慌。赶紧上 pprof 工具(命令是 go tool pprof http://localhost:6060/debug/pprof/goroutine?debug=2),看看 Goroutine 的堆栈信息,到底卡在了哪个锁或者哪个 Channel 上,一目了然。

把这些原则融入日常开发,你的 Go 并发系统自然会越来越健壮,少踩这些坑。

本文转载于:https://www.jb51.net/jiaoben/362264mcd.htm 如有侵犯,请联系zhengruancom@outlook.com删除。
免责声明:正软商城发布此文仅为传递信息,不代表正软商城认同其观点或证实其描述。