如何限制石英调度器中特定类并发执行的作业实例数？

Question

我有一个实现作业的类“Applier”。意思是类“Applier”是石英作业的实例之一。

我的要求是控制一次执行“Applier”的实例数。意味着我想限制最多5个“Applier”实例执行。如果“Applier”的第6个实例来了并且5个实例已经执行，那么它必须等到“Applier”的一个实例完成。

Quartz调度器中是否有等待/通知类型机制。意味着如果作业的第6个实例尝试运行，而5个实例已经执行，则第6个实例必须在5个实例中的任何一个执行完成后等待并通知。

这意味着我想为特定的作业实例实现一些线程池类型的机制。我不希望像mechanisum这样的线程池出现在Quartz调度器级别的b'Z，因为它已经由Quartz调度器提供了。

Answer 1

可以限制并发运行的作业数（线程池），也可以将给定的作业实例限制为仅一个并发实例。不能将给定的作业限制为仅给定数量的实例（1个除外）。唯一的方法是只为给定的调度程序运行一种作业，然后将线程池限制为在同一时间段运行的作业数

Answer 2

我不确定你是否意识到这一点，但所有的工作都是jobkey独有的。

让我们从这个答案的约定开始

工作——这意味着一份石英的工作

工作——石英工作班

正如我之前提到的，JOB只能有一个实例。这是如何发生的，每个JOB都由一个工作键定义，现在工作键总是唯一的

这意味着通常您在JOB和作业之间有一对一的映射，即计划作业（QuartZ作业和实现接口作业的类

哪一项是工作-

案例1

作业的多个实例而不是JOBs的多个实例

看起来像

工作A-

工作B-

工作C-

只需在同一个jobgroup中保留不同的jobkey，就可以将多个Job实例加载到调度程序中

看看JobFactory，因为

JobFactory负责生成作业类的实例。

..

案例2

现在来看看JOB的实例。根据您的日程安排和JOB的执行时间，可以有多个实例并行运行（将其称为多个实例是不恰当的，更好的术语是并发执行）。为了避免这种情况，您将不得不编写一些自定义逻辑。或者使用注释DislowConrontExecution。

加载5个作业实例，如案例1所示，其中不允许OnCurrentExecution。但这将意味着5个不必要的例子，即使有时可能不需要这份工作。

案例3

现在让我们考虑设置一个初始化为1的标志。可能有助于处理此问题的自定义逻辑

在你开始工作之前。您可以检查标志是否小于5。如果小于5，则进入主业务逻辑并增加标志的值。执行结束后，在退出程序段之前，将其减量。这样，即使有多个作业实例在运行，也不会执行业务逻辑。

    private static int jobRunningFlag = 0;

    @Override
html" target="_blank">public void execute(JobExecutionContext context) throws JobExecutionException {
    if(JobName.jobRunningFlag <= 5)
        {
            JobName.jobRunningFlag++
    .....execute this piece of code....
            JobName.jobRunningFlag--
    }
}

显然jobRunningFlag将是一个静态变量，存储在同一个Jobs类中

PS：更多的答案将基于你的评论。你看过JobFactory和相关的类/接口了吗。你试过什么。我的想法是，这将完全取决于您的实现逻辑。我对石英不太在行，对它们也不太了解。