for select
是一个多分支循环,其中 select
分支如果都没有准备好执行,那么 default
默认分支就会被执行。
为了非阻塞的发送或接收,就可以使用 default
分支。
我们举例一个爆破过程,有读秒、有爆炸、有过程。读秒为每半秒钟读一次,过程为1/4秒一个记录,最后爆炸。完结。
先准备两个计时器,分别设定读秒时长和爆炸时长。
tick := time.Tick(500 * time.Millisecond)
boom := time.After(2000 * time.Millisecond)
然后使用 for select
循环,“过程”会执行 default
分支,“读秒”会执行 <-tick
分支,直到“爆炸” <- boom
分支执行到 return
,循环结束。
for {
select {
case <-tick:
fmt.Println("tick.")
case <-boom:
fmt.Println("boom!")
return
default:
fmt.Println(" .")
time.Sleep(250 * time.Millisecond)
}
}
由于 tick 和 boom 分别需要 500 和 2000 毫秒才会有数据过来,那么其他时间会执行 default
。而 default
每次执行会休眠 250毫秒,所以每 250毫秒才会输出一个 " ." 。
package main
import (
"time"
"fmt"
)
func main() {
tick := time.Tick(500 * time.Millisecond)
boom := time.After(2000 * time.Millisecond)
for{
select {
case <-tick:
fmt.Println("tick.")
case <-boom:
fmt.Println("boom!")
return
default:
fmt.Println(" .")
time.Sleep(250 * time.Millisecond)
}
}
}
运行结果
.
.
tick.
.
.
tick.
.
.
tick.
.
.
boom!
如果你删除 time.Sleep(250 * time.Millisecond)
这条语句,就会发现,程序运行开始后,会一直执行 default
,直到 boom。多运行几次,偶尔会显示 tick 。这是在抢通道么?由于上一次执行的 default
,所以再次循环过来的时候,大多数情况下优先执行 default
了。