Quartz: предотвращение одновременных экземпляров задания в jobs.xml

Ответ 1

когда ваше задание Quartz просыпается, вы можете сделать:

JobDetail existingJobDetail = sched.getJobDetail(jobName, jobGroup);
    if (existingJobDetail != null) {
        List<JobExecutionContext> currentlyExecutingJobs = (List<JobExecutionContext>) sched.getCurrentlyExecutingJobs();
        for (JobExecutionContext jec : currentlyExecutingJobs) {
            if(existingJobDetail.equals(jec.getJobDetail())) {
                //String message = jobName + " is already running.";
                //log.info(message);
                //throw new JobExecutionException(message,false);
            }
        }
        //sched.deleteJob(jobName, jobGroup); if you want to delete the scheduled but not-currently-running job
    }

Ответ 2

Существует еще одно более простое решение. Задание может быть предоставлено аннотацией DisallowConcurrentExecution, которая предотвращает запуск нескольких параллельных экземпляров. См. Docs здесь.

Связь продолжает ломаться, поэтому вот соответствующий образец.

@DisallowConcurrentExecution
public class ColorJob implements Job {

Ответ 3

dimitrisli ответ не является полным, поэтому здесь.

Когда Quartz Job просыпается, он возвращает вам JobExecutionContext. Я предполагаю, что вы хотите пропустить задания с одним и тем же триггером.

  List<JobExecutionContext> jobs = jobExecutionContext.getScheduler().getCurrentlyExecutingJobs();
            for (JobExecutionContext job : jobs) {
                if (job.getTrigger().equals(jobExecutionContext.getTrigger()) && !job.getJobInstance().equals(this)) {
                    logger.info("There another instance running, so leaving" + this);
                    return;
                }

            }

В настоящее время мы получаем контексты работы и проверяем, есть ли предыдущий экземпляр задания с тем же триггером. Если это так, мы просто пропустим возврат.

Ответ 4

Я выполнил что-то подобное, чтобы мои классы работы реализовали StatefulJob, что гарантирует, что другие задания не начнутся до окончания текущего текущего задания.

Надеюсь, что помогает;)

PD: я реализовал его с помощью JBoss... но я не думаю, что это имеет значение.

Ответ 5

Можете ли вы установить задание как StatefulJob, и для каждого создаваемого вами триггера задайте, чтобы MisfireInstruction для задания не срабатывал, если он был пропущен? Не уверен, какой тип работы вы используете, но вам нужно будет провести некоторое исследование пропусков пропускания, которые доступны для вашего типа триггера.

Спасибо, D

Ответ 6

Незначительное изменение к решению скарамуша.

List<JobExecutionContext> jobs = jobExecutionContext.getScheduler().getCurrentlyExecutingJobs();
for (JobExecutionContext job : jobs) {
    if (job.getTrigger().equals(jobExecutionContext.getTrigger()) && !job.getFireInstanceId().equals(jobExecutionContext.getFireInstanceId()) {
        logger.info("There another instance running, so leaving" + this);
        return;
    }

}

Решение scaramouche терпит неудачу, когда есть один экземпляр, используемый для всех JobExecutions (возврат Singleton с использованием собственного класса JobFactory, а не вызов newInstance() для каждого выполнения)

Ответ 7

Если вы используете org.springframework.scheduling.quartz.QuartzJobBean:

protected void executeInternal(JobExecutionContext context) throws JobExecutionException {
    try {
        Scheduler scheduler = context.getScheduler();
        List<JobExecutionContext> jobs = scheduler.getCurrentlyExecutingJobs();
        for (JobExecutionContext job : jobs) {
            if (job.getTrigger().equals(context.getTrigger()) && job.getJobDetail() != context.getJobDetail()) {
                LOG.warn("Ignored!");
                return;
            }
        }
        ...
    } catch (SchedulerException e) {
        LOG.error("What a luck! :'(", e);
    }
    ...
}