本文将与您分享go concurrency中select示例分析的内容。我觉得边肖很实用,就和大家分享一下作为参考。让我们跟着边肖看一看。
00-1010对于Go语言中的并发通信,使用协同学goroutine,而协同学之间的通信使用channel。但是,无论通道缓存还是不缓存,都会出现拥塞,但没有缓存的拥塞会更频繁。但是协同过程长期被阻断后,Go语言本身并没有提供这种超时解决机制,所以开发者需要考虑自行实现这种超时机制。这个超时机制是通过在Go语言中选择来解决的。
相关背景知识:
1.围棋语言并发文章(1):围棋句子文章:https://mp.weixin.qq.com/s/FD-MP9r5sEn1QYRAYZE_4g
2.GO语言中goroutine的调度原则:https://mp.weixin.qq.com/s/hTgIyJN7p-wrDfLj1bP1wQ
3.Go并发频道:https://mp.weixin.qq.com/s/PIb-gGBootc6581pHhi5ew
00-1010我们先来看几个问题。什么是选择?它的特点是什么?
语法定义:
选择Go是语言中的控制语句。它由select、case和default组成,类似于switch的编写方式。
Select仅用于读写操作通道。
(注意:golang的select本质上是监控IO操作,当IO操作发生时触发相应的动作。它也是一种常用的复用方式,如poll、epoll(这将在另一篇文章中介绍)、select)
示例:
Select的特性:
1.如果只计算并传递了一个case语句,那么在这种情况下执行该语句。
2.如果评估并传递了多个case语句,则通过伪随机随机选择一个。
3.如果除default之外的case语句未能通过评估,则默认执行这些语句。
4.如果没有默认值,代码块将被阻止,直到一个案例通过评估;否则,它会一直阻塞。
特征1:的示例选择可以评估和通过的正常情况:
没有默认分支和选择阻止的功能4:的示例:
与功能1相比,我们会发现,当select无法检测到案例正在接收c1数据时,它会在哪里阻塞,并且不会打印“go end!”
属性3:有一个默认示例:
如果select中有default,如果case未命中,将直接进入默认分支,协同过程也将结束,不会阻塞。
当同时满足23360多个案例时,随机抽取一个案例。
从输出可以看出,虽然通道c1和c2基本上同时向通道写入数据,但select选择了c2,忽略了c1。
00-1010在阅读了select的特性后,作者知道了如何使用channel。但是你到底什么时候用select呢?于是作者又问了自己一个问题。
select有哪些应用场景,为什么需要select?
场景一:实现无阻塞读写操作。
根据select的特性3(如果default以外的case语句没有通过评估,那么执行default中的语句),我们可以实现无阻塞读写操作。
当服务器不希望用户继续向用户推送数据时,通常会出现这种情况。
阻塞在读操作上面。代码实例参考特性3的例子,我们利用default来跳过这个阻塞过程。
场景二: 为请求设置超时时间。
这一个场景也就是前言介绍里面提到的协程通讯时候,长时间收不到读写操作,导致协程一直被阻塞的情况,而超时机制则是一个很常规的操作。我们来看下例子:
1.复现channel阻塞的例子:
2.超时处理的例子:
例子1,因为channel中没有数据可读,导致协程一直阻塞住,并没有go end的日志打印出来。
例子2, 虽然channel 中依然没有数据可读,但是我们实现了超时机制,在2s超时之后,select会触发超时相关的channel,进而结束协程go的阻塞,打印出go end日志。
场景三: 调度协程,控制其他协程的退出或者完成
在并发程序中,通常 main goroutine 将任务分给其它 goroutine 去完成,而自身只是起到调度作用。这种情况下,main goroutine无法知道 其它goroutine 任务是否完成,此时我们需要 done channel来协助完成。
例子为:
不实用done channel的方式,会发现main的goroutinue并不会等待其他的goroutine结束之后,才结束,也不知道其他的goroutiue何时结束。
添加了done channel之后,main goroutinue可以等待其他的goroutinue结束之后,再结束。
感谢各位的阅读!关于“go并发中select的示例分析”这篇文章就分享到这里了,希望
内容来源网络,如有侵权,联系删除,本文地址:https://www.230890.com/zhan/99782.html