讲师中心 微信公众号

工具推荐

视频效率加速
Seko
Seko

AI短剧一键生成成片

立刻MV
立刻MV

低成本歌曲 MV、视频生成

Laper
Laper

剧本策划到成片协作

剧云
剧云

中文短剧剧本制作平台

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

轻瑶同学_5768

轻瑶同学_5768

发布时间: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 的缓冲区足以解决问题。

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

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

下载

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

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

修改 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工具

更多
讯飞智作

讯飞智作是一款AI视频创作工具,AI文本配音工具,数字人课程、营销视频制作。

立刻MV
立刻MV Hot

立刻MV是一款AI文本写作工具,AI 音乐视频(MV)创作工具。

墨刀AI
墨刀AI Hot

一款AI图像与设计工具,主要用于产品经理的专属智能体,适合需要提升相关任务效率的用户。

SkildArt
SkildArt Hot

SkildArt是一款AI文本写作工具,一站式 AI 视觉创作平台。

讯飞绘文

讯飞绘文是一款由科大讯飞推出的一站式 AIGC 内容运营平台。

豆包大模型

豆包大模型是一款由字节跳动推出的企业级大语言模型服务平台。

DeepSeek

DeepSeek是一款面向对话、写作、编程和推理场景的AI大模型工具。

WorkBuddy

一款AI办公效率工具,主要用于腾讯云推出的AI原生桌面智能体工作台,适合需要提升相关任务效率的用户。

UpDream
UpDream Hot

一款AI视频创作工具,主要用于哔哩哔哩推出的自研AI视频创作工具,适合需要提升相关任务效率的用户。

相关专题

更多
string转int
string转int

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

7319

2023.08.02

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

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

3485

2024.08.29

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

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

4588

2025.08.29

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

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

3065

2025.08.29

Golang channel原理
Golang channel原理

本专题整合了Golang channel通信相关介绍,阅读专题下面的文章了解更多详细内容。

454

2025.11.14

golang channel相关教程
golang channel相关教程

本专题整合了golang处理channel相关教程,阅读专题下面的文章了解更多详细内容。

639

2025.11.17

Go语言 channel用法详解
Go语言 channel用法详解

本专题整合了go语言中channel的各种使用方法,阅读专题下面的文章了解更多详细步骤。

503

2026.04.03

Postman身份认证怎么配置
Postman身份认证怎么配置

本专题从实际API接口调试场景出发,讲解Postman身份认证的完整配置流程,包括常见认证协议介绍、授权参数设置、访问令牌填写、OAuth 2.0授权及认证失败排查,帮助用户正确完成接口授权与访问验证。

40

2026.11.06

Postman请求头Headers怎么设置
Postman请求头Headers怎么设置

围绕Postman HTTP请求头配置展开,讲解Headers选项的具体使用方式,包括Key和Value参数填写、请求头信息添加、常见Header字段设置及请求头修改方法,帮助用户解决接口调试过程中遇到的请求头配置问题。

20

2026.11.06

热门下载

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

精品课程

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

Copyright 2014-2026 https://www.php.cn/ All Rights Reserved | php.cn