前言
TimerTickerTicker
Ticker
Ticker是周期性定时器,即周期性的触发一个事件,它会以一个间隔(interval)往channel发送一个事件(当前时间),而channel的接收者可以以固定的时间间隔从channel中读取事件。通过Ticker本身提供的管道将事件传递出去。
应用示例
输出结果:
1 ====> 2022-08-24 15:58:38.971837 +0800 CST m=+1.001366085
2 ====> 2022-08-24 15:58:39.971154 +0800 CST m=+2.000695418
3 ====> 2022-08-24 15:58:40.971633 +0800 CST m=+3.001185460
4 ====> 2022-08-24 15:58:41.97109 +0800 CST m=+4.000654126
5 ====> 2022-08-24 15:58:42.971594 +0800 CST m=+5.001169210
创建定时器
使用NewTicker()方法就可以创建一个周期性定时器,函数如下:
其中参数d即为定时器时间触发的周期,为一个时间段。
停止定时器
使用定时器对外暴露的 Stop 方法就可以停掉一个周期性定时器, 函数如下:
该方法会停止计时,停止后不会向定时器的管道中写入事件,但管道并不会被关闭。
管道在使用完成后,生命周期结束后会自动释放。
实现原理
数据结构
Ticker的数据结构与Timer完全一致:
src/time.sleep.go:TickerTimer
channelTicker.Cchannel
Ticker.CTickerTicker.r
runtimeTimer
runtimeTimer与Timer一样,任务的载体,用于监控定时任务,每创建一个Timer就创建一个runtimeTimer变量,然后把它交给系统进行监控,我们通过设置runtimeTimer过期后的行为来达到定时的目的。
源码包src/time/sleep.go:runtimeTimer定义了其数据结构:
创建Ticker
NewTicker()构造了一个Ticker,然后把Ticker.r通过startTimer()交给系统协程维护。
其中period为事件触发的周期。
停止Ticker
停止Ticker,只是把Ticker从系统协程中移除。
stopTicker()即通知系统协程把该Ticker移除,即不再监控。系统协程只是移除Ticker并不会关闭管道,以避免用户协程读取错误。
注意:
Ticker在使用完后务必要释放,否则会产生资源泄露,进而会持续消耗CPU资源,最后会把CPU耗尽。
Ticker 与 Timer 区别
- Ticker —— 重复性执行任务非常有用呢
- Timer —— 用于执行一次性任务
小结
Ticker相关内容总结如下:
- 使用time.NewTicker()来创建一个定时器;
- 使用Stop()来停止一个定时器;
- 定时器使用完毕要释放,否则会产生资源泄露;
如果需要了解Timer,可以看这篇文章 https://www.jb51.net/article/260598.htm