Go 并发编程：解决通道死锁问题

冬静小哥_2485

发布时间：2025-10-03 16:45:05

543人浏览过

来源于php中文网

原创

go 并发编程：解决通道死锁问题

本文旨在帮助开发者理解并解决 Go 语言并发编程中常见的通道死锁问题。通过分析一个简单的求和示例，我们将深入探讨死锁产生的原因，并提供两种有效的解决方案：利用计数器替代 range 循环，避免对未关闭通道的无限等待。掌握这些技巧，可以有效提升 Go 并发程序的健壮性和可靠性。

在 Go 语言的并发编程中，通道（channel）扮演着至关重要的角色，用于 goroutine 之间的通信和同步。然而，不当的使用方式容易导致死锁，影响程序的正常运行。本文将通过一个实际的例子，深入剖析死锁的产生原因，并提供解决方案。

死锁示例：并发求和

考虑以下场景：我们需要将一个整数数组分割成两部分，然后使用两个 goroutine 分别计算各自部分的和，最后将两个结果汇总并输出。

package main

import (
    "fmt"
)

// Add calculates the sum of elements in a and sends the result to res.
func Add(a []int, res chan<- int) {
    sum := 0
    for _, v := range a {
        sum += v
    }
    res <- sum
}

func main() {
    a := []int{1, 2, 3, 4, 5, 6, 7}

    n := len(a)
    ch := make(chan int)
    go Add(a[:n/2], ch)
    go Add(a[n/2:], ch)

    sum := 0
    for s := range ch {
        sum += s
    }

    fmt.Println(sum)
}

这段代码存在死锁的风险。原因在于 main 函数中的 for s := range ch 循环会持续尝试从通道 ch 中接收数据，直到通道关闭。然而，Add 函数在发送完各自的和之后并没有关闭通道，导致 range 循环永远无法结束，从而产生死锁。

解决方案一：使用计数器

一种解决方案是使用计数器来控制循环的结束。我们可以预先知道将会有多少个 goroutine 向通道发送数据，然后在主 goroutine 中使用一个计数器来记录已接收到的数据数量。当计数器达到预期值时，循环结束。

AI舌诊面诊问诊医疗系统+诊疗商城系统源码

AI 舌诊面诊问诊医疗系统 + 诊疗商城系统源码是一套结合 AI 辅助诊断与商品转化的健康类程序，基于浩创云、ThinkPHP（PHP）开发，支持微信服务号与 H5 端，适合做中医舌诊面诊问答、健康建议推送以及配套诊疗商品的运营。

下载

package main

import (
    "fmt"
)

// Add calculates the sum of elements in a and sends the result to res.
func Add(a []int, res chan<- int) {
    sum := 0
    for _, v := range a {
        sum += v
    }
    res <- sum
}

func main() {
    a := []int{1, 2, 3, 4, 5, 6, 7}

    n := len(a)
    ch := make(chan int)
    go Add(a[:n/2], ch)
    go Add(a[n/2:], ch)

    sum := 0
    count := 0 // Initialize the counter

    for count < 2 { // Loop until all results are received
        s := <-ch
        sum += s
        count++ // Increment the counter
    }

    fmt.Println(sum)
}

在这个版本中，我们添加了一个 count 变量来跟踪从通道接收到的结果数量。循环只会在 count 小于 2 时继续，确保了在接收到两个结果后循环能够正常结束，避免了死锁。

解决方案二：关闭通道

另一种解决方案是在所有发送者完成发送后关闭通道。这样，range 循环就能检测到通道已关闭，并正常结束。但是，在并发环境中，确定所有发送者都已完成发送可能比较困难。

以下代码展示了如何在 Add 函数完成后关闭通道（不推荐，仅作演示）：

package main

import (
    "fmt"
    "sync"
)

// Add calculates the sum of elements in a and sends the result to res.
func Add(a []int, res chan<- int, wg *sync.WaitGroup) {
    defer wg.Done()
    sum := 0
    for _, v := range a {
        sum += v
    }
    res <- sum
}

func main() {
    a := []int{1, 2, 3, 4, 5, 6, 7}

    n := len(a)
    ch := make(chan int)
    var wg sync.WaitGroup

    wg.Add(2)
    go Add(a[:n/2], ch, &wg)
    go Add(a[n/2:], ch, &wg)

    go func() {
        wg.Wait()
        close(ch)
    }()

    sum := 0
    for s := range ch {
        sum += s
    }

    fmt.Println(sum)
}

注意： 在多个 goroutine 向同一个通道发送数据时，直接在发送者 goroutine 中关闭通道通常是不安全的。上面的示例使用 sync.WaitGroup 确保所有 Add 函数完成后再关闭通道，但这种方法相对复杂，并且容易出错。因此，通常推荐使用计数器的方式来避免死锁。