gocron启动后任务不执行,因默认仅注册不运行,须显式调用s.Start();含IO操作的任务应使用RunWithLock()防并发;HTTP动态管理需自建API层配合tag与map任务映射。
为什么
启动后任务不执行?
多数情况不是代码写错了,而是没调用
或漏了
逻辑。默认启动是“注册但不运行”状态,尤其在 Web 服务中常被误当成“自动执行”。
只初始化调度器,不启动后台 goroutine
必须显式调用
才真正开始 tick 和触发任务
若任务含数据库操作或 HTTP 调用,建议用
避免并发重入
注意:
是阻塞调用(内部启 goroutine 但会等待信号),若在
中直接调用后没加
,程序可能立即退出
如何用 HTTP API 动态增删 Cron 任务?
原生
不提供 REST 接口,得自己封装一层状态管理。核心难点不在调度,而在任务 ID 的可寻址性与生命周期同步。
用
存任务引用,key 为自定义 ID(如
),避免靠索引或匿名函数匹配
新增任务时,先
,再存到 map;删除时用
+ 清 map
GET
返回 map 的 key 列表即可,不用序列化整个
(它含未导出字段,JSON 会丢数据)
别用
模拟手动触发——它绕过调度逻辑,且不保证和定时执行环境一致(比如 context、超时控制)
和
关键区别在哪?
选错库会导致后期改不动:一个面向“长期后台作业”,一个偏向“类 Unix cron 表达式解析”,定位完全不同。
:基于时间间隔(
)、支持 tag/lock/limit 并发,适合服务内嵌轻量调度,但不支持
这种表达式
(现为
):专注 cron 表达式,支持时区、秒级精度、
别名,但无内置锁、无任务标签、重启后任务丢失(除非你自己持久化)
混合用法常见:用
解析表达式生成触发时间点,再交给
的单次任务(
)执行——但注意别高频创建 scheduler 实例
Web 服务里怎么防止调度器随 HTTP 请求重复初始化?
典型错误是在 handler 里每次 new scheduler,结果跑出 N 个独立调度器,内存涨、任务重复、日志刷屏。
立即学习
“
go语言免费学习笔记(深入)
”;
调度器必须是全局单例:
放包变量,init 或 main 里
别把
当参数传进 handler——handler 只负责读写任务 map、调
等方法
如果用 Gin/Echo,可在中间件里检查
,但不要在这里 start;启动时机只应在
最后、服务器 ListenAndServe 之前
热更新任务时,注意
是异步清理,新任务立即生效,但旧 goroutine 可能还在跑最后一轮——这是正常行为,不是 bug
真正麻烦的从来不是加一行
,而是当三个不同团队同时往这个调度器里塞任务,没人知道谁在什么时候停掉了谁的 job,也没人记得 lock 的 key 是不是拼错了。
gocronStart()RunWithLock()gocron.NewScheduler(time.UTC)s.Start()s.Every("5s").Do(func() { ... }).RunWithLock()Start()main()select{}gocronmap[string]*gocron.Job"sync_user_cache"s.Every("10m").Tag("sync_user_cache").Do(...)s.RemoveByTag("sync_user_cache")/api/jobsJobjob.Run()gocronrobfig/crongocronEvery("30s")0 2 * * *robfig/crongithub.com/robfig/cron/v3@dailyv3gocrons.After(time.Now().Add(5*time.Second)).Do(...)var sched = gocron.NewScheduler(time.UTC)sched.Start()schedulersched.AddJob()sched.IsRunning()main()RemoveByTags.Every("1h").Do(...)