Go Cron 怎样用 SkipIfStillRunning 跳过重叠任务

如果一个 Go Cron 任务每 10 秒触发一次，但单次处理需要 30 秒，直接注册函数会让同一进程里出现重叠运行。robfig/cron/v3 可以用 SkipIfStillRunning 包装任务：前一次还没结束时，新的触发会被跳过，而不是继续并发执行。这个策略适合“本轮没赶上可以丢弃”的刷新、巡检和同步任务。

官方地址：https://pkg.go.dev/github.com/robfig/cron/v3

最简单的统一配置是 cron.New(cron.WithChain(cron.SkipIfStillRunning(logger)))。它只约束当前 Cron 实例所在进程；如果任务不能丢弃，应改用 DelayIfStillRunning 或在业务层设计持久化队列。

先把跳过、等待和并发范围分开

cron v3 会在自己的 goroutine 中调用注册的函数，所以调度间隔小于任务耗时时，默认行为可能是并发执行。SkipIfStillRunning 的语义是“已有一次运行就放弃这次触发”，它不是加锁后排队，也不会把被跳过的任务补回来。

若每次触发都必须处理，可以考虑 DelayIfStillRunning，它会等前一次结束后再进入任务。若服务部署了多个副本，进程内包装器无法阻止不同副本同时执行，仍需要数据库租约、分布式锁或持久化任务系统。

用 WithChain 统一跳过重叠运行

所有任务都采用同一种策略时，把包装器放进 WithChain 最清楚。下面示例把每 10 秒执行一次的任务设为跳过模式；任务内部故意等待较长时间，只用来说明重叠边界。

package main

import (
    "log"
    "time"

    "github.com/robfig/cron/v3"
)

func main() {
    logger := cron.PrintfLogger(log.New(log.Writer(), "cron: ", log.LstdFlags))

    // 给这个 Cron 实例中的所有任务统一加上“运行中就跳过”的包装器。
    scheduler := cron.New(cron.WithChain(
        cron.SkipIfStillRunning(logger),
    ))

    _, err := scheduler.AddFunc("@every 10s", func() {
        // 模拟一次超过调度间隔的同步工作；真实任务应在这里处理错误并记录结果。
        time.Sleep(30 * time.Second)
        log.Println("同步任务完成")
    })
    if err != nil {
        // 表达式解析失败时不要启动调度器，先把配置错误暴露出来。
        log.Fatal(err)
    }

    scheduler.Start()
    defer scheduler.Stop()
    select {} // 示例保持进程运行，生产服务应交给生命周期管理。
}

这里的关键不是等待 30 秒，而是包装器记录了任务是否仍在运行。第一个触发进入任务后，后续触发在这段时间内直接被跳过；日志适合用来观察“为什么某次没有执行”，但不能把跳过当作失败重试机制。

只给一个任务加 JobWrapper

生产服务经常同时存在两类任务：缓存刷新可以跳过，账单汇总却不能漏掉。此时不要把全局 Chain 当成默认答案，而是对需要限制的任务单独包装。

package main

import (
    "log"

    "github.com/robfig/cron/v3"
)

func main() {
    logger := cron.PrintfLogger(log.Default())
    scheduler := cron.New()

    // 只有刷新任务使用跳过策略，避免影响同一调度器中的其他任务。
    refresh := cron.NewChain(
        cron.SkipIfStillRunning(logger),
    ).Then(cron.FuncJob(func() {
        // 这里放可丢弃本轮触发的工作，不要把关键消息只留在内存中。
        log.Println("刷新缓存")
    }))

    if _, err := scheduler.AddJob("@every 1m", refresh); err != nil {
        // AddJob 失败时保留原始错误，便于定位表达式或任务配置问题。
        log.Fatal(err)
    }
    scheduler.Start()
    defer scheduler.Stop()
}

NewChain(...).Then(job) 返回的是被包装后的 Job，再交给 AddJob 即可。这样可以把任务的并发策略写在任务注册位置，后续维护时不需要回头猜全局配置影响了哪些工作。

上线前检查三个边界

第一，确认“跳过”是业务允许的结果：它不会积压、补偿或重放被忽略的触发。第二，检查日志配置，SkipIfStillRunning 接收 Logger，应该让跳过事件能被检索，而不是静默丢失。第三，确认部署副本数；多个进程各自拥有一套 Cron 状态，单进程 JobWrapper 不是跨实例互斥方案。

还要注意 scheduler.Stop() 只停止后续调度，不会强行终止已经在运行的任务。服务退出时应给任务自己的上下文和收尾时间，避免把“防重叠”误解为“可安全中断”。

常见问题

SkipIfStillRunning 会把上一次任务排队吗？

不会。上一次仍运行时，新触发直接跳过；需要等待处理时应评估 DelayIfStillRunning 或持久化队列。

多个服务副本能共用这个防重叠策略吗？

不能。它只作用于同一个 Cron 实例的进程内状态，多副本场景要把互斥和幂等放到共享存储或任务系统中。