Ticker 周期漂移时如何改成按截止时间调度

如果你发现周期任务不是“每隔 10 秒触发”，而是“上一次处理结束后又等 10 秒”，问题通常不在时间精度，而在调度模型。time.Ticker 提供的是周期节拍；当接收方处理较慢时，tick 可能被调整或丢弃，它并不负责把每个业务截止点补回来。

需要贴近固定时间表时，把 Ticker 改成一次性的 time.Timer：保存下一次绝对截止时间 nextDeadline，每轮只等待“现在距离截止点还有多久”，处理完成后再把截止时间向前推进。这样任务偶尔变慢，只会跳过已经过期的历史点，不会把漂移传给后面的每一轮。

本文要解决：一个周期任务耗时不稳定时，怎样从相对周期改为按截止时间调度。

适合：维护 Go worker、批处理、心跳或定期刷新任务，并且能接受“错过的截止点不补跑”的场景。

先看懂 Ticker 为什么会出现周期漂移

NewTicker(period) 会返回一个带有 C 通道的 Ticker。代码从这个通道取到节拍后开始处理；如果处理时间、锁等待或调度暂停超过一个周期，接收端看到的完成时间自然会向后移动。官方文档还说明，Ticker 会为了慢接收方调整间隔或丢弃 tick，所以不能把 ticker.C 当成“每个业务截止点都排队”的任务队列。

先明确取舍：如果任务必须尽量处理每个周期，应该另外设计持久队列或补偿策略；如果目标是“始终追赶当前时间表”，就不要在完成时间上再次加一个周期。

用 Timer 保存下一次截止时间

核心变量不是“上次何时完成”，而是“下一次应该何时开始”。下面的示例把周期设置为 10 秒，第一次截止点从当前时间开始计算。

package main

import (
	"context"
	"fmt"
	"time"
)

func run(ctx context.Context, period time.Duration) {
	// nextDeadline 是业务时间表，不随任务实际完成时间漂移。
	nextDeadline := time.Now().Add(period)
	timer := time.NewTimer(time.Until(nextDeadline))
	defer timer.Stop() // 退出时释放本轮等待，Timer 通道不需要手动关闭。

	for {
		select {
		case 

这个循环的关键是 nextDeadline = nextDeadline.Add(period)。它从既定时间表继续向前走，而不是写成 nextDeadline = time.Now().Add(period)。后者会把本轮耗时重新计入周期，重新制造“完成后再等一周期”的漂移。

运行检查：慢任务时选择跳过还是补跑

假设周期是 10 秒，而一次任务执行了 24 秒。任务结束时，原定的下一个和再下一个截止点都已过去。for !nextDeadline.After(now) 会把它们跳过，最终只等待仍在未来的截止点。这样可以避免任务刚结束就连续补跑多次，把系统拖进追赶循环。

如果业务不能跳过每个截止点，就不要简单改成补跑循环。可以把“应触发时间”写入显式队列，并为队列设置容量、过期策略和幂等键；那是可靠投递问题，不是 Ticker 或 Timer 的默认职责。

还要注意 time.Until(nextDeadline) 可能因为时钟推进而得到非正值。上面的循环已经把落后的 deadline 推到未来，因此传入 Timer 的时长保持为正数。NewTimer 和 Reset 的使用仍应集中在拥有该计时器的单个 goroutine 中，避免多个执行者同时改写计时状态。

按截止时间调度时的三个边界

• 取消：用 context.Context 退出循环，退出路径调用 timer.Stop()；不要依赖关闭 timer.C。
• 重置：示例是在收到 timer.C 后重置，因此没有未接收的当前通知。若在其他分支提前重置，需按项目支持的 Go 版本采用相应的 Stop 与排空策略；Go 1.23 起 Timer channel 的同步语义消除了旧值残留问题。
• 时钟语义：time.Time 的计算适合进程内相对调度；如果需要跨机器一致的日历时间、故障恢复或持久化，应该把截止点与任务状态交给外部调度系统。

小结：周期节拍用 Ticker，固定时间表用 Timer；绝对截止点放在 nextDeadline，任务完成后只推进时间表，并明确落后任务是否跳过。这样改动很小，却能把“按完成时间漂移”变成“按截止时间追赶”。

常见追问

Ticker.Reset 能不能直接解决周期漂移？

不能。Reset 只改变下一次 Ticker 周期；如果每轮都在任务完成后 Reset，仍然是相对完成时间调度。要保持固定时间表，必须单独保存并推进绝对截止时间。

任务落后时一定要补跑吗？

不一定。刷新、采样、心跳通常更关心最新状态，可以跳过过期点；账务、结算或消息消费则可能要求显式队列、幂等和重试，不能用简单的 Timer 循环代替。