未知长度的封闭通道
来源:Golang技术栈
时间:2023-03-03 19:11:34 166浏览 收藏
对于一个Golang开发者来说,牢固扎实的基础是十分重要的,golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《未知长度的封闭通道》,主要介绍了golang,希望对大家的知识积累有所帮助,快点收藏起来吧,否则需要时就找不到了!
问题内容
当不知道频道的长度时,我无法关闭频道
package main import ( "fmt" "time" ) func gen(ch chan int) { var i int for { time.Sleep(time.Millisecond * 10) ch 100 { break } } // hot to close it properly? close(ch) } func receiver(ch chan int) { for i := range ch { fmt.Println("received:", i) } } func main() { ch := make(chan int) for i := 0; i它给了我错误
panic: send on closed channel goroutine 8 [running]: main.gen(0xc82001a0c0) /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:12 +0x57 created by main.main /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:35 +0xbd goroutine 1 [panicwait]: runtime.gopark(0x0, 0x0, 0x50b8e0, 0x9, 0x10, 0x1) /usr/lib/go/src/runtime/proc.go:185 +0x163 runtime.main() /usr/lib/go/src/runtime/proc.go:121 +0x2f4 runtime.goexit() /usr/lib/go/src/runtime/asm_amd64.s:1696 +0x1 goroutine 6 [sleep]: time.Sleep(0x989680) /usr/lib/go/src/runtime/time.go:59 +0xf9 main.gen(0xc82001a0c0) /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:11 +0x29 created by main.main /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:33 +0x79 goroutine 7 [sleep]: time.Sleep(0x989680) /usr/lib/go/src/runtime/time.go:59 +0xf9 main.gen(0xc82001a0c0) /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:11 +0x29 created by main.main /home/exu/src/github.com/exu/go-workshops/100-concurrency-channels/16-close-problem.go:34 +0x9b exit status 2这是合乎逻辑的 - 当第二个 goroutine 尝试发送给它时,第一个 goroutine 关闭通道。在这种情况下关闭渠道的最佳方法是什么?
正确答案
通道关闭后,您无法在其上发送更多值,否则会发生恐慌。这就是你所经历的。
这是因为您启动了多个使用同一通道的 goroutine,它们在其上发送值。然后关闭每个通道中的通道。而且由于它们不同步,一旦第一个 goroutine 到达关闭它的点,其他人可能(并且他们将)仍然继续在其上发送值:恐慌!
您只能关闭一次通道(尝试关闭已经关闭的通道也会出现恐慌)。当所有发送值的 goroutine 都完成后,你应该这样做。为此,您需要检测所有发送者 goroutine 何时完成。检测这一点的惯用方法是使用
sync.WaitGroup
.对于每个启动的发送者 goroutine,我们将 1 添加到
WaitGroup
usingWaitGroup.Add()
。每个完成发送值的 goroutine 都可以通过调用WaitGroup.Done()
. 最好将其作为延迟语句执行,因此如果您的 goroutine 突然终止(例如恐慌),WaitGroup.Done()
仍然会被调用,并且不会让其他 goroutines 挂起(等待赦免 - 一个WaitGroup.Done()
永远不会出现的“丢失”调用.. .)。并且
WaitGroup.Wait()
会一直等到所有发送者 goroutine 都完成,并且只有在此之后并且只有一次才会关闭通道。我们想要检测这个“全局”完成事件并关闭通道,同时处理正在处理的值,因此我们必须在它自己的 goroutine 中执行此操作。由于我们在
for ... range
通道上使用了构造,因此接收器 goroutine 将一直运行直到通道关闭。并且由于它在主 goroutine 中运行,因此在从通道正确接收和处理所有值之前,程序不会退出。for ... range
构造循环,直到接收到在通道关闭之前发送的所有值。请注意,下面的解决方案也适用于缓冲和非缓冲通道,无需修改(尝试使用带缓冲的通道
ch := make(chan int, 100)
)。func gen(ch chan int, wg *sync.WaitGroup) { defer wg.Done() var i int for { time.Sleep(time.Millisecond * 10) ch 100 { break } } } func receiver(ch chan int) { for i := range ch { fmt.Println("received:", i) } } func main() { ch := make(chan int) wg := &sync.WaitGroup{} for i := 0; i笔记:
请注意,在主 goroutine 中运行很重要,代码在其自己的(非主)goroutine 中
receiver(ch)
等待并关闭通道;WaitGroup
而不是相反。如果您切换这 2 个,可能会导致“提前退出”,即并非所有值都可能从通道接收和处理。这样做的原因是因为当主 goroutine 完成时 Go 程序退出(规范:程序执行)。它不会等待其他(非主)goroutine 完成。因此,如果等待和关闭通道将在主 goroutine 中,则在关闭通道后,程序可以随时退出,而不是等待在这种情况下将循环以从通道接收值的另一个 goroutine。以上就是《未知长度的封闭通道》的详细内容,更多关于golang的资料请关注golang学习网公众号!
-
439 收藏
-
262 收藏
-
193 收藏
-
188 收藏
-
500 收藏
-
139 收藏
-
204 收藏
-
325 收藏
-
477 收藏
-
486 收藏
-
439 收藏
-
- 前端进阶之JavaScript设计模式
- 设计模式是开发人员在软件开发过程中面临一般问题时的解决方案,代表了最佳的实践。本课程的主打内容包括JS常见设计模式以及具体应用场景,打造一站式知识长龙服务,适合有JS基础的同学学习。
- 立即学习 542次学习
-
- GO语言核心编程课程
- 本课程采用真实案例,全面具体可落地,从理论到实践,一步一步将GO核心编程技术、编程思想、底层实现融会贯通,使学习者贴近时代脉搏,做IT互联网时代的弄潮儿。
- 立即学习 507次学习
-
- 简单聊聊mysql8与网络通信
- 如有问题加微信:Le-studyg;在课程中,我们将首先介绍MySQL8的新特性,包括性能优化、安全增强、新数据类型等,帮助学生快速熟悉MySQL8的最新功能。接着,我们将深入解析MySQL的网络通信机制,包括协议、连接管理、数据传输等,让
- 立即学习 497次学习
-
- JavaScript正则表达式基础与实战
- 在任何一门编程语言中,正则表达式,都是一项重要的知识,它提供了高效的字符串匹配与捕获机制,可以极大的简化程序设计。
- 立即学习 487次学习
-
- 从零制作响应式网站—Grid布局
- 本系列教程将展示从零制作一个假想的网络科技公司官网,分为导航,轮播,关于我们,成功案例,服务流程,团队介绍,数据部分,公司动态,底部信息等内容区块。网站整体采用CSSGrid布局,支持响应式,有流畅过渡和展现动画。
- 立即学习 484次学习