首先先上一段问题代码
package main
import (
"fmt"
"time"
)
func main() {
//closeChannel()
//var i int
go func() {
for {
select {
case <-time.After(time.Second * 4): // 代码段1
fmt.Println("4s timeout。。。。")
default: // 代码段2
fmt.Println("default")
time.Sleep(time.Second * 5)
}
}
}()
time.Sleep(time.Second * 10)
fmt.Println("main退出")
}
以上代码有点小问题
在上面这段代码中,代码块1的case是 永远不会执行的 ,无论main进程执行多久。这是为什么呢?
经过笔者的试验,发现程序一直执行的是 default 后的代码。这是笔者在工作项目中遇到的问题,问题代码并不像给出的demo那么简略。起初笔者以为是因为在协程里面启协程导致time.After失效。但是后来一想,应该不是这个原因,各个协程之间应该是互相独立互不干扰的。因此笔者判断会出现这种原因可能是由于:
case <-time.After(time.Second * 4):
这是本次监听动作的超时时间,也就是说,只有在 本次select 中才会生效,再次select又会 重新开始计时(从当前时间+4秒),但是有default,所以case超时操作就肯定执行不到了。
换句话说,只要先定义计时操作就行了。
修改后的代码
package main
import (
"fmt"
"time"
)
func main() {
timeout := time.After(time.Second * 4)
go func() {
for {
select {
case <- timeout: // 代码段1
fmt.Println("4s timeout。。。。")
default: // 代码段2
fmt.Println("default")
time.Sleep(time.Second * 5)
}
}
}()
time.Sleep(time.Second * 10)
fmt.Println("main退出")
}
在协程开始前,我们就已经设置了超时时间,这就类似是定时任务了。但是,这样有一个小问题 他只执行一次。
本文查询资料有:点我点我
以上