
本文详解如何正确使用 robfig/cron 在 go 程序中实现长期运行的定时方法调用,解决因主 goroutine 过早退出导致任务不执行的问题,并提供可立即运行的完整示例。
在 Go 中使用 robfig/cron(现维护版本为 github.com/robfig/cron/v3)实现定时任务时,一个常见误区是:调用 c.Start() 后未保持主 goroutine 活跃,导致程序立即退出,定时器根本来不及触发。你的原始代码正是如此——c.Start() 启动了调度器,但 main() 函数随即结束,整个进程终止。
此外,原 cron 表达式 "1 * * * * *" 表示「秒字段为 1 时执行」(即每分钟第 1 秒),而非「每秒执行」;若需每秒触发,请使用 "* * * * * *"(6 字段格式,对应 秒 分 时 日 月 周)。
以下是修正后的完整、健壮的实现:
package main
import (
"fmt"
"os"
"os/signal"
"syscall"
"time"
"github.com/robfig/cron/v3"
)
func main() {
// 创建 cron 调度器(v3 版本推荐使用 cron.New() 或 cron.New(cron.WithSeconds()))
c := cron.New(cron.WithSeconds())
// 添加每秒执行的任务(6 字段:* * * * * *)
_, err := c.AddFunc("* * * * * *", RunEverySecond)
if err != nil {
panic(err)
}
// 启动调度器(非阻塞,需在后台运行)
c.Start()
defer c.Stop() // 确保优雅关闭
fmt.Println("Cron job started. Press Ctrl+C to exit.")
// 阻塞主 goroutine,等待系统中断信号(如 Ctrl+C)
sigChan := make(chan os.Signal, 1)
signal.Notify(sigChan, syscall.SIGINT, syscall.SIGTERM)
<-sigChan // 阻塞直至收到信号
fmt.Println("Shutting down...")
}
func RunEverySecond() {
fmt.Printf("[%s] Task executed\n", time.Now().Format("15:04:05"))
}✅ 关键要点说明:
- ✅ 必须显式阻塞 main():使用 signal.Notify 监听 SIGINT(Ctrl+C)或 SIGTERM,避免进程闪退;
- ✅ 正确使用 cron v3 的秒级支持:通过 cron.WithSeconds() 启用 6 字段语法,"* * * * * *" 表示每秒执行;
- ✅ 调用 c.Start() 后无需 go 关键字:v3 的 Start() 本身已启动 goroutine,手动 go c.Start() 是冗余且易引发竞态;
- ✅ 务必调用 c.Stop():在退出前清理资源(如关闭内部 ticker),避免 goroutine 泄漏;
- ⚠️ 注意:旧版 github.com/robfig/cron(v2)默认不支持秒级,需升级至 v3 并启用 WithSeconds() 选项。
运行该程序后,你将看到每秒打印一条带时间戳的日志,直到手动中断(Ctrl+C)。此模式适用于后台服务、健康检查、定时同步等长期运行场景。










