Timer 是一种单一事件定时器,就是说 Timer 只执行一次就会结束。
创建:
time.NewTimer(d Duration)
:创建一个 timer
源码包 src/time/sleep.go:Timer 定义了Timer数据结构:
type Timer struct {
C <-chan Time
r runtimeTimer
}
Timer 对外仅暴露了一个 channel,当指定时间到来就会往该 channel 中写入系统时间,即一个事件。
比如在一个连接中等待数据,设定一个超时时间,当时间到来还是没有数据获取到,则为超时。
func WaitChannel(conn <-chan string) bool {
timer := time.NewTimer(3 * time.Second)
select {
case <- conn:
timer.Stop()
return true
case <- timer.C: //超时
fmt.Println("WaitChannel timeout")
return false
}
}
如上示例中,select 语句轮询 conn 和 timer.C 两个管道,timer 会在 3s 后向 timer.C 写入数据,如果 3s 内 conn 还没有数据,则会判断为超时。
有时我们希望某个方法在今后的某个时刻执行:
func DelayFunction() {
timer := time.NewTimer(5 * time.Second)
select {
case <- time.C
fmt.Println("Delayed 5s,...")
}
}
DelayFunction()会一直等待timer的事件到来才会执行后面的方法(打印)。
func NewTimer(d Duration) *Timer
:
func (t *Timer) Stop() bool
:
func (t *Timer) Reset(d Duration) bool
:
有时我们就是想等指定的时间,没有需求提前停止定时器,也没有需求复用该定时器,那么可以使用匿名的定时器:
func AfterDemo(){
log.Println(time.Now)
<- time.After(1 * time.Second)
log.Println(time.Now())
}
打印时间间隔为1s,实际还是一个定时器,但代码变得更简洁。
我们可以使用 AfterFunc 更加简洁的实现延迟一个方法的调用:
func AfterFunc(d Duration, f func()) *Timer
示例:
func AfterFuncDemo() {
log.Println("AfterFuncDemo start", time.Now())
time.AfterFunc(1 * time.Second, func(){
log.Println("AfterFuncDemo end", time.Now())
})
time.Sleep(2 * time.Second) //等待协程退出
}
Ticker是周期性定时器,即周期性的触发一个事件。其数据结构和 Timer 完全一致:
type Timer struct {
C <-chan Time
r runtimeTimer
}
在创建Ticker时会指定一个时间,作为事件触发的周期。这也是Ticker与Timer的最主要的区别。
示例,每隔1s记录一次日志:
func TickerDemo() {
ticker := time.NewTicker(1 * time.Second)
defer ticker.Stop()
for range ticker.C {
log.Println("ticker...")
}
}
for range ticker.C
会持续从管道中获取事件,收到事件后打印一行日志,如果管道中没有数据会阻塞等待事件,由于 ticker 会周期性的向管道中写入事件,所以上述程序会周期性的打印日志。
func NewTicker(d Durtion) * Ticker
:
d
为定时器事件触发的周期。func (t * Ticker) Stop()
:
如果我们需要一个定时轮询任务,可以使用一个简单的Tick函数来获取定时器的管道,函数原型如下:
func TIck(d Durtion) <-chan Time
:
func WorngTicker() {
for {
select {
case <- time.Tick(1 * time.Second)
log.Println("资源泄露")
}
}
}
如上错误示例,select 每次检测 case 语句时都会创建一个定时器,for 循环又会不断的执行select语句,所以系统里会有越来越多的定时器不断的消耗 CPU 资源,最终CPU会被耗尽。
正确用法:
func demo(t interface{}) {
for {
select {
case <-t.(*time.Ticker).C:
println("1s timer")
}
}
}
func main() {
t := time.NewTicker(time.Second * 1)
go demo(t)
select {}
}
图片及部分相关技术知识点来源于网络搜索,侵权删!
参考资料:
https://book.douban.com/subject/35144587/
https://www.cnblogs.com/codingnote/archive/2020/03/12/12469098.html
https://blog.csdn.net/x356982611/article/details/80425030