跳到主要内容

Ticker 心跳

如何创建、消费并停止周期性 Ticker？​

  • time.NewTicker: 按固定时间间隔产生 tick;
  • ticker.C: 接收每次 tick 对应的 time.Time;
  • ticker.Stop: 停止 ticker 并释放资源;
package main

import "time"

func main() {
	ticker := time.NewTicker(time.Second)
	defer ticker.Stop()

	for i := 0; i < 2; i++ {
		t := <-ticker.C
		println(t.String())
	}
}

  • 停止含义: Stop 阻止后续 tick，但不会关闭 ticker.C，因此不能依靠遍历 channel 等待结束;

  • 处理速度: 接收方处理过慢时，ticker 会调整或丢弃 tick，不保证补发每一次间隔;

  • 周期前提: interval 必须大于零，否则 NewTicker 会 panic；循环退出条件独立于 Stop，示例通过计数退出;

  • API 依据: time.Ticker；周期任务需要保证不漏执行时，应单独记录任务状态，不能把每个 tick 当作可靠队列消息;