Go Ticker 周期性定时器用法及实现原理详解

对于一个Golang开发者来说，牢固扎实的基础是十分重要的，golang学习网就来带大家一点点的掌握基础知识点。今天本篇文章带大家了解《Go Ticker 周期性定时器用法及实现原理详解》，主要介绍了定时器、Ticker、周期性，希望对大家的知识积累有所帮助，快点收藏起来吧，否则需要时就找不到了！

Ticker

Ticker是周期性定时器，即周期性的触发一个事件，它会以一个间隔(interval)往channel发送一个事件(当前时间)，而channel的接收者可以以固定的时间间隔从channel中读取事件。通过Ticker本身提供的管道将事件传递出去。

应用示例

package main
import (
	"fmt"
	"time"
)
func main()  {
	ticker := time.NewTicker(time.Second * 1) //创建一个周期性定时器
	i := 1
	for  {
		fmt.Println(i, "====>", 
<p>输出结果：</p>
<blockquote><p>1 ====> 2022-08-24 15:58:38.971837 +0800 CST m=+1.001366085<br>2 ====> 2022-08-24 15:58:39.971154 +0800 CST m=+2.000695418<br>3 ====> 2022-08-24 15:58:40.971633 +0800 CST m=+3.001185460<br>4 ====> 2022-08-24 15:58:41.97109 +0800 CST m=+4.000654126<br>5 ====> 2022-08-24 15:58:42.971594 +0800 CST m=+5.001169210</p></blockquote>
<h3>创建定时器</h3>
<p>使用NewTicker()方法就可以创建一个周期性定时器，函数如下：</p>
<pre class="brush:go;">func NewTicker(d Duration) *Ticker

其中参数d即为定时器时间触发的周期，为一个时间段。

停止定时器

使用定时器对外暴露的 Stop 方法就可以停掉一个周期性定时器， 函数如下：

func (t *Ticker) Stop()

该方法会停止计时，停止后不会向定时器的管道中写入事件，但管道并不会被关闭。

管道在使用完成后，生命周期结束后会自动释放。

实现原理

数据结构

Ticker的数据结构与Timer完全一致：

通过src/time.sleep.go:Ticker定义了Timer数据结构:

type Ticker struct {
    C 
<p>它提供了一个<code>channel</code>，在定时时间到达之前，没有数据写入<code>Ticker.C</code>会一直阻塞，直到时间到达，向<code>channel</code>写入系统时间，阻塞解除，可以从中读取数据，这就是一个事件。</p>
<p>我们可以理解为<code>Ticker.C</code>即面向<code>Ticker</code>用户的，<code>Ticker.r</code>是面向底层的定时器实现。</p>
<h3>runtimeTimer</h3>
<p>runtimeTimer与Timer一样，任务的载体，用于监控定时任务，每创建一个Timer就创建一个runtimeTimer变量，然后把它交给系统进行监控，我们通过设置runtimeTimer过期后的行为来达到定时的目的。</p>
<p>源码包src/time/sleep.go:runtimeTimer定义了其数据结构：</p>
<pre class="brush:go;">type runtimeTimer struct {
    tb uintptr                          // 存储当前定时器的数组地址
    i  int                              // 存储当前定时器的数组下标
    when   int64                        // 当前定时器触发时间
    period int64                        // 当前定时器周期触发间隔
    f      func(interface{}, uintptr)   // 定时器触发时执行的函数
    arg    interface{}                  // 定时器触发时执行函数传递的参数一
    seq    uintptr                      // 定时器触发时执行函数传递的参数二(该参数只在网络收发场景下使用)
}

创建Ticker

func NewTicker(d Duration) *Ticker {
    if d 
<p>NewTicker()构造了一个Ticker，然后把Ticker.r通过startTimer()交给系统协程维护。</p>
<p>其中period为事件触发的周期。</p>
<h3>停止Ticker</h3>
<p>停止Ticker，只是把Ticker从系统协程中移除。</p>
<pre class="brush:go;">func (t *Ticker) Stop() {
    stopTimer(&t.r)
}

stopTicker()即通知系统协程把该Ticker移除，即不再监控。系统协程只是移除Ticker并不会关闭管道，以避免用户协程读取错误。

注意：

Ticker在使用完后务必要释放，否则会产生资源泄露，进而会持续消耗CPU资源，最后会把CPU耗尽。

ticker := time.NewTicker(1 * time.Second)
defer ticker.Stop()

Ticker 与 Timer 区别

• Ticker —— 重复性执行任务非常有用呢
• Timer —— 用于执行一次性任务

小结

Ticker相关内容总结如下：

• 使用time.NewTicker()来创建一个定时器；
• 使用Stop()来停止一个定时器；
• 定时器使用完毕要释放，否则会产生资源泄露；

如果需要了解Timer，可以看这篇文章 https://www.jb51.net/article/260598.htm

今天关于《Go Ticker 周期性定时器用法及实现原理详解》的内容就介绍到这里了，是不是学起来一目了然！想要了解更多关于golang的内容请关注golang学习网公众号！