关闭golang通道时,接收者goroutine不会被阻塞
来源:stackoverflow
时间:2024-02-25 10:24:25 483浏览 收藏
本篇文章主要是结合我之前面试的各种经历和实战开发中遇到的问题解决经验整理的,希望这篇《关闭golang通道时,接收者goroutine不会被阻塞》对你有很大帮助!欢迎收藏,分享给更多的需要的朋友学习~
我写了一些代码来学习go通道,如下所示的一段代码:
func main(){
intChan := make(chan int, 1)
strChan := make(chan string, 1)
intChan <- 3
strChan <- "hello"
fmt.Println("send")
// comment this, fatal error: all goroutines are asleep - deadlock!
// close(intChan)
// close(strChan)
for {
select {
case e, ok := <-intChan:
time.Sleep(time.Second * 2)
fmt.Println("The case intChan ok: ", ok)
fmt.Println("The case intChan is selected.", e)
case e, ok := <-strChan:
time.Sleep(time.Second)
fmt.Println("The case strChan ok: ", ok)
fmt.Println("The case strChan is selected.", e)
}
}
}
如果我注释掉 close() 函数,“for”语句就会被阻塞,正如错误提示“all goroutine are sleep - deadlock!”,这似乎是合理的。
如果我取消注释 close(),“for”语句永远不会停止。接收方从通道获取默认值 0 和 nil,并且从不阻塞。
即使我没有向通道发送任何内容,并在定义通道后调用 close() 。接收器永远不会阻塞或导致任何错误。
我对 close 函数的作用感到困惑,它是否启动一个 go 例程将特定类型的默认值发送到通道,并且永远不会停止?
正确答案
当频道关闭时,您仍然可以阅读它,但您的 ok 将为 false。所以,这就是为什么你的 for 永远不会停止。并且,您需要通过条件 if !ok {break } 来中断 for 语句。
当通道未关闭时,当您尝试从中读取数据时,它会被阻塞或不被阻塞,具体取决于缓冲/非缓冲通道。
缓冲通道:您指定大小 (make(chan int, 1))。
无缓冲通道:您没有给出大小 (make(chan int))
在您评论 close 的情况下,它将从您缓冲的通道读取数据一次,因为您通过 intchan <- 3 和 strchan <- "hello" 将数据发送到通道。因此,您将看到控制台打印以下结果。
send the case strchan ok: true the case strchan is selected. hello the case intchan ok: true the case intchan is selected. 3
但是,此后,两个缓冲通道都不再有数据。然后,如果您尝试读取它,您将被阻止,因为缓冲通道中没有任何数据。 (实际上,无缓冲也是没有数据时的情况。)
然后,你会得到 all goroutine are sleep - deadlock 因为主 goroutine 被阻塞以等待来自通道的数据。顺便说一句,当你运行这个程序时,它会启动一个主 goroutine 来运行你的代码。如果只有一个主 goroutine 被阻塞,那就意味着没有人可以帮助你运行你的代码。
您可以在for语句之前添加以下代码。
go func() {
fmt.Println("another goroutine")
for {}
}()
你会发现你没有遇到死锁,因为仍然有一个 goroutine“可能”运行你的代码。
理论要掌握,实操不能落!以上关于《关闭golang通道时,接收者goroutine不会被阻塞》的详细介绍,大家都掌握了吧!如果想要继续提升自己的能力,那么就来关注golang学习网公众号吧!
-
502 收藏
-
502 收藏
-
501 收藏
-
501 收藏
-
501 收藏
-
Golang · Go问答 | 2天前 | 并发 · channel · Mutex · 性能优化 · Go问答 · benchmark · Goroutine channel Mutex 并发性能 锁等待 benchmark Go问答268 收藏
-
Golang · Go问答 | 2天前 | 并发 · map · RWMutex · sync.Map · Go问答 · 数据竞争 RWMutex sync.Map map并发读写 Go问答 concurrent map read and map write291 收藏
-
Golang · Go问答 | 2天前 | 并发 · channel · range · Close · Go问答 · 并发退出 Channel关闭 Go问答 close channel range退出 发送方关闭427 收藏
-
Golang · Go问答 | 2天前 | goroutine · HTTP · Context · 超时控制 · Go问答 · WithTimeout Go问答 context取消 QueryContext HTTP请求取消 goroutine退出120 收藏
-
Golang · Go问答 | 2天前 | goroutine · pprof · Go问答 · 线上排查 · 性能调优 · pprof goroutine泄漏 服务告警 Go问答 context取消 Go线上排查374 收藏
-
Golang · Go问答 | 2天前 | goroutine · Context · 超时控制 · Go问答 · 协程泄漏 · Go Goroutine 超时控制 context.WithTimeout 取消信号 协程泄漏 ctx.Done147 收藏
-
Golang · Go问答 | 2天前 | 闭包 · go · Go问答 · 循环变量 · Go1.22 · 代码迁移 · 闭包 循环变量 go vet Go问答 Go 1.22 for range loopclosure356 收藏
-
127 收藏
-
449 收藏
-
Golang · Go问答 | 3天前 | sync.Pool · reset · 对象复用 · Go问答 · 线上排查 · Go sync.Pool Go问答 sync.Pool串数据 Reset清理 对象池复用342 收藏
-
Golang · Go问答 | 3天前 | 标准库 · 文件读取 · io.Reader · Go问答 · io.EOF · Go read io.Reader io.EOF Go问答 n err 读取循环486 收藏
-
181 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 543次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 516次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 500次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 485次学习