如何检查 Quartz cron 作业是否正在运行？

java cron quartz-scheduler job-scheduling scheduler

2022-09-03 06:13:01

如何检查计划的 Quartz cron 作业是否正在运行？是否有任何API来执行检查？

答案 1

scheduler.getCurrentlyExecutingJobs（）在大多数情况下应该有效。但请记住不要在 Job 类中使用它，因为它使用 ExecutingJobsManager（一个 JobListener）将正在运行的作业放到一个 HashMap 上，该作业在作业类之前运行，所以使用此方法检查作业是否正在运行肯定会返回 true。一种简单的方法是检查火灾时间是否不同：

public static boolean isJobRunning(JobExecutionContext ctx, String jobName, String groupName)
        throws SchedulerException {
    List<JobExecutionContext> currentJobs = ctx.getScheduler().getCurrentlyExecutingJobs();

    for (JobExecutionContext jobCtx : currentJobs) {
        String thisJobName = jobCtx.getJobDetail().getKey().getName();
        String thisGroupName = jobCtx.getJobDetail().getKey().getGroup();
        if (jobName.equalsIgnoreCase(thisJobName) && groupName.equalsIgnoreCase(thisGroupName)
                && !jobCtx.getFireTime().equals(ctx.getFireTime())) {
            return true;
        }
    }
    return false;
}

另请注意，此方法不具有群集感知能力。也就是说，它只会返回当前在此计划程序实例中执行的作业，而不会返回整个群集中执行的作业。如果在集群中运行 Quartz，它将无法正常工作。

答案 2

如果您注意到在QUARTZ_TRIGGERS表中，有一个TRIGGER_STATE列。这将告诉您特定作业的触发器（触发器状态）的状态。你的应用很可能没有指向此表的直接接口，但石英计划程序具有，你可以通过这种方式检查状态：

private Boolean isJobPaused(String jobName) throws SchedulerException {

    JobKey jobKey = new JobKey(jobName);
    JobDetail jobDetail = scheduler.getJobDetail(jobKey);
    List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobDetail.getKey());
    for (Trigger trigger : triggers) {
        TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
        if (TriggerState.PAUSED.equals(triggerState)) {
            return true;
        }
    }
    return false;
}