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 了。
网友评论