select 是 Golang 中的一个控制结构,语法上类似于switch 语句,只不过select是用于 goroutine 间通信的 ,每个 case 必须是一个通信操作,要么是发送要么是接收,select 会随机执行一个可运行的 case。如果没有 case 可运行,goroutine 将阻塞,直到有 case 可运行。
select 多路选择
select写法上跟switch case的写法基本一致,只不过golang的select是通信控制语句。select的执行必须有通信的发送或者接受,如果没有就一直阻塞。
ch := make(chan bool, 0) ch1 := make(chan bool, 0) select { case ret := <-ch: fmt.Println(ret) case ret := <-ch1: fmt.Println(ret) }
如果ch和ch1都没有通信数据发送,select就一直阻塞,直到ch或者ch1有数据发送,select就执行相应的case来接受数据。
select 实现超时控制
我们可以利用select机制实现一种简单的超时控制。
先看下程序完整执行的代码
func service(ch chan bool) { time.Sleep(time.Second*3) ch<-true } func main() { ch := make(chan bool, 0) go service(ch) select { case ret := <-ch: fmt.Println(ret) case <-time.After(time.Second*5): fmt.Println("timeout") } } ___go_build_main_go #gosetup true
可以看到使用time.After超时定义了5S,service程序执行3S,所以肯定没有超时,跟预想的一致。
我们再看看超时的执行,我们将service程序执行时间该为6S。超时控制继续是5S,再看下执行效果
func service(ch chan bool) { time.Sleep(time.Second*6) ch<-true } func main() { ch := make(chan bool, 0) go service(ch) select { case ret := <-ch: fmt.Println(ret) case <-time.After(time.Second*5): fmt.Println("timeout") } } ___go_build_main_go #gosetup timeout
执行到了超时的case,跟预想的其实是一致的。
select 判断channel是否关闭
先看下接受数据的语法
val,ok <- ch ok true 正常接收数据 ok false 通道关闭
可以看到接受数据其实有两个参数,第二个bool值会反应channel是否关闭,是否可以正常接受数据。
看下测试代码
我们写了一个数据发送者,两个数据接收者,当发送者关闭channel的时候,两个接收者的 goroutine 可以通过以上的语法判断channel是否关闭,决定自己的 goroutine 是否结束。
func sender(ch chan int, wg *sync.WaitGroup) { for i:=0;i<10;i++ { ch<-i } close(ch) wg.Done() } func receiver(ch chan int, wg *sync.WaitGroup) { for { if val,ok := <-ch;ok { fmt.Println(fmt.Sprintf("%d,%s",val, "revevier")) } else { fmt.Println("quit recevier") break; } } wg.Done() } func receiver2(ch chan int, wg *sync.WaitGroup) { for { if val,ok := <-ch;ok { fmt.Println(fmt.Sprintf("%d,%s",val, "revevier2")) } else { fmt.Println("quit recevier2") break; } } wg.Done() } func main() { ch := make(chan int, 0) wg := &sync.WaitGroup{} wg.Add(1) go sender(ch, wg) wg.Add(1) go receiver(ch, wg) wg.Add(1) go receiver2(ch, wg) wg.Wait() }
执行结果
0,revevier2
2,revevier2
3,revevier2
4,revevier2
5,revevier2
6,revevier2
7,revevier2
1,revevier
9,revevier
quit recevier
8,revevier2
quit recevier2
可以看到一个数据发送者,两个数据接收者,当channel关闭的时候,两个数据接收者都收到了channel关闭的通知。
需要注意的是,给一个已经关闭的channel发送数据,程序会panic,从一个已经关闭的channel接收数据,会接收到没有参考意义的channel类型的0值数据,Int是0,string是空...
select 退出计时器等程序
开发中经常会经常会使用轮训计时器,但是当程序退出时,轮训计时器无法关闭的问题。其实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 <-q: fmt.Println("quit") return case <-t.C: fmt.Println("seconds timer") } } } func main() { q := make(chan bool) wg := new(sync.WaitGroup) wg.Add(1) go TimeTick(wg,q) time.Sleep(time.Second*10) close(q) wg.Wait() }
执行结果
seconds timer
seconds timer
seconds timer
quit
很优雅的通过关闭channel退出了轮训计时器 goroutine,
免责声明:本站资源来自互联网收集,仅供用于学习和交流,请遵循相关法律法规,本站一切资源不代表本站立场,如有侵权、后门、不妥请联系本站删除!
稳了!魔兽国服回归的3条重磅消息!官宣时间再确认!
昨天有一位朋友在大神群里分享,自己亚服账号被封号之后居然弹出了国服的封号信息对话框。
这里面让他访问的是一个国服的战网网址,com.cn和后面的zh都非常明白地表明这就是国服战网。
而他在复制这个网址并且进行登录之后,确实是网易的网址,也就是我们熟悉的停服之后国服发布的暴雪游戏产品运营到期开放退款的说明。这是一件比较奇怪的事情,因为以前都没有出现这样的情况,现在突然提示跳转到国服战网的网址,是不是说明了简体中文客户端已经开始进行更新了呢?
更新日志
- 《哈迪斯2》第二关boss打法攻略
- 天艺发烧精选试音王【非卖品】壹【WAV】
- 金海心.-.玲珑[WAV+CUE]
- 杜如松2007-《笛声吹向云水间》2CD笛箫独奏专辑[WAV+CUE]
- 美国要给奶牛吃小袋鼠的便便:称是阻止全球变暖
- 华硕ROG新掌机6月正式公开 续航能力或将翻倍
- 赞达亚拍摄杂志新写真:身材纤细曼妙 吸睛引人遐想
- 赵鹏《天净沙 2023头版限量编号24K金碟》[WAV+CUE][550MB]
- 张碧晨《开往早晨的午夜 首张个人专辑》[WAV+CUE][450MB]
- 群星《2023数字精品 Live合唱版》[FLAC+CUE][550MB]
- 杨润泽.2024-于是我抱住一棵树【FLAC分轨】
- 伍思凯.1999-怎么做朋友【点将】【WAV+CUE】
- 关德辉.1995-无怨无尤【飞碟】【WAV+CUE】
- 未来少年柯南 未来少年コナン
- 十角馆杀人事件 十角館の殺人