关于在goroutine中使用time.After的理解， 新手在学习过程中的“此时此刻”的理解，错误还请指正。
先线上代码：
package main
import (
"fmt"
"time"
)
func main() {
//closeChannel()
c := make(chan int)
timeout := time.After(time.Second * 2) //
t1 := time.NewTimer(time.Second * 3) // 效果相同 只执行一次
var i int
go func() {
for {
select {
case <-c:
fmt.Println("channel sign")
return
case <-t1.C: // 代码段2
fmt.Println("3s定时任务")
case <-timeout: // 代码段1
i++
fmt.Println(i, "2s定时输出")
case <-time.After(time.Second * 4): // 代码段3
fmt.Println("4s timeout。。。。")
default: // 代码段4
fmt.Println("default")
time.Sleep(time.Second * 1)
}
}
}()
time.Sleep(time.Second * 6)
close(c)
time.Sleep(time.Second * 2)
fmt.Println("main退出")
}
主要有以上4点是我们平时遇到的。
首先遇到的问题是：
如上的代码情况下， 代码段3处的case 永远不执行， 无论main进程执行多久。这是为什么呢？
首先我们分析为啥不执行代码段3， 而是程序一直执行的是default. 由此我们判断：
case <- time.After(time.Second) :
是本次监听动作的超时时间， 意思就说，只有在本次select 操作中会有效， 再次select 又会重新开始计时（从当前时间+4秒后）， 但是有default ，那case 超时操作，肯定执行不到了。
那么问题就简单了我们预先定义了计时操作：
case <- timeout:
在goroutine开始前， 我们记录了时间，在此时间3s之后进行操作。相当于定时任务， 并且只执行一次。 代码段1和代码段2 实现的结果都相同
针对以上问题解决后，我写了一个小案例：
package main
import (
"fmt"
"time"
)
//发送者
func sender(c chan int) {
for i := 0; i < 100; i++ {
c <- i
if i >= 5 {
time.Sleep(time.Second * 7)
} else {
time.Sleep(time.Second)
}
}
}
func main() {
c := make(chan int)
go sender(c)
timeout := time.After(time.Second * 3)
for {
select {
case d := <-c:
fmt.Println(d)
case <-timeout:
fmt.Println("这是定时操作任务 >>>>>")
case dd := <-time.After(time.Second * 3):
fmt.Println(dd, "这是超时*****")
}
fmt.Println("for end")
}
}
执行结果：
要注意的是，虽然执行到i == 6时， 堵塞了，并且执行了超时操作， 但是下次select 依旧去除的是6
因为通道中已经发送了6,如果未取出，程序堵塞。
有疑问加站长微信联系（非本文作者）
