Quartz.NET如何避免同JobKey任务并行执行（复用Job类）

看起来你已经把多表迁移的任务调度框架搭起来了，核心问题是要让同一张表的迁移任务不会并行执行，但不同表的任务可以同时跑，而且不想为每张表写单独的Job类——这个需求其实Quartz本身就有很贴合的解决方案，不用额外写复杂的锁逻辑。

方案一：利用DisallowConcurrentExecution特性（推荐） #

你可能之前误解了DisallowConcurrentExecution的作用，它并不是限制整个Job类的所有任务都不能并行，而是限制同一个JobDetail的多次执行不能并行。

你现在的代码里，每张表都创建了一个独立的JobDetail（通过不同的JobKey区分），所以只需要给你的TransferData类加上这个特性，就能完美实现需求：

[DisallowConcurrentExecution]
public class TransferData : IJob {
    public Task Execute(IJobExecutionContext context){
        string tableName = context.JobDetail.JobDataMap.Get("table");
        // 执行表数据迁移操作
        return Task.CompletedTask;
    }
}

原理说明： #

• 当某个表的迁移任务正在执行时，Quartz会检测到这个JobDetail（对应该表的JobKey）已有未完成的执行实例，就会自动跳过本次触发（或根据触发器配置重试，默认是跳过）。
• 不同表的JobDetail是完全独立的，所以它们的迁移任务可以并行执行，不会互相阻塞。

这个方案是Quartz官方推荐的，代码改动最小，不需要自己维护锁逻辑，可靠性也更高。

方案二：自定义锁机制（适合特殊场景） #

如果因为某些原因你不想使用DisallowConcurrentExecution特性（比如需要更灵活的控制逻辑，比如自定义超时处理、跳过策略），可以自己实现基于表名的锁机制：

单机场景（内存锁） #

用静态的ConcurrentDictionary维护正在执行的表锁，保证同一时间只有一个线程处理某张表：

public class TransferData : IJob {
    // 静态锁容器，key为表名，value为锁对象
    private static readonly ConcurrentDictionary<string, object> _tableLocks = new ConcurrentDictionary<string, object>();

    public async Task Execute(IJobExecutionContext context){
        string tableName = context.JobDetail.JobDataMap.Get("table").ToString();
        
        // 尝试获取锁，获取不到直接返回（表示上一次任务还在执行）
        if (!_tableLocks.TryAdd(tableName, new object()))
        {
            Console.WriteLine($"表{tableName}的迁移任务正在执行，本次触发跳过");
            return;
        }

        try
        {
            // 执行表数据迁移操作
            Console.WriteLine($"开始迁移表{tableName}");
            // 模拟迁移耗时
            await Task.Delay(TimeSpan.FromMinutes(6));
        }
        finally
        {
            // 无论执行成功还是失败，都要释放锁
            _tableLocks.TryRemove(tableName, out _);
        }
    }
}

集群场景（分布式锁） #

如果你的Quartz是集群部署的，内存锁就不起作用了，需要用分布式锁（比如Redis锁）：

public class TransferData : IJob {
    private readonly IDistributedLock _distributedLock; // 假设你有封装好的分布式锁实现

    // 通过依赖注入注入分布式锁实例
    public TransferData(IDistributedLock distributedLock){
        _distributedLock = distributedLock;
    }

    public async Task Execute(IJobExecutionContext context){
        string tableName = context.JobDetail.JobDataMap.Get("table").ToString();
        string lockKey = $"transfer_task_lock:{tableName}";
        
        // 尝试获取锁，超时时间设置为略大于任务预期执行时间
        using (var lockHandle = await _distributedLock.TryAcquireAsync(lockKey, TimeSpan.FromMinutes(10), TimeSpan.FromSeconds(1)))
        {
            if (lockHandle == null)
            {
                Console.WriteLine($"表{tableName}的迁移任务正在执行，本次触发跳过");
                return;
            }

            // 执行表数据迁移操作
            Console.WriteLine($"开始迁移表{tableName}");
            await Task.Delay(TimeSpan.FromMinutes(6));
        }
        // using块结束后自动释放锁
    }
}

注意事项 #

• 方案一中，一定要确保每张表对应的JobDetail是唯一的（你现在的代码已经通过JobKey(table.Name, "table_transfer")实现了，这点没问题）。
• 如果使用自定义锁，必须确保锁能被正确释放（比如在finally块或using块中处理），避免出现死锁导致后续任务无法执行。

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