如何修复gocron停止后重启触发积压任务的问题

1. 调度器停止后未移除任务：调用sch.scheduler.Stop()只会终止调度器的运行循环，但不会删除已添加的定时任务。当再次启动调度器时，gocron会自动补执行停止期间所有错过的任务，导致批量打印积压日志。
2. 重复创建任务：每次调用启动API时，都会新建一个5秒执行的任务，多次启停后调度器中会存在多个相同任务，进一步加重任务积压问题。

提供两种可行的修改方案，按需选择：

方案一：停止时彻底移除任务，启动时重新创建 #

该方案在停止调度器后，主动移除已添加的任务，确保下次启动时从当前时间开始执行新任务，不会补做历史任务。

修改后的代码：

package handler

import (
    "fmt"
    "log"
    "net/http"
    "time"

    "github.com/gin-gonic/gin"
    "github.com/go-co-op/gocron"
    _ "github.com/jinzhu/gorm/dialects/postgres"
)

type Scheduler struct {
    scheduler *gocron.Scheduler
    job       *gocron.Job
}

func (sch *Scheduler) StartSchedulerJob(c *gin.Context) {
    if sch == nil {
        log.Println("Scheduler not initialized")
        c.String(http.StatusInternalServerError, "Scheduler not initialized")
        return
    }
    if !sch.scheduler.IsRunning() {
        // 每次启动前确保没有残留任务
        if sch.job != nil {
            sch.scheduler.Remove(sch.job)
            sch.job = nil
        }
        // 创建新任务并启动调度器
        sch.job, _ = sch.scheduler.Every(5).Second().Do(func() {
            fmt.Println("Running cron job...")
        })
        sch.scheduler.StartAsync()
        c.String(http.StatusOK, "Cron job started")
    } else {
        c.String(http.StatusOK, "Cron job is already running")
    }
}

func (sch *Scheduler) StopSchedulerJob(c *gin.Context) {
    if sch.scheduler.IsRunning() {
        sch.scheduler.Stop()
        // 移除任务并置空引用
        if sch.job != nil {
            sch.scheduler.Remove(sch.job)
            sch.job = nil
        }
        c.String(http.StatusOK, "Cron job stopped")
    } else {
        c.String(http.StatusOK, "No active cron job to stop")
    }
}

func InitializeScheduler() *Scheduler {
    sch := gocron.NewScheduler(time.Local)
    return &Scheduler{
        scheduler: sch,
    }
}

方案二：复用任务，使用暂停/恢复替代停止 #

该方案初始化时就创建好任务，通过暂停（Pause）和恢复（StartAsync）调度器来控制任务执行，避免任务重复创建和历史任务补执行。

修改后的代码：

package handler

import (
    "fmt"
    "log"
    "net/http"
    "time"

    "github.com/gin-gonic/gin"
    "github.com/go-co-op/gocron"
    _ "github.com/jinzhu/gorm/dialects/postgres"
)

type Scheduler struct {
    scheduler *gocron.Scheduler
    job       *gocron.Job
}

func (sch *Scheduler) StartSchedulerJob(c *gin.Context) {
    if sch == nil {
        log.Println("Scheduler not initialized")
        c.String(http.StatusInternalServerError, "Scheduler not initialized")
        return
    }
    if !sch.scheduler.IsRunning() {
        sch.scheduler.StartAsync()
        c.String(http.StatusOK, "Cron job resumed")
    } else {
        c.String(http.StatusOK, "Cron job is already running")
    }
}

func (sch *Scheduler) StopSchedulerJob(c *gin.Context) {
    if sch.scheduler.IsRunning() {
        sch.scheduler.Pause()
        c.String(http.StatusOK, "Cron job paused")
    } else {
        c.String(http.StatusOK, "No active cron job to pause")
    }
}

func InitializeScheduler() *Scheduler {
    sch := gocron.NewScheduler(time.Local)
    // 初始化时创建任务，添加SkipIfStillRunning避免任务重叠（可选）
    job, _ := sch.Every(5).Second().SkipIfStillRunning(gocron.SkipModeWait).Do(func() {
        fmt.Println("Running cron job...")
    })
    return &Scheduler{
        scheduler: sch,
        job: job,
    }
}

方案二补充说明 #

• 使用Pause()替代Stop()，调度器会暂停任务执行，但不会清除任务计划；恢复时会从当前时间开始计算下一次执行时间，不会补做暂停期间的任务。
• SkipIfStillRunning(gocron.SkipModeWait)是可选配置，用于防止任务执行时间超过5秒时，新的任务与旧任务重叠执行。

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