Golang的select多路复用及channel使用操作
看到有个例子实现了一个类似于核弹发射装置,在发射之前还是需要随时能输入终止发射。
这里就可以用到cahnnel配合select实现多路复用。
select的写法用法有点像switch。但是和switch不同的是,select的一个case代表一个通信操作(在某个channel上进行发送或者接收)并且会包含一些语句组成的一个语句块。现在让我们来实现一下这个核弹发射器
packagemain import( "fmt" "time" "os" ) funclaunch(){ fmt.Println("nuclearlaunchdetected") } funccommencingCountDown(canLunchchanint){ c:=time.Tick(1*time.Second) forcountDown:=20;countDown>0;countDown--{ fmt.Println(countDown) <-c } canLunch<--1 } funcisAbort(abortchanint){ os.Stdin.Read(make([]byte,1)) abort<--1 } funcmain(){ fmt.Println("Commencingcoutdown") abort:=make(chanint) canLunch:=make(chanint) goisAbort(abort) gocommencingCountDown(canLunch) select{ case<-canLunch: case<-abort: fmt.Println("Launchaborted!") return } launch() }
首先打印了一个commencingcountdown开始进行倒数计时。
申明一个int类型的channel变量abort用来做取消时候传递给select的消息信号量这个后面会介绍到。
申明一个int类型的channel变量canLunch用来做倒计时结束可以发射的信号量。只有当倒数结束,且canLunch有值后才能进行发射。
用一个goroutine开启一个用于监听是否有停止发射信号的函数isAbort并且把申明好的channel变量传入。
isAbort就干一件事情,监听是否有标准输入输入,如果有输入我们默认是下达了发射停止的信号需要向abortchannel里面发送一个信号。这里我们会发射一个-1
用一个goroutine开启一个用于倒数计时的函数commencingCountDown负责开始倒计时,这里重新申明了一个TICKchannel每一秒倒数计时一下。并且在倒数计时完成之后向canLunchchannel发送信号。
然后开始执行select,select在没有就绪的channel的时候会阻塞或者执行指定的defualt,这里我没有写default所以他会阻塞监听两个信号,一个是canLunch,一个是停止发送。只要收到任何一个信号后,执行该信号后面的内容
最后运行Lunch函数。
其实把思路理清楚,以并发的思考方式去思考这类问题感觉还是不会太乱。多加练习应该会变好。下面的文章应该会开始逐步开始从服务器和连接开始,实现一个im系统。或者添加更多的实践。
补充:golang使用select完成超时
我就废话不多说了,大家还是直接看代码吧~
timeout:=make(chanbool,1) gofunc(){ time.Sleep(1e9) timeout<-true }() select{ case<-ch: //从ch中读取数据 case<-timeout: //ch一直没有数据写入,超时触发timeout }
funcmain(){ varachanstring a=make(chanstring) gosendDataTo(a) gotiming() getAchan(10*time.Second,a) } funcsendDataTo(achanstring){ for{ a<-"我是a通道的数据" time.Sleep(1e9*3) } } //在一定时间内接收不到a的数据则超时 funcgetAchan(timeouttime.Duration,achanstring){ varafter<-chantime.Time loop: after=time.After(timeout) for{ fmt.Println("等待a中的数据,10秒后没有数据则超时") select{ casex:=<-a: fmt.Println(x) gotoloop case<-after: fmt.Println("timeout.") return } } } functiming(){ //定时器,10秒钟执行一次 ticker:=time.NewTicker(10*time.Second) for{ time:=<-ticker.C fmt.Println("定时器====>",time.String()) } }
以上为个人经验,希望能给大家一个参考,也希望大家多多支持毛票票。如有错误或未考虑完全的地方,望不吝赐教。