如何在不阅读的情况下检查频道是否关闭?
IT行业相对于一般传统行业,发展更新速度更快,一旦停止了学习,很快就会被行业所淘汰。所以我们需要踏踏实实的不断学习,精进自己的技术,尤其是初学者。今天golang学习网给大家整理了《如何在不阅读的情况下检查频道是否关闭?》,聊聊golang,我们一起来看看吧!
问题内容
这是@Jimt 编写的Go 中worker 和controller 模式的一个很好的例子,以回答“Golang 中是否有一些优雅的方式来暂停和恢复任何其他goroutine? ”
package main
import (
"fmt"
"runtime"
"sync"
"time"
)
// Possible worker states.
const (
Stopped = 0
Paused = 1
Running = 2
)
// Maximum number of workers.
const WorkerCount = 1000
func main() {
// Launch workers.
var wg sync.WaitGroup
wg.Add(WorkerCount + 1)
workers := make([]chan int, WorkerCount)
for i := range workers {
workers[i] = make(chan int)
go func(i int) {
worker(i, workers[i])
wg.Done()
}(i)
}
// Launch controller routine.
go func() {
controller(workers)
wg.Done()
}()
// Wait for all goroutines to finish.
wg.Wait()
}
func worker(id int, ws
但是这段代码也有一个问题:如果你想在退出workers时删除一个工作通道worker(),就会发生死锁。
如果你close(workers[i]),下次控制器写入它会导致恐慌,因为 go
无法写入关闭的通道。如果您使用一些互斥锁来保护它,那么它将被卡住,workers[i] 因为worker它没有从通道读取任何内容并且写入将被阻塞,并且互斥锁将导致死锁。您还可以为通道提供更大的缓冲区作为解决方法,但这还不够好。
所以我认为解决这个问题的最好方法是worker()退出时关闭通道,如果控制器发现通道关闭,它将跳过它并且什么都不做。但是在这种情况下,我找不到如何检查通道是否已关闭。如果我尝试读取控制器中的通道,控制器可能被阻塞。所以我现在很困惑。
PS:恢复引发的恐慌是我尝试过的,但它会关闭引发恐慌的goroutine。在这种情况下,它将是控制器,所以没有用。
不过,我认为 Go 团队在下一个版本的 Go 中实现这个功能是有用的。
正确答案
可以通过一种 hacky 方式,通过恢复引发的恐慌来尝试写入的通道。但是如果不读取读取通道,则无法检查它是否已关闭。
要么你会
- 最终从中读取“真实”值 (
v ) - 读取“真”值和“未关闭”指示符 (
v, ok ) - 读取 零值 和“关闭”指示器 (
v, ok )(示例) - 将阻塞在永久读取的通道中 (
v )
只有最后一个在技术上不会从频道中读取,但这没什么用。
今天关于《如何在不阅读的情况下检查频道是否关闭?》的内容就介绍到这里了,是不是学起来一目了然!想要了解更多关于golang的内容请关注golang学习网公众号!
'*' 和 '&' 是什么意思?
- 上一篇
- '*' 和 '&' 是什么意思?
- 下一篇
- 当所有通道都关闭时,跳出一个 select 语句
-
- Golang · Go问答 | 38分钟前 | 字符串 · 性能 · Go问答 · strings.Builder · Go panic Pointer 传值 strings.Builder
- Go strings.Builder 为什么不能复制:传值参数、append 和 panic 的边界
- 246浏览 收藏
-
- Golang · Go问答 | 1小时前 | HTTP · 静态资源 · Go问答 · 浏览器缓存 · 浏览器缓存 Cache-Control ETag http.FileServer Go静态文件
- Go 静态文件更新了浏览器还是旧版本:Cache-Control、ETag 和文件名指纹怎么配
- 251浏览 收藏
-
- Golang · Go问答 | 2小时前 | 依赖注入 · 设计模式 · api设计 · Go问答 · Functional Options · API设计 默认值 依赖注入 Go问答 Functional Options 函数选项
- Go Functional Options 怎么设计:默认值、必填依赖和不该使用的场景
- 153浏览 收藏
-
- Golang · Go问答 | 2小时前 | 单元测试 · HTTP · Go问答 · httptest · ResponseRecorder · 单元测试 HTTP响应 httptest Go问答 ResponseRecorder Handler测试
- Go 用 httptest 测 Handler,为什么响应体是空的:WriteHeader、Result 与断言顺序
- 481浏览 收藏
-
- Golang · Go问答 | 2小时前 | 并发 · 性能优化 · sync.Pool · bytes.Buffer · Go问答 · reset bytes.Buffer 对象复用 Go sync.Pool 数据串行
- Go sync.Pool 复用 bytes.Buffer 为什么会串数据:Reset 位置和归还时机
- 294浏览 收藏
-
- Golang · Go问答 | 8小时前 | golang · errgroup · Context · 并发控制 · Go问答 · SetLimit · 错误传播 Go errgroup.SetLimit errgroup.WithContext Go 并发限制 批量调用 context 取消
- Go errgroup.SetLimit 怎么用:批量调用下游时限制并发、保留取消与错误
- 467浏览 收藏
-
- Golang · Go问答 | 1天前 | [] · []
- Go 服务怎么用 Sec-Fetch-Site 拦住跨站请求:Fetch Metadata 的最小中间件
- 349浏览 收藏
-
- Golang · Go问答 | 1天前 | 云原生 · golang · 性能优化 · kubernetes · HPA · Go HPA不扩容 Kubernetes HPA CPU resources requests HPA并发指标 Go服务扩缩容
- Go 服务上 Kubernetes 后 HPA 为什么不扩容:requests、CPU 和并发指标怎么选
- 111浏览 收藏
-
- Golang · Go问答 | 1天前 | golang · 消息队列 · 性能优化 · websocket · 高并发 · Go WebSocket广播 Go慢客户端 WebSocket发送队列 Go Hub分片 WebSocket背压
- Go WebSocket 广播为什么会被慢客户端拖住:发送队列、丢弃策略和分片 Hub
- 146浏览 收藏
-
- Golang · Go问答 | 1天前 | 性能排查 · net/http · HTTP客户端 · Go问答 · 连接复用 · 连接复用 keep-alive http.Transport Response.Body Go HTTP Client
- Go HTTP Client 为什么频繁建连接:Response.Body 没读完和没关闭的排查
- 241浏览 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 485次学习
-
- ljg-skills
- ljg-skills 是李继刚开源的 AI 技能与提示词集合,面向大模型使用者整理了一批可复用的 prompt、角色设定和任务技能模板,适合用于学习提示词设计、搭建个人 AI 工作流和沉淀团队常用智能体能力。
- 4551次使用
-
- MELO音乐
- MELO音乐是一站式AI视频与音乐制作助手,对标suno, udio的高品质体验。提供伴奏生成、原创写词、无损导出、哼唱识曲、混音变声等全套音频与短视频编辑工具。无论是流行Kpop、电音说唱、民谣古风、摇滚儿歌还是商用轻音乐,MELO为你免费谱曲,轻松做同款!
- 4214次使用
-
- UniScribe
- UniScribe 是一款 AI 音视频转文字与内容整理工具,支持上传音频、视频文件或粘贴 YouTube 链接,自动生成转写文本、摘要、思维导图和关键问题,并支持多格式导出,适合会议记录、课程学习、访谈整理和内容创作复盘。
- 4172次使用
-
- 剧云
- 剧云是专业中文剧本创作平台,安全稳定运行十余年,集成AI编剧、剧本医生审核、人物小传、剧情关系图、大纲编写、多人协作、Word导入导出、版权管控功能,数据安全防护,轻松高效创作剧本。
- 4396次使用
-
- 万象有声
- 万象有声,一个专为有声创作者打造的新一代智能有声内容创作平台。平台提供专业的智能拆章、智能画本编辑、AI配音、AI生成音效、后期制作、智能对轨、智能审听等有声创作全流程工具,可以帮助创作者高效、低成本创作出引人入胜的有声作品。立即体验,让有声书制作更简单!
- 4342次使用
-
- GOLANG使用Context管理关联goroutine的方法
- 2022-12-28 193浏览
-
- 聊聊Go中的注释和godoc工具
- 2022-12-29 354浏览
-
- 聊聊Golang语言中的复数类型
- 2023-01-07 418浏览
-
- 浅析Golang中的浮点类型(float32和float64)
- 2022-12-23 161浏览
-
- 聊聊Golang中的整数类型
- 2022-12-24 209浏览

