golang定时器案例详解

for {
   t := heap.Top() // 最近的定时器
   sleepUntil(t.when)
   trigger(t) // 执行任务
   }

package main
import (
	"fmt"
	"time"
)
func main() {
	timer := time.NewTimer(2 * time.Second)
	fmt.Println("等待中...")
	<-timer.C // 阻塞，直到2秒后收到信号
	fmt.Println("2秒到了！")
}

<-time.After(3 * time.Second) fmt.Println("3秒到了！")

timer := time.NewTimer(3 * time.Second) <-timer.C

timer := time.NewTimer(5 * time.Second)
go func() {
	<-timer.C
	fmt.Println("定时任务执行")
}()
time.Sleep(2 * time.Second)
if timer.Stop() {
	fmt.Println("定时器被取消")
}

timer := time.NewTimer(2 * time.Second)
<-timer.C // 第一次触发
timer.Reset(1 * time.Second) // 重新开始计时
<-timer.C
fmt.Println("又过了1秒")

ticker := time.NewTicker(1 * time.Second)
defer ticker.Stop()
for t := range ticker.C {
	fmt.Println("时间到了：", t)
}

ticker.Stop()

package main
import (
	"fmt"
	"time"
)
func main() {
	// 闹钟,自动重试任务
	// NewTimer 创建一个 Timer，它会在最少过去时间段 d 后到期，向其自身的 C 字段发送当时的时间
	timer1 := time.NewTimer(5 * time.Second)
	fmt.Println("开始时间：", time.Now().Format("2006-01-02 15:04:05"))
	go func(t *time.Timer) {
		times := 0
		for {
			<-t.C
			fmt.Println("timer", time.Now().Format("2006-01-02 15:04:05"))
			// 从t.C中获取数据，此时time.Timer定时器结束。如果想再次调用定时器，只能通过调用 Reset() 函数来执行
			// Reset 使 t 重新开始计时，（本方法返回后再）等待时间段 d 过去后到期。
			// 如果调用时 t 还在等待中会返回真；如果 t已经到期或者被停止了会返回假。
			times++
			// 调用 reset 重发数据到chan C
			fmt.Println("调用 reset 重新设置一次timer定时器，并将时间修改为2秒")
			t.Reset(2 * time.Second)
			if times > 3 {
				fmt.Println("调用 stop 停止定时器")
				t.Stop()
			}
		}
	}(timer1)
	time.Sleep(30 * time.Second)
	fmt.Println("结束时间：", time.Now().Format("2006-01-02 15:04:05"))
	fmt.Println("ok")
}

package main
import (
	"fmt"
	"time"
)
func main() {
	ticker := time.NewTicker(2 * time.Second)
	defer ticker.Stop() // 函数结束时关闭 ticker
	done := make(chan bool)
	// 模拟外部协程：10秒后关闭心跳
	go func() {
		time.Sleep(10 * time.Second)
		done <- true
	}()
	for {
		select {
		case t := <-ticker.C:
			fmt.Println("发送心跳包：", t)
		case <-done:
			fmt.Println("停止发送心跳包")
			return
		}
	}
}