上海网站建设中小型企业,公司网站备案名称,易思espcms企业网站管理系统,高端 建站目录 1、背景2、go版本3、源码解释【1】Ticker结构【2】NewTicker函数解释 4、代码示例5、总结 1、背景
说到定时器我们一般想到的库是cron#xff0c;但是对于一些简单的定时任务场景#xff0c;标准库time包下提供的定时器就足够我们使用#xff0c;本篇文章我们就来研究… 目录 1、背景2、go版本3、源码解释【1】Ticker结构【2】NewTicker函数解释 4、代码示例5、总结 1、背景
说到定时器我们一般想到的库是cron但是对于一些简单的定时任务场景标准库time包下提供的定时器就足够我们使用本篇文章我们就来研究一下time包下的Ticker定时器。
2、go版本 $ go version go version go1.21.4 windows/386 3、源码解释
【1】Ticker结构
Ticker结构如下
type Ticker struct {C -chan Time //元素类型为Time的只读通道r runtimeTimer //底层定时结构
}runtimeTimer结构如下
type runtimeTimer struct {pp uintptrwhen int64 //定时器触发时间period int64 //定时器触发间隔f func(any, uintptr) //定时器触发要执行的函数arg any //定时器触发执行函数的参数seq uintptrnextwhen int64 //定时器下次触发时间status uint32
}【2】NewTicker函数解释
NewTicker函数用于初始化Ticker对象源码如下
func NewTicker(d Duration) *Ticker {if d 0 {panic(non-positive interval for NewTicker)}c : make(chan Time, 1) //初始化一个存放时间类型缓冲区大小为1的通道t : Ticker{C: c, //时间通道r: runtimeTimer{ //底层定时对象when: when(d), //下一次任务执行时间period: int64(d), //每次任务执行间隔f: sendTime, //时间到之后要执行的函数arg: c, //要执行的函数的参数},}startTimer(t.r) //开启定时任务更底层逻辑不用关心其实现return t
}初始化之后我们一般使用Ticker对象的方式为间隔d时间从Ticker对象里的C通道读取到当前时间一般我们认为到时间之后就会往C通道写入当前时间每次间隔时间都能读到数据其实每次间隔不一定能读到这个就看sendTime函数的实现了源码如下
func sendTime(c any, seq uintptr) {select {case c.(chan Time) - Now():default:}
}select中有一个default块前面看过c通道的缓冲区大小为1如果上一次缓冲区里记录的时间未被读取那么这次写c通道就会阻塞select没有找到合适的case时就会走default分支所以这次时间并不会记录到通道缓冲区中就已经开始准备下一个到时间点执行逻辑。后面会给一个简单的例子来演示这种场景。
4、代码示例
接下来给一个示例来演示从Ticker的通道中读取时间不一定是固定间隔的示例如下
func main() {logger.Info(测试Ticker开始)t : time.NewTicker(5 * time.Second) //创建一个定时器,每隔5秒执行一次time.Sleep(17 * time.Second) //延时5552秒logger.Info(第1次读取通道, zap.Time(读取到的时间, -t.C))logger.Info(第2次读取通道, zap.Time(读取到的时间, -t.C))
}上面示例初始化了一个每5秒执行一次的定时对象我们延时5的整数倍再加小于5的时间之后从定时对象的通道中读取两次时间并打印出来观察打印输出如下
[2024-11-29 17:31:12.902] | INFO | Goroutine:1 | [chan_demo/main.go:74] | 测试Ticker开始
[2024-11-29 17:31:29.981] | INFO | Goroutine:1 | [chan_demo/main.go:80] | 第1次读取通道 | {读取到的时间: [2024-11-29 17:31:17.986]}
[2024-11-29 17:31:32.978] | INFO | Goroutine:1 | [chan_demo/main.go:81] | 第2次读取通道 | {读取到的时间: [2024-11-29 17:31:32.978]}开始定时任务时间为12秒第1次读取通道和第2次读取通道时间分别为17和32秒并不是间隔5秒的也就验证了22、27秒走的sendTime函数中的default分支。
5、总结
通过对Ticker对象中通道的理解在select中有多个case时对于准备好的caseselect会从中随机选择一个所以要注意case中如有Ticker的通道对象时不一定会定时间隔的读取到数据。Ticker对象还提供了一些其它的函数Stop(停止定时器)、Reset(重置定时器)、Tick(返回只读的时间通道)。
