Golang控制通道实现协程等待详解
作者:Mingvvv 发布时间:2023-07-21 16:23:39
前言
上一次简单了解了协程的工作原理 前文链接
最后提到了几个使用协程时会遇到的问题,其中一个就是主线程不会等待子线程结束,在这里记录两种比较简单的方法,并借此熟悉下通道的概念。
方法一-睡眠等待
简单暴力的解决方案,在创建了子协程之后,主协程等待一段时间再结束。
func goroutineTest(i int) {
fmt.Println(i)
}
func main() {
for i := 0; i < 3; i++ {
go func() {
fmt.Println(i)
}()
}
//等待一段时间
time.Sleep(time.Millisecond * 500)
}
简单暴力但是并不实用,缺点十分明显, 我们并不知道子协程什么时候会全部执行结束,要么等待时间太短,要么等待时间太长影响方法执行性能。
所以我们需要其他更灵活的方式。
方法二-通道
什么是通道
通道是 Go 自带的、唯一的可以满足并发安全的类型,通道相当于是一个先进先出的队列,通道中的元素会按照插入进来时候的顺序再发送出去。
通道的特性
一、进出通道的值都是副本数据
当向通道内传值时,传递的其实是原本元素的副本,移动时也是同理。
二、对于同一个通道,发送操作之间是互斥的,接收操作之间也是互斥的。
当有操作要向通道发送数据的时候,其他操作的发送处理会被阻塞,只有当前面的操作执行完毕,值完全被复制进通道内之后,后面的操作才可以发送。接收通道里的值也是同理,只有当值被接受,且元素在通道内被删除之后,其他的接受操作才能被执行。
三、对于同一个通道同一元素值来说,发送和接受操作也是互斥的。
因为上面提到元素进出通道是通过副本的方式,这样做可以避免出现复制还未完成就有操作将其取走的情况。
四、发送操作和接收操作中对元素值的处理是绝对完整的。
发送至通道的操作时,绝不会出现只复制一部分的情况,同理接收通道时,通道在准备好元素值的副本之后一定会将通道内的原值删除。
五、发送和接受操作在未完成之前会一直阻塞
其实就是为了实现操作的互斥和元素值的完整。
什么是非缓冲通道
无缓冲队列表示长度为 0 的通道,长度为 0 表示这个通道不能保留信息,数据是直接从发送方复制到接收方,当有信息传进来时,发送方会阻塞,直到有接收方接受这个值,当然我们也可以先找到一个接收方去接收(但是这里有个坑>>>需要注意死锁)。
什么是缓冲通道
缓冲队列就是表示长度大于 0 的通道,这里的通道相当于一个中转仓库。如果通道满了,那么对它的所有发送操作都会被阻塞,直到通道中有元素值被接收走,通道会优先通知最早因此在等待的发送操作。同理,如果通道已空,那么对它的所有接收操作都会被阻塞,直到通道中有新的元素值出现。这时,通道会通知最早等待的那个接收操作。
通道的简单使用
在声明通道时,我们要定义通道内元素的类型 chan [type]
<-是发送至通道和接收通道元素的操作符,通道在左侧表示向通道内发送,通道在右侧表示从通道内接收
通道定义之后,一定要初始化,对于没有进行初始化的通道,发送和接收操作都是阻塞的
非缓冲通道
定义一个非缓冲通道,通道内元素类型为int
var ch0 = make(chan int)
func set() {
for i := 0; i < 3; i++ {
time.Sleep(time.Millisecond * 1000)
fmt.Println(i)
}
ch0 <- 999
}
func main() {
//val := <-ch0
go set()
fmt.Println("work in here")
val2 := <-ch0
fmt.Println("get value")
fmt.Println(val2)
fmt.Println("work finished")
}
这段代码主协程中先开启了一个子协程,然后从通道中接受一个值,并打印出来,运行结果如下。
主协程执行到val2 := <-ch0这一行时发生了阻塞,三秒过后子协程向通道中发送了元素值。主协程从通道中接收到了值,然后继续向下走。
work in here
0
1
2
get value
999
work finished
缓冲通道
func main() {
定义一个大小为3的通道
chn := make(chan int, 3)
chn <- 1
chn <- 2
chn <- 3
fmt.Printf("get value: %v\n", <-chn)
fmt.Printf("get value: %v\n", <-chn)
fmt.Printf("get value: %v\n", <-chn)
}
get value: 1
get value: 2
get value: 3
小心死锁
有一个需要注意的地方,如果我们把非缓冲通道示例代码中主协程方法中的第一行代码解开注释再运行,会发现程序出现了报错。
表示所有的协程都睡眠了,发生了死锁。
fatal error: all goroutines are asleep - deadlock!
其实原因也很简单,就比如那上面的代码来说。我们上来就在主协程中接收通道中的值,而此时通道中没有值,所以主协程会阻塞,然而此时我们并没有开启其他的协程,那就相当于这个程序后面将不会有没有任何操作,永远锁在了这个位置。所以如果在阻塞期间发现没有正在执行的协程,程序将爆出异常退出。
所以我们在对通道进行操作时,要注意千万不要在逻辑上把自己锁死了。
使用通道实现协程等待
用起来有点像 JAVA 中的 CountDownLatch
首先我们需要知道子协程的数量 num
然后我们创建一个大小为 num 的通道
当子协程完全执行完之后就向通道中放一个元素值
主协程从通道中循环取值,取值的次数就是 num,取不到值时会阻塞,而这 num 个值只有当全部子协程都执行完毕之后才能提供全,所以这样就实现了主协程等待子协程
至于为什么要创建 struct{} 类型的通道,是因为空结构体占用了0字节的内存空间
func main() {
num := 5
sign := make(chan struct{}, num)
for i := 0; i < num; i++ {
go func() {
fmt.Println(i)
sign <- struct{}{}
}()
}
for j := 0; j < num; j++ {
<-sign
}
}
来源:https://mingvvv.blog.csdn.net/article/details/127611928


猜你喜欢
- 以一种有意义的方式组织数据可能是一项挑战。有时你需要的可能是一个简单的排序,但是通常你需要做更多,你需要分组来进行分析和统计。幸运的是,SQ
- 用v-model绑定单选框能带来很多便捷的开发体验。基础用法<template> <div id="app&qu
- 引包引入对应的包,和原来一样写一个打印文字的方法import sys, random, pygamefrom pygame.lo
- 直接进入主题立方体每列颜色不同:# Import librariesimport matplotlib.pyplot as pltfrom
- 确定数据库内有多少记录,或者确定有多少记录达到了某些标准,这些用ASP完成并非难事。如果你采用了正确的游标类型,你可以用RecordCoun
- antd-日历组件,前后禁止选择,只能选中间一部分:dateDisabledDate(current) { // 需求有效期的禁止选择时间
- 本文实例为大家分享了Tensorflow之MNIST CNN实现并保存、加载模型的具体代码,供大家参考,具体内容如下废话不说,直接上代码#
- 在JAVA WEB应用中,如何获取servlet请求中的参数,并传递给跳转的JSP页面?例如访问http://localhost:8088/
- 1.文本框只能输入数字代码(小数点也不能输入)<input onkeyup="this.value=this.va
- 本文实例讲述了GO语言实现列出目录和遍历目录的方法。分享给大家供大家参考。具体如下:GO语言获取目录列表用 ioutil.ReadDir()
- 本项目是利用五年左右的世界地震数据,通过python的pandas库、matplotlib库、basemap库等进行数据可视化,绘制出地震散
- 二维正态分布采样后,绘制置信椭圆假设二维正态分布表示为:下图为两个二维高斯分布采样后的置信椭圆和每个二维高斯分布采样100个数据点,图片为:
- 最近发现一常见的加载进度条(loadding)的问题,所以试试,觉得还不错,大家可以看下.当然这个只是一个效果而已!呵呵,用的着的时候,你就
- 点阵字体是指根据文字的像素点来显示的字体,效果如下:使用Python读取并显示的过程如下:根据中文字符获取GB2312编码通过GB2312编
- Vue路由跳转传参或打开新页面跳转1. 通过路由中的name属性 使用params传递参数, 使用this.$route.para
- 在php编写中有时会用户页面跳转,在这里收集了几种不错的跳转方法,可以用到。用HTTP头信息实现也就是用PHP的HEADER函数。PHP里的
- 5.0版本和之前版本的差异较大,本篇对熟悉3.2版本的用户给出了一些5.0的主要区别。URL和路由5.0的URL访问不再支持普通URL模式,
- 目标是拷贝微信的飞机大战,当然拷贝完以后大家就具备自己添加不同内容的能力了。首先是要拿到一些图片素材,熟悉使用图像处理软件和绘画的人可以自己
- SOCKET编程socket(套接字):是一个网络通信的端点,能实现不同主机的进程通信, -通过IP+端口定位对方并发送消息的通信机制分为U
- golang常用库:gorilla/mux-http路由库使用golang常用库:配置文件解析库-viper使用golang常用库:操作数据