如何用System.Cron.Schedule避免长时任务重复执行？

嘿，这个场景太常见了！当你的定时任务周期比任务本身运行时间短的时候，很容易出现多个备份实例同时跑的情况。针对你的Haskell代码，我给你几个实用的解决方案：

方法一：用MVar做内存互斥锁（单进程首选） #

Haskell标准库的MVar是线程安全的同步原语，刚好可以用来做任务的“运行标记”——同一时间只有一个线程能拿到锁，其他线程会阻塞直到锁被释放。修改你的代码如下：

import Control.Concurrent.MVar
import System.Cron.Schedule
import Control.Concurrent (threadDelay)

main :: IO ()
main = do
  -- 创建一个MVar作为互斥锁，用()作为占位值表示锁可用
  runLock <- newMVar ()
  tids <- execSchedule $ do
    -- 把锁传给备份任务
    addJob (doBackup runLock) "* * * * *"
  print tids

doBackup :: MVar () -> IO ()
doBackup lock = do
  -- 尝试获取锁：如果锁被占用，这里会阻塞直到前一次任务释放
  takeMVar lock
  putStrLn "Backing up system..."
  threadDelay 70000000  -- 模拟你的长时备份任务
  putStrLn "Backup finished"
  -- 任务完成后释放锁，让下一次定时触发的任务可以执行
  putMVar lock ()

这个方法的好处是完全用标准库实现，不需要额外依赖，而且逻辑简单清晰——如果前一次备份还在跑，下一次触发的任务会自动等待，直到上一次完成再执行。

方法二：用文件锁（跨进程场景适用） #

如果你的备份守护进程可能被重启，或者担心有其他进程也会触发备份，用文件锁会更稳妥。可以用filelock这个第三方库来实现，它会自动处理锁的获取和释放：

首先在你的cabal文件里添加filelock依赖，然后修改代码：

import System.Cron.Schedule
import Control.Concurrent (threadDelay)
import System.FileLock (withFileLock, LockMode(ExclusiveLock))

main :: IO ()
main = do
  tids <- execSchedule $ do
    addJob doBackup "* * * * *"
  print tids

doBackup :: IO ()
doBackup = do
  -- 选一个固定的锁文件路径，比如/tmp/backup-daemon.lock
  let lockPath = "/tmp/backup-daemon.lock"
  -- 尝试获取排他锁：如果锁已被持有，直接跳过本次任务（不会阻塞）
  withFileLock lockPath ExclusiveLock $ \_ -> do
    putStrLn "Backing up system..."
    threadDelay 70000000
    putStrLn "Backup finished"

这种方式的特点是，当备份任务正在运行时，新触发的任务会直接跳过，而不是等待。如果你的需求是“到点了但备份还没做完就跳过这次”，这个方法比MVar更合适。

方法三：抛弃固定调度，改用任务完成后再调度 #

如果不需要严格按照cron的“每分钟整分触发”，而是只要两次备份之间间隔一分钟，那可以完全不用System.Cron.Schedule，改成任务完成后自动安排下一次执行：

import Control.Concurrent (threadDelay)
import Control.Concurrent.Async (async)
import Control.Monad (forever)

main :: IO ()
main = do
  -- 启动备份循环，用async让它在后台运行
  async backupLoop
  -- 让主线程保持运行（不然程序会直接退出）
  forever $ threadDelay 1000000

backupLoop :: IO ()
backupLoop = do
  putStrLn "Backing up system..."
  threadDelay 70000000  -- 执行备份任务
  putStrLn "Backup finished"
  -- 等待一分钟后，再启动下一次备份
  threadDelay 60000000
  backupLoop

这个方法从根源上避免了任务重叠的问题，因为只有上一次备份完全结束，才会开始倒计时准备下一次。适合对触发时间精度要求不高的场景。

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