石英：跳过以相同的触发时间计划的重复作业触发

Question

html" target="_blank">public static class MyJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        System.out.println("My Job at " + DateUtils.toDateTimeString(context.getFireTime()) +  " by " +
                context.getTrigger().getKey().getName());
    }
}

startScheduler() {

    final Set<Trigger> triggers = new HashSet<Trigger>();
    triggers.add(TriggerBuilder.<CronScheduleBuilder>newTrigger().withIdentity("every 3 secs").
            withSchedule(CronScheduleBuilder.cronSchedule("0/3 * * * * ? *")).build());
    triggers.add(TriggerBuilder.<CronScheduleBuilder>newTrigger().withIdentity("every 2 secs").
            withSchedule(CronScheduleBuilder.cronSchedule("0/2 * * * * ? *")).build());

    final Scheduler scheduler = new StdSchedulerFactory(properties).getScheduler();
    scheduler.scheduleJob(JobBuilder.newJob(MyJob.class).build(), triggers, false);
    scheduler.start();

}

和日志：

• 我在01.11.2013T23:19:26.000的作业，每隔2秒
• 我在01.11.2013T23:19:27.000的作业，每3秒
• 我在01.11.2013T23:19:28.000的作业，每隔2秒
• 我的工作时间01.11.2013t23:19:0.000，每隔2秒
• 我在01.11.2013t23:19:30.001的作业，每3秒
• 我的作业在01.11.2013T23:19:32.000，每隔2秒
• 我在01.11.2013t23:19:33.000的作业，每3秒
• 我在01.11.2013T23:19:34.000的作业，每隔2秒
• 我在01.11.2013T23:19:36.000的作业，每隔2秒
• 我在01.11.2013t23:19:36.001的作业，每3秒
• 我在01.11.2013T23:19:38.000的作业，每隔2秒
• 我在01.11.2013T23:19:39.000的作业，每3秒
• 我在01.11.2013T23:19:40000的作业，每隔2秒
• 我在01.11.2013T23:19:42.001的作业，每隔2秒
• 我在01.11.2013t23:19:42.002的作业，每3秒

Answer 1

发现TriggerListener适合此任务：

scheduler.getListenerManager().addTriggerListener(new TriggerListener() {

    private Date lastFireTime = null;

    @Override
    public String getName() {
        return "prevent-duplicate-fires";
    }

    @Override
    public void triggerFired(Trigger trigger, JobExecutionContext context) {
    }

    @Override
    public boolean vetoJobExecution(Trigger trigger, JobExecutionContext context) {
        final Date fireTime = context.getScheduledFireTime();
        if (lastFireTime != null && fireTime.equals(lastFireTime)) {
            return true;
        }
        lastFireTime = fireTime;
        return false;
    }

    @Override
    public void triggerMisfired(Trigger trigger) {
    }

    @Override
    public void triggerComplete(Trigger trigger, JobExecutionContext context, Trigger.CompletedExecutionInstruction triggerInstructionCode) {
    }
});

看起来很管用：

• 我在01.11.2013t23:46:14.000的作业，每隔2秒
• 我在01.11.2013t23:46:15.000的作业，每3秒
• 我在01.11.2013t23:46:16.000的作业，每隔2秒
• 我在01.11.2013t23:46:18.000的作业，每隔2秒
• -->应该触发但跳过了-我的作业在01.11.2013t23:46:18.000，每3秒
• 我在01.11.2013t23:46:20.000的作业，每隔2秒
• 我在01.11.2013t23:46:21.000的作业，每3秒
• 我的作业在01.11.2013t23:46:22.000，每隔2秒
• 我在01.11.2013t23:46:24.000的作业，每隔2秒
• -->应该触发但跳过了-我的作业在01.11.2013t23:46:24.000，每3秒
• 我在01.11.2013t23:46:26.000的作业，每隔2秒
• 我在01.11.2013t23:46:27.000的作业，每3秒