0

0

用 channel 实现生产者消费者模式(带退出)

冰川箭仙

冰川箭仙

发布时间:2026-02-10 13:32:03

|

250人浏览过

|

来源于php中文网

原创

直接 close(channel) 会导致 panic 的原因是多个 goroutine 同时 close 已关闭的 channel,触发“close of closed channel”;正确做法是由唯一生产者关闭数据 channel,并用 done channel 或 context 控制消费者退出。

用 channel 实现生产者消费者模式(带退出)

为什么直接 close(channel) 会导致 panic

生产者消费者模式里,如果生产者提前 close(ch),而消费者还在用 range ch 循环读取,这本身是安全的;但若消费者用 单次接收,且没配合 ok 判断,就会在 channel 关闭后继续读取,返回零值并引发逻辑错误——更危险的是,如果多个 goroutine 同时对已关闭 channel 调用 close(),会直接 panic:panic: close of closed channel

所以退出控制不能依赖「谁先关 channel」,而要让生产者明确告知「数据发完了」,消费者感知到后自行退出。

  • 永远不要让多个 goroutine 执行 close(ch)
  • range ch 是安全的,它内部自动检测 closed 状态并退出循环
  • 单次接收必须写成 v, ok := ,靠 ok == false 判断是否结束

用 done channel + sync.WaitGroup 协调退出

最稳妥的做法是:用一个 done channel 通知所有 goroutine 该停了,再用 sync.WaitGroup 等待它们真正退出。这样生产者可以优雅终止(比如收到信号、处理完一批任务),消费者也能在本轮消费完后退出,不丢数据也不阻塞。

示例关键结构:

done := make(chan struct{})
var wg sync.WaitGroup

// 启动消费者 for i := 0; i < 3; i++ { wg.Add(1) go func() { defer wg.Done() for { select { case v, ok := <-jobs: if !ok { return } // jobs 关闭,退出 process(v) case <-done: return // 外部要求退出 } } }() }

// 生产者:发完数据后 close(jobs),再 close(done) go func() { for _, job := range allJobs { select { case jobs <- job: case <-done: return } } close(jobs) // 仅此处 close,且只一次 close(done) // 通知消费者可以彻底收工了 }()

wg.Wait()

用 context.Context 替代 done channel 更灵活

当需要支持超时、取消链路或与 HTTP/gRPC 等生态集成时,context.Context 比裸 done chan struct{} 更合适。它自带取消传播和 deadline 支持,且 ctx.Done() 返回的 channel 可直接用于 select

Hika AI
Hika AI

Hika AI是一个免费的AI智能搜索引擎

下载
  • context.WithCancel 创建可取消上下文
  • 生产者在完成或出错时调用 cancel()
  • 消费者监听 ,而不是自己维护 done channel
  • 注意:消费者仍需正确处理 jobs 关闭(如 range jobsv, ok := )

常见误用:ctx 仅用于控制生命周期,不能替代数据 channel 的关闭逻辑——jobs 还是要由生产者显式 close(),否则消费者可能永远卡在 上。

消费者用 range 还是 select?取决于是否要响应外部中断

如果消费者只需要等数据发完就退出,用 for v := range jobs 最简洁,它隐含了对 closed channel 的处理;但如果还要响应超时、强制取消或多个输入源(比如同时从 jobscontrol channel 读),就必须用 select

  • range jobs:适合纯数据流、无中断需求的场景,代码少、不易错
  • select + :必须配 ok 判断,否则关 channel 后继续读会拿到零值
  • select + ctx.Done():能及时响应取消,但要注意:即使 ctx 取消了,也应确保已接收的数据被处理完(比如把 v 放进本地队列再退出)

最容易被忽略的一点:无论用哪种方式,只要生产者 close 了 jobs,所有正在 的 goroutine 都会立刻解除阻塞——所以「退出」不是瞬间发生的,而是按当前正在执行的语句自然流转结束。别指望一 cancel 就立马全部停住。

本站声明:本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn

热门AI工具

更多
DeepSeek
DeepSeek

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

豆包大模型
豆包大模型

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

通义千问
通义千问

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

腾讯元宝
腾讯元宝

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

文心一言
文心一言

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

讯飞写作
讯飞写作

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

即梦AI
即梦AI

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

ChatGPT
ChatGPT

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

相关专题

更多
golang如何定义变量
golang如何定义变量

golang定义变量的方法:1、声明变量并赋予初始值“var age int =值”;2、声明变量但不赋初始值“var age int”;3、使用短变量声明“age :=值”等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

185

2024.02.23

golang有哪些数据转换方法
golang有哪些数据转换方法

golang数据转换方法:1、类型转换操作符;2、类型断言;3、字符串和数字之间的转换;4、JSON序列化和反序列化;5、使用标准库进行数据转换;6、使用第三方库进行数据转换;7、自定义数据转换函数。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

233

2024.02.23

golang常用库有哪些
golang常用库有哪些

golang常用库有:1、标准库;2、字符串处理库;3、网络库;4、加密库;5、压缩库;6、xml和json解析库;7、日期和时间库;8、数据库操作库;9、文件操作库;10、图像处理库。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

345

2024.02.23

golang和python的区别是什么
golang和python的区别是什么

golang和python的区别是:1、golang是一种编译型语言,而python是一种解释型语言;2、golang天生支持并发编程,而python对并发与并行的支持相对较弱等等。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

211

2024.03.05

golang是免费的吗
golang是免费的吗

golang是免费的。golang是google开发的一种静态强类型、编译型、并发型,并具有垃圾回收功能的开源编程语言,采用bsd开源协议。本专题为大家提供相关的文章、下载、课程内容,供大家免费下载体验。

401

2024.05.21

golang结构体相关大全
golang结构体相关大全

本专题整合了golang结构体相关大全,想了解更多内容,请阅读专题下面的文章。

302

2025.06.09

golang相关判断方法
golang相关判断方法

本专题整合了golang相关判断方法,想了解更详细的相关内容,请阅读下面的文章。

196

2025.06.10

golang数组使用方法
golang数组使用方法

本专题整合了golang数组用法,想了解更多的相关内容,请阅读专题下面的文章。

742

2025.06.17

包子漫画网页版入口与全集阅读指南_正版免费漫画快速访问方法
包子漫画网页版入口与全集阅读指南_正版免费漫画快速访问方法

本专题汇总了包子漫画官网和网页版入口,提供最新章节抢先看方法、正版免费阅读指南,以及稳定访问方式,帮助用户快速直达包子漫画页面,无广告畅享全集漫画内容。

1

2026.02.10

热门下载

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

精品课程

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

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