用Ticker+队列实现轻量级调度:以time.Ticker驱动定时检查,每个任务维护nextRun时间,避免sleep漂移,专注定时触发与执行,不涉持久化或分布式。

核心思路:用Ticker+队列实现轻量级调度
Go 本身没有内置的任务调度器,但标准库的 time.Ticker 和并发原语(goroutine、channel、sync.Mutex)足以支撑一个简单可靠的调度系统。关键不是“轮子造得多全”,而是明确边界:只管**定时触发**和**任务执行**,不负责持久化、分布式、失败重试等高级功能——那些留给专门的系统(如 Quartz、Temporal)。
时间精度与触发逻辑:别依赖 Sleep,用 Ticker 驱动
避免用 time.Sleep() 做间隔控制,它无法应对任务执行耗时导致的漂移。正确做法是用 time.Ticker 按固定周期“滴答”,每次滴答检查当前时间是否匹配待执行任务的下一次计划时间。
- 维护一个任务列表,每个任务含
nextRun time.Time字段 - Ticker 每秒(或更细粒度,如 100ms)触发一次检查
- now.After(task.nextRun),则执行,并更新
nextRun(如 cron 表达式解析后计算下次时间) - 执行任务建议起新 goroutine,防止阻塞调度主循环
支持 Cron 表达式:用第三方库快速落地
自己解析 cron(如 * * * * *)容易出错且覆盖不全。推荐直接使用成熟小而美的库:robfig/cron/v3 或更轻量的 khorevaa/cron。
-
robfig/cron/v3支持秒级、时区、Job 接口,API 清晰 - 示例:创建 cron 实例,调用
c.AddFunc("0 */2 * * *", func(){...})即可注册每两小时执行的任务 - 如需自定义 Job 类型(比如带 context、超时控制),实现
cron.Job接口即可
内存任务管理:用 map + sync.RWMutex 安全增删查
所有任务存在内存中,用 map[string]*Task 管理,key 是唯一任务 ID。读多写少场景下,sync.RWMutex 比普通 mutex 更高效。
立即学习“go语言免费学习笔记(深入)”;
- 添加任务:加写锁,存入 map,更新 nextRun
- 执行时:读锁遍历,只读取字段;实际执行前再加写锁更新状态/时间(如设置 running = true)
- 删除任务:加写锁,从 map 删除,并通知正在运行的任务 graceful shutdown(如有)
- 避免在执行函数里直接操作任务 map,防止死锁或并发读写 panic
基本上就这些。不复杂但容易忽略的是时间漂移处理和并发安全——把 Ticker 当节拍器,把任务当数据结构来管,Golang 的调度系统就立住了。










