如何避免GoCron中任务超时导致的堆积执行问题？

问题分析 #

你启用的SingletonModeAll()仅能保证同一时间不会有多个任务实例并行执行，但它会将任务运行期间错过的调度请求加入等待队列，等当前任务结束后连续执行这些堆积的任务，这就是问题的根源。

gocron原生解决方案 #

使用SkipIfStillRunning()选项替代或结合全局的SingletonModeAll()，让调度器直接跳过任务运行期间的所有调度触发，不会堆积任务：

单任务配置 #

修改任务定义，添加SkipIfStillRunning()：

func newScheduler(loc *time.Location) {
    e := gocron.NewScheduler(loc)

    e.Every("2m").SkipIfStillRunning().Do(func() {
        Logger.Warn("Task Started at: " + time.Now().Format("2006-01-02 15:04:05"))
        err := tasks.MyTask()
        if err != nil {
            Logger.Error("Error occurred during task execution: ", err)
        }
        Logger.Warn("Task Completed at: " + time.Now().Format("2006-01-02 15:04:05"))
    })

    e.StartAsync()
    select {}
}

全局默认配置 #

如果需要所有任务都应用这个规则，可以设置全局默认任务选项：

func newScheduler(loc *time.Location) {
    e := gocron.NewScheduler(loc).SetDefaultTaskOptions(gocron.WithSkipIfStillRunning())

    e.Every("2m").Do(func() {
        // 任务逻辑
    })

    e.StartAsync()
    select {}
}

该配置的效果是：当任务仍在运行时，调度器会跳过当前的调度触发，不会将任务加入等待队列。长任务结束后，只会在下一个2分钟的时间点执行任务，不会补跑期间错过的次数。

自定义替代方案 #

如果需要更灵活的控制逻辑，可以直接用Go标准库的ticker和通道实现调度，完全避免任务堆积：

func newScheduler(loc *time.Location) {
    // 设置带时区的ticker
    ticker := time.NewTicker(2 * time.Minute)
    defer ticker.Stop()

    // 用缓冲通道控制任务并发，确保同一时间仅一个实例运行
    runPermit := make(chan struct{}, 1)
    runPermit <- struct{}{} // 初始化允许执行一次

    go func() {
        for range ticker.C {
            select {
            case <-runPermit:
                go func() {
                    Logger.Warn("Task Started at: " + time.Now().Format("2006-01-02 15:04:05"))
                    err := tasks.MyTask()
                    if err != nil {
                        Logger.Error("Error occurred during task execution: ", err)
                    }
                    Logger.Warn("Task Completed at: " + time.Now().Format("2006-01-02 15:04:05"))
                    // 任务完成后释放许可，允许下一次执行
                    runPermit <- struct{}{}
                }()
            default:
                // 任务仍在运行，跳过本次调度
                Logger.Info("Task is still running, skip this tick")
            }
        }
    }()

    select {}
}

这个方案的核心是用带缓冲的通道作为执行许可，每次ticker触发时只有在许可可用时才启动任务，否则直接跳过，从根本上杜绝任务堆积。

内容的提问来源于stack exchange，提问作者Yash Chauhan