社区微信群开通啦,扫一扫抢先加入社区官方微信群
社区微信群
select 是 Golang 中的一个控制结构,语法上类似于switch 语句,只不过select是用于 goroutine 间通信的 ,每个 case 必须是一个通信操作,要么是发送要么是接收,select 会随机执行一个可运行的 case。如果没有 case 可运行,goroutine 将阻塞,直到有 case 可运行。
select写法上跟switch case的写法基本一致,只不过golang的select是通信控制语句。select的执行必须有通信的发送或者接受,如果没有就一直阻塞。
ch := make(chan bool, 0)ch1 := make(chan bool, 0)select {case ret :=
如果ch和ch1都没有通信数据发送,select就一直阻塞,直到ch或者ch1有数据发送,select就执行相应的case来接受数据。
我们可以利用select机制实现一种简单的超时控制。
先看下程序完整执行的代码
func service(ch chan bool) {time.Sleep(time.Second*3)ch
可以看到使用time.After超时定义了5S,service程序执行3S,所以肯定没有超时,跟预想的一致。
我们再看看超时的执行,我们将service程序执行时间改为6S。超时控制继续是5S,再看下执行效果
func service(ch chan bool) {time.Sleep(time.Second*6)ch
执行到了超时的case,跟预想的其实是一致的。
先看下接受数据的语法
val,ok
可以看到接受数据其实有两个参数,第二个bool值会反应channel是否关闭,是否可以正常接受数据。
看下测试代码
我们写了一个数据发送者,两个数据接收者,当发送者关闭channel的时候,两个接收者的 goroutine 可以通过以上的语法判断channel是否关闭,决定自己的 goroutine 是否结束。
func sender(ch chan int, wg *sync.WaitGroup) {for i:=0;i<10;i++ {ch
执行结果
0,revevier22,revevier23,revevier24,revevier25,revevier26,revevier27,revevier21,revevier9,revevierquit recevier8,revevier2quit recevier2
可以看到一个数据发送者,两个数据接收者,当channel关闭的时候,两个数据接收者都收到了channel关闭的通知。
需要注意的是,给一个已经关闭的channel发送数据,程序会panic,从一个已经关闭的channel接收数据,会接收到没有参考意义的channel类型的0值数据,Int是0,string是空...
开发中经常会经常会使用轮训计时器,但是当程序退出时,轮训计时器无法关闭的问题。其实select是可以解决这个问题的。
如果我们有一个轮训任务,需要一个timer,每隔3S执行逻辑,过完10S之后关闭这个timer。
看下代码
func TimeTick(wg *sync.WaitGroup,q chan bool) {defer wg.Done()t := time.NewTicker(time.Second*3)defer t.Stop()for {select {case
执行结果
seconds timerseconds timerseconds timerquit
很优雅的通过关闭channel退出了轮训计时器 goroutine
最后,小编想说:我是一名python开发工程师,整理了一套最新的python系统学习教程,
想要这些资料的可以关注私信小编“01”即可(免费分享哦)希望能对你有所帮助。
如果觉得我的文章对您有用,请随意打赏。你的支持将鼓励我继续创作!