0

0

解决 Go 语言中无缓冲通道导致的死锁问题

聖光之護

聖光之護

发布时间:2025-09-26 13:05:01

|

219人浏览过

|

来源于php中文网

原创

解决 Go 语言中无缓冲通道导致的死锁问题

本文探讨 Go 语言中因无缓冲通道(unbuffered channels)不当使用而导致的死锁现象。当发送操作在没有接收者准备就绪时阻塞,且程序中没有其他并发协程来执行接收操作时,就会发生死锁。教程将提供两种有效的解决方案:使用带缓冲的通道(buffered channels)来允许有限数量的非阻塞发送,或将发送操作封装在独立的 Goroutine 中以实现并发执行,从而避免主协程阻塞。

问题现象与原因分析

go 语言中,通道(channel)是实现协程(goroutine)间通信的重要机制。然而,不当使用通道,尤其是无缓冲通道,很容易导致程序死锁。考虑以下计算自然数和的 go 程序示例:

package main

import "fmt"

func sum(nums []int, c chan int) {
    var sum int = 0
    for _, v := range nums {
        sum += v
    }
    c <- sum // 将结果发送到通道
}

func main() {
    allNums := []int{1, 2, 3, 4, 5, 6, 7, 8}
    c1 := make(chan int) // 创建无缓冲通道
    c2 := make(chan int) // 创建无缓冲通道

    sum(allNums[:len(allNums)/2], c1) // 直接调用 sum 函数
    sum(allNums[len(allNums)/2:], c2) // 直接调用 sum 函数

    a := <-c1 // 从通道接收数据
    b := <-c2 // 从通道接收数据
    fmt.Printf("%d + %d is %d :D", a, b, a+b)
}

运行这段代码会产生以下死锁错误:

throw: all goroutines are asleep - deadlock!

goroutine 1 [chan send]:
main.sum(0x44213af00, 0x800000004, 0x420fbaa0, 0x2f29f, 0x7aaa8, ...)
    main.go:9 +0x6e
main.main()
    main.go:16 +0xe6

goroutine 2 [syscall]:
created by runtime.main
    /usr/local/go/src/pkg/runtime/proc.c:221

exit status 2

这个死锁的根本原因在于 sum 函数被直接调用,而不是在一个独立的 Goroutine 中运行。当执行到 sum(allNums[:len(allNums)/2], c1) 这一行时,sum 函数会在当前(即 main)Goroutine 中执行。在 sum 函数内部,c

由于 main Goroutine 阻塞,程序无法继续执行到第二个 sum 函数调用或任何通道接收操作。最终,Go 运行时检测到所有 Goroutine(包括 main Goroutine)都处于阻塞状态,没有 Goroutine 可以继续执行,从而报告死锁。尽管使用了两个独立的通道 c1 和 c2,但问题在于 sum 函数的同步调用模式,导致 main Goroutine 无法同时扮演发送者和接收者的角色。

解决方案一:使用带缓冲的通道

解决上述死锁问题的一种方法是使用带缓冲的通道。带缓冲的通道允许在没有接收者准备就绪的情况下,发送一定数量的数据到通道中,直到缓冲区满。

修改 main 函数中通道的创建方式:

package main

import "fmt"

func sum(nums []int, c chan int) {
    var sum int = 0
    for _, v := range nums {
        sum += v
    }
    c <- sum // 将结果发送到通道
}

func main() {
    allNums := []int{1, 2, 3, 4, 5, 6, 7, 8}
    c1 := make(chan int, 1) // 创建一个容量为1的缓冲通道
    c2 := make(chan int, 1) // 创建一个容量为1的缓冲通道

    sum(allNums[:len(allNums)/2], c1) // 直接调用 sum 函数
    sum(allNums[len(allNums)/2:], c2) // 直接调用 sum 函数

    a := <-c1 // 从通道接收数据
    b := <-c2 // 从通道接收数据
    fmt.Printf("%d + %d is %d :D", a, b, a+b)
}

通过将通道 c1 和 c2 创建为容量为 1 的缓冲通道 (make(chan int, 1)),sum 函数中的 c

注意事项: 使用缓冲通道时,需要仔细考虑缓冲区的容量。如果发送的数据量超过缓冲区容量,发送操作仍然会阻塞。对于本例,每个 sum 函数只发送一个整数,因此容量为 1 的缓冲区足以解决问题。

解决方案二:利用 Goroutine 实现并发

更符合 Go 语言并发编程范式,也是解决此类问题的推荐方法,是将 sum 函数的调用封装到独立的 Goroutine 中。这将使得 sum 函数与 main 函数并发执行,从而确保在 sum 函数尝试发送数据时,main 函数能够及时准备好接收数据。

Videoleap
Videoleap

Videoleap是一个一体化的视频编辑平台

下载

修改 main 函数中 sum 函数的调用方式:

package main

import "fmt"

func sum(nums []int, c chan int) {
    var sum int = 0
    for _, v := range nums {
        sum += v
    }
    c <- sum // 将结果发送到通道
}

func main() {
    allNums := []int{1, 2, 3, 4, 5, 6, 7, 8}
    c1 := make(chan int) // 保持无缓冲通道
    c2 := make(chan int) // 保持无缓冲通道

    go sum(allNums[:len(allNums)/2], c1) // 在新的 Goroutine 中运行
    go sum(allNums[len(allNums)/2:], c2) // 在新的 Goroutine 中运行

    a := <-c1 // 从通道接收数据
    b := <-c2 // 从通道接收数据
    fmt.Printf("%d + %d is %d :D", a, b, a+b)
}

在此方案中,我们保留了无缓冲通道。关键的改变在于 go sum(...) 的使用。当 go sum(...) 被调用时,Go 运行时会启动一个新的 Goroutine 来执行 sum 函数,而 main Goroutine 会立即继续执行下一行代码。这意味着:

  1. main Goroutine 启动第一个 sum Goroutine。
  2. main Goroutine 立即启动第二个 sum Goroutine。
  3. main Goroutine 接着执行 a :=

此时,两个 sum Goroutine 正在并行计算它们的子和,并将结果发送到 c1 和 c2。当其中一个 sum Goroutine 完成计算并执行 c

总结与最佳实践

理解 Go 语言中通道的缓冲特性和 Goroutine 的并发执行是避免死锁的关键。

  • 无缓冲通道:强制发送和接收操作同步发生。如果发送者发送数据而没有接收者准备好,或者接收者尝试接收数据而没有发送者准备好,操作就会阻塞。这非常适合需要严格同步的场景。
  • 带缓冲通道:允许在缓冲区未满时进行非阻塞发送,在缓冲区非空时进行非阻塞接收。它在一定程度上解耦了发送者和接收者,但如果缓冲区满或空,操作仍会阻塞。适用于生产者-消费者模型中,允许一定程度的异步处理。
  • Goroutine:是 Go 并发模型的核心。当需要函数并发执行并通过通道进行通信时,应始终将函数调用封装在 Goroutine 中 (go func())。

在上述示例中,使用 Goroutine 来并发执行 sum 函数是更符合 Go 语言并发哲学的做法。它清晰地表达了“计算子和是独立的任务,可以并行进行”的意图,并通过通道安全地将结果传递回主逻辑。虽然使用缓冲通道也能解决特定场景下的死锁,但它通常用于流量控制或解耦,而不是作为替代 Goroutine 实现并发执行的主要手段。

因此,在设计并发程序时,应优先考虑使用 Goroutine 来启动并发任务,并根据同步需求和数据流特征选择合适的通道类型(无缓冲或带缓冲)。

热门AI工具

更多
DeepSeek
DeepSeek

幻方量化公司旗下的开源大模型平台

豆包大模型
豆包大模型

字节跳动自主研发的一系列大型语言模型

通义千问
通义千问

阿里巴巴推出的全能AI助手

腾讯元宝
腾讯元宝

腾讯混元平台推出的AI助手

文心一言
文心一言

文心一言是百度开发的AI聊天机器人,通过对话可以生成各种形式的内容。

讯飞写作
讯飞写作

基于讯飞星火大模型的AI写作工具,可以快速生成新闻稿件、品宣文案、工作总结、心得体会等各种文文稿

即梦AI
即梦AI

一站式AI创作平台,免费AI图片和视频生成。

ChatGPT
ChatGPT

最最强大的AI聊天机器人程序,ChatGPT不单是聊天机器人,还能进行撰写邮件、视频脚本、文案、翻译、代码等任务。

相关专题

更多
string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

483

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

545

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

113

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

200

2025.08.29

string转int
string转int

在编程中,我们经常会遇到需要将字符串(str)转换为整数(int)的情况。这可能是因为我们需要对字符串进行数值计算,或者需要将用户输入的字符串转换为整数进行处理。php中文网给大家带来了相关的教程以及文章,欢迎大家前来学习阅读。

483

2023.08.02

int占多少字节
int占多少字节

int占4个字节,意味着一个int变量可以存储范围在-2,147,483,648到2,147,483,647之间的整数值,在某些情况下也可能是2个字节或8个字节,int是一种常用的数据类型,用于表示整数,需要根据具体情况选择合适的数据类型,以确保程序的正确性和性能。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

545

2024.08.29

c++怎么把double转成int
c++怎么把double转成int

本专题整合了 c++ double相关教程,阅读专题下面的文章了解更多详细内容。

113

2025.08.29

C++中int的含义
C++中int的含义

本专题整合了C++中int相关内容,阅读专题下面的文章了解更多详细内容。

200

2025.08.29

C++ 设计模式与软件架构
C++ 设计模式与软件架构

本专题深入讲解 C++ 中的常见设计模式与架构优化,包括单例模式、工厂模式、观察者模式、策略模式、命令模式等,结合实际案例展示如何在 C++ 项目中应用这些模式提升代码可维护性与扩展性。通过案例分析,帮助开发者掌握 如何运用设计模式构建高质量的软件架构,提升系统的灵活性与可扩展性。

14

2026.01.30

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Go 教程
Go 教程

共32课时 | 4.4万人学习

Go语言实战之 GraphQL
Go语言实战之 GraphQL

共10课时 | 0.8万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号