golang定时器Timer的用法和实现原理解析

// Timer代表一次定时，时间到达后仅执行一个事件。
type Timer struct {
    C <-chan Time
    r runtimeTimer
}

func NewTimer(d Duration) *Timer

func main()  {
	timer := time.NewTimer(time.Second * 5) //设置超时时间5s

	<- timer.C
	fmt.Println("Time out!")
}

func (t *Timer) Stop() bool

func main()  {
	timer := time.NewTimer(time.Second * 5) //设置超时时间5s
    timer.Stop()
}

func (t *Timer) Reset(d Duration) bool

func main()  {
	timer := time.NewTimer(time.Second * 5)

	<- timer.C
	fmt.Println("Time out!")

	timer.Stop() 
	timer.Reset(time.Second*3)  // 重置定时器
}

type Timer struct {
    C <-chan Time
    r runtimeTimer
}

type runtimeTimer struct {
    tb uintptr                          // 存储当前定时器的数组地址
    i  int                              // 存储当前定时器的数组下标

    when   int64                        // 当前定时器触发时间
    period int64                        // 当前定时器周期触发间隔
    f      func(interface{}, uintptr)   // 定时器触发时执行的函数
    arg    interface{}                  // 定时器触发时执行函数传递的参数一
    seq    uintptr                      // 定时器触发时执行函数传递的参数二(该参数只在网络收发场景下使用)
}

func NewTimer(d Duration) *Timer {
    c := make(chan Time, 1)  // 创建一个管道
    t := &Timer{ // 构造Timer数据结构
        C: c,               // 新创建的管道
        r: runtimeTimer{
            when: when(d),  // 触发时间
            f:    sendTime, // 触发后执行函数sendTime
            arg:  c,        // 触发后执行函数sendTime时附带的参数
        },
    }
    startTimer(&t.r) // 此处启动定时器，只是把runtimeTimer放到系统协程的堆中，由系统协程维护
    return t
}

//c interface{} 就是NewTimer 赋值的参数，就是channel
func sendTime(c interface{}, seq uintptr) {
    select {
    case c.(chan Time) <- Now(): //写不进去的话，C 已满，走default 分支
    default:
    }
}

func (t *Timer) Stop() bool {
    return stopTimer(&t.r)
}

func (t *Timer) Reset(d Duration) bool {
    w := when(d)
    active := stopTimer(&t.r)
    t.r.when = w
    startTimer(&t.r)
    return active
}

// Ticker保管一个通道，并每隔一段时间向其传递"tick"。
type Ticker struct {
	C <-chan Time // 周期性传递时间信息的通道.
	r runtimeTimer
}

func NewTicker(d Duration) *Ticker{}

func (t *Ticker) Stop()

package main

import (
	"fmt"
	"time"
)

func main() {
	t := time.NewTicker(5 * time.Second) //创建定时器
	defer t.Stop()
    
	go sync(t)
	select {

	}
}

func sync(t *time.Ticker) {
	for {
		// 每5秒中从chan t.C 中读取一次
		<-t.C
		fmt.Println("执行数据备份任务:", time.Now().Format("2006-01-02 15:04:05"))
	}
}