两个 Quartz-Worker 执行同一作业两次

Question

我们已经实现了quartz来进行调度。每个产生的作业都有不同的key。到目前为止一切正常。昨天我们遇到了一个问题，因为同一个作业被两个不同的 Quartz-Worker 线程执行了两次或三次（没有特殊行为）。 我们不能将线程池大小设为一，因为我们需要并发作业。

关于我们的计划作业，值得注意的一件事是，它会在每次运行时自行重新安排（每日、每周或每月），即如果一项作业计划每天运行，那么它将在接下来的 24 小时内重新安排自己，但会随机预定义（例如 3 小时）时间窗口。例如，如果某个作业今天在 4:10（即 4:00 到 7:00 之间）运行，那么我们的作业会将其自行重新安排到明天 4:00 到 7:00 之间的某个随机时间。它可以是 4:01 或 6:59 或 5:23 或给定时间窗口中的任何其他值。这个过程也运行良好，并且在大多数情况下仍然运行良好，但在某些情况下，我们的重新安排算法无法在接下来的 24 小时内自行安排。相反，它会在接下来的 10 秒、1 小时或任何其他随机值内自行安排。但在2-3次错误的重新安排之后，它最终稳定下来，即它最终在接下来的24小时内自行安排。我们怀疑发生这种情况的原因可能是多个线程访问 Calendar 对象（我们使用 Calendar.getInstance() 和 cal.add(Calendar.DAY_OF_YEAR, 1) 在接下来的 24 小时内重新安排作业）。不知何故，日历实例选择了错误的时间或无法在当前时间添加一天。

所以，有两个问题： 1. 多个Quartz线程获取同一个作业 2.日历无法添加给定间隔或在某些特定情况下选择错误的当前时间（多线程访问）

任何帮助将不胜感激。尽快回复。 谢谢。

---

感谢您的回复。 我想知道 Statefuljob 和 @DisallowConcurrentExecution 注释以及将 threadPool.threadCount 设置为 1 之间有什么区别。

重新调度的代码如下...

    Calendar cal = Calendar.getInstance();
    Calendar nextCal = Calendar.getInstance();
    cal.setTimeZone(TimeZone.getTimeZone(obj.getTimeZone()));
    nextCal.setTimeZone(TimeZone.getTimeZone(obj.getTimeZone()));
    Date startTime = null;
    SimpleTrigger trigger = null;

    JobDataMap dataMap = new JobDataMap();
     if (repeatTimeInMillis == null) {
        cal.set(Calendar.HOUR_OF_DAY, obj.getStartTime());
        nextCal.set(Calendar.HOUR_OF_DAY, obj.getStartTime());
        cal.set(Calendar.MINUTE, 0);
        nextCal.set(Calendar.MINUTE, 0);
        cal.set(Calendar.SECOND, 0);
        nextCal.set(Calendar.SECOND, 0);
        if (obj.getScheduleType() == ScheduleType.MONTHLY) { // Monthly
    log.info("in monthly schedule");                
            nextCal.add(Calendar.MONTH, 2);
            nextCal.set(Calendar.DAY_OF_MONTH, obj.getDate());
            cal.add(Calendar.MONTH, 1);
            cal.set(Calendar.DAY_OF_MONTH, obj.getDate());
        } else if (obj.getScheduleType() == ScheduleType.WEEKLY) { // Weekly
    log.info("in weekly schedule");                
            nextCal.add(Calendar.WEEK_OF_YEAR, 2);
            nextCal.set(Calendar.DAY_OF_WEEK, obj.getDay());
            cal.add(Calendar.WEEK_OF_YEAR, 1);
            cal.set(Calendar.DAY_OF_WEEK, obj.getDay());
        } else if (obj.getScheduleType() == ScheduleType.DAILY) { // Daily
    log.info("in daily schedule");                
    nextCal.add(Calendar.DAY_OF_YEAR, 2);
            cal.add(Calendar.DAY_OF_YEAR, 1);
        }

        long time = obj.getTimeWindow() * 60 * 60 * 1000;
        time = Math.round(time * Math.random());
        cal.setTimeInMillis(cal.getTimeInMillis() + time);
        startTime = cal.getTime();
        nextCal.setTimeInMillis(nextCal.getTimeInMillis() + time);
        repeatTimeInMillis = nextCal.getTimeInMillis() - cal.getTimeInMillis();

        log.info("Rescheduling job at " + startTime);
        trigger = newTrigger().usingJobData(dataMap)
                .withIdentity(obj.getScheduleJobName(), obj.getScheduleJobGroup()).startAt(startTime)
                .withSchedule(simpleSchedule().withIntervalInMilliseconds(repeatTimeInMillis).repeatForever())
                .build();
    } else {
        log.info("Rescheduling job next " + repeatTimeInMillis + " milliseconds.");
        cal.setTimeInMillis(cal.getTimeInMillis() + repeatTimeInMillis);
        startTime = cal.getTime();
        trigger = newTrigger().usingJobData(dataMap)
                .withIdentity(obj.getScheduleJobName(), obj.getScheduleJobGroup()).startAt(startTime)
                .withSchedule(simpleSchedule().withIntervalInMilliseconds(repeatTimeInMillis).withRepeatCount(1)).build();
    }

Answer 1

StatefulJob 接口和 @DisallowConcurrentExecution 注释执行相同的操作。

来自 DisallowConcurrentExecution javadoc：

将 Job 类标记为不得有多个实例
同时执行....

这可以用来代替实现 StatefulJob 标记
Quartz 2.0 之前使用的接口

将 threadPool.threadCount 属性设置为 1 意味着最多可以执行 1 个任何类型的作业

使用这些解决方案中的任何一个都将停止并发执行的作业并导致任何触发被放入队列中，以便在前一个触发器实例完成时执行