Go定时器的三种实现方式
编程三分钟
共 2001字，需浏览 5分钟
·
2022-12-22 10:16
很多时候需要周期性的执行某些操作，就需要用到定时器。定时器有三种思路。
Sleep
使用休眠，让当前Goroutine休眠一定的时间来实现定时的效果，缺点是程序执行速度不均匀，导致定时周期不均匀。
for{
fmt.Println(time.Now())
time.Sleep(time.Second*1)
}
Timer
Go 语言的内置包，指定一个时间开始计时，时间到之后会向外发送通知，发送通知的方式就是使用<-chan Time 返回内容。
第一种方式，直接在需要等待处使用，效果和Sleep一样，一使用就卡在那了内部就是使用了Timer。
fmt.Println(time.Now())
<-time.After(1*time.Second)
fmt.Println(time.Now())
也可以把他拆分开，在任意地方进行等待
timer := time.NewTimer(1 * time.Second)
<-timer.C
fmt.Println(time.Now())
但是以上只是做到延迟一次性执行，我们来改造一下，把他变成定时器。
done := make(chan struct{})
timer := time.NewTimer(1 * time.Second)
go func() {
for {
select {
case <-timer.C:
fmt.Println(time.Now())
timer.Reset(1 * time.Second)
case <-done:
return
}
}
}()
<-time.After(5*time.Second + time.Millisecond*100)
done <- struct{}{}
定义子 Goroutine的目的是为了防止形成死锁，让定时器最终能退出，在实际项目中可能需要一个永久运行的定时器，一般为了不影响项目主逻辑也会这样定义。如果你的项目就是定时任务，我建议也这么写，这样可以注册很多个定时器互不影响。done是为了判断执行是否结束，防止主Goroutine提前退出。这个示例只有两个 case，实战中如果有加其他case需要给每个case内都做一次Reset，保证重置定时器。
Ticker
相比上述使用延迟执行功能实现的定时器，Ticker 本身就是一个定时器(内部封装了Timer)，我们使用起来就非常简单。
ticker := time.NewTicker(1 * time.Second)
go func() {
for {
<-ticker.C
fmt.Println(time.Now())
}
}()
<-time.After(5 * time.Second + time.Millisecond*100)
ticker.Stop()
在select 一节中讲述的官方超时控制方案非常的实用，也是使用的此函数。还使用到timer.Stop和timer.Reset这两个内置函数这里就不展开讲解了，建议进行复习。
小结
定时器一般用来周期性执行任务，比如定时同步数据、计算报表、发送通知。
time.Sleep使用休眠，让当前goroutine休眠一定的时间来实现定时的效果，缺点是内部逻辑执行的速度会影响到定时器的时间差，无法做到精确间隔。Timer类似于Sleep的延迟处理，通过channel来获得通知，也可以改造成定时器。因为是延迟处理，所以要记得重置时间来实现定时执行的效果。Ticker现成的定时器，内部也是封装了Timer。
评论