Quartz.Net任务调度问题：前序任务未完成时跳过后续任务

要实现任务每5秒触发，当前任务执行耗时超过5秒时跳过下一次触发，完成后按原计划执行后续任务的需求，不能用传统的lock阻塞线程（会导致后续任务排队而非跳过），需要用线程安全的异步互斥或原子操作来控制执行状态。

方案1：使用SemaphoreSlim（推荐，异步友好） #

利用SemaphoreSlim实现非阻塞的互斥检测，确保同一时间只有一个任务实例在运行，新触发的任务如果检测到已有任务在执行则直接跳过。

public class LoggerJob : IJob
{
    private readonly ILogger<LoggerJob> _logger;
    // 静态信号量：所有Job实例共享同一执行状态，确保全局互斥
    private static readonly SemaphoreSlim _executionLock = new SemaphoreSlim(1, 1);

    public LoggerJob(ILogger<LoggerJob> logger)
    {
        _logger = logger;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        // 尝试立即获取信号量（超时时间0），获取失败说明已有任务在运行
        if (!await _executionLock.WaitAsync(0))
        {
            _logger.LogInformation($"任务跳过：{DateTime.Now}，已有实例在执行");
            return;
        }

        try
        {
            _logger.LogInformation($"任务启动：{DateTime.Now}，任务类型：{context.JobDetail.JobType}");
            // 模拟耗时业务逻辑（比如运行6秒，超过5秒触发间隔）
            await Task.Delay(6000);
            _logger.LogInformation($"任务完成：{DateTime.Now}");
        }
        finally
        {
            // 无论成功/失败，必须释放信号量，避免永久锁定
            _executionLock.Release();
        }
    }
}

方案2：使用Interlocked原子操作（轻量场景） #

通过Interlocked.CompareExchange实现线程安全的状态标记，适合简单的互斥场景。

public class LoggerJob : IJob
{
    private readonly ILogger<LoggerJob> _logger;
    // 静态volatile标记：确保多线程下状态可见性
    private static volatile bool _isTaskRunning;

    public LoggerJob(ILogger<LoggerJob> logger)
    {
        _logger = logger;
    }

    public async Task Execute(IJobExecutionContext context)
    {
        // 原子操作：尝试将_isTaskRunning设为true，若原状态为false则执行任务
        if (Interlocked.CompareExchange(ref _isTaskRunning, true, false) == true)
        {
            _logger.LogInformation($"任务跳过：{DateTime.Now}，已有实例在执行");
            return;
        }

        try
        {
            _logger.LogInformation($"任务启动：{DateTime.Now}，任务类型：{context.JobDetail.JobType}");
            await Task.Delay(6000); // 模拟耗时逻辑
            _logger.LogInformation($"任务完成：{DateTime.Now}");
        }
        finally
        {
            // 原子操作重置状态
            Interlocked.Exchange(ref _isTaskRunning, false);
        }
    }
}

调度配置注意事项 #

确保你的CreateTrigger方法正确配置为每5秒触发：

private ITrigger CreateTrigger(JobMetadata jobMetadata)
{
    return TriggerBuilder.Create()
        .WithIdentity(jobMetadata.JobId.ToString())
        .WithSimpleSchedule(schedule => schedule
            .WithIntervalInSeconds(5)
            .RepeatForever())
        .Build();
}

为什么之前的lock方案不可行？ #

1. 阻塞线程：lock是同步阻塞操作，新触发的任务会等待锁释放而非直接跳过，不符合“跳过下一次触发”的需求。
2. 状态无效：Quartz默认每次触发都会创建新的LoggerJob实例，实例级的_lock和_isRunning无法跨实例共享状态，根本无法检测到已有任务在运行。

效果说明 #

• 0秒：任务启动，运行6秒
• 5秒：新触发的任务检测到已有实例在运行，直接跳过
• 6秒：当前任务完成，状态重置
• 10秒：下一次触发正常执行任务

内容的提问来源于stack exchange，提问作者Олег