2014-09-21 87 views
0

我是Quartz 2.1的新手,对此有疑问。我有一个工作如下石英防止作业重叠

@PersistJobDataAfterExecution 
@DisallowConcurrentExecution 
public class HelloJob implements Job { 

    public void execute(JobExecutionContext arg0) throws JobExecutionException { 

和我创造就业岗位2如下

JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("Job1").build(); 
JobDetail jobDetail2 = JobBuilder.newJob(HelloJob.class).withIdentity("Job2").storeDurably().build(); 
Trigger trigger = TriggerBuilder.newTrigger().forJob(jobDetail).withSchedule(
         SimpleScheduleBuilder.simpleSchedule() 
           .withIntervalInSeconds(5).repeatForever()).build(); 
Trigger trigger2 = TriggerBuilder.newTrigger().forJob(jobDetail2).withSchedule(
         SimpleScheduleBuilder.simpleSchedule() 
           .withIntervalInSeconds(10).repeatForever()).build(); 
     SchedulerFactory factory = new StdSchedulerFactory("quartz.properties"); 
     Scheduler scheduler = factory.getScheduler(); 
     scheduler.start(); 
     scheduler.scheduleJob(jobDetail, trigger); 
     scheduler.scheduleJob(jobDetail2, trigger2); 

正如你看到的,JOB1执行每5秒,作业2执行每10秒。我想要的是,如果job1完成超过10秒钟,job2将执行直到job1完成。但实际上,job2仍然在job1未完成时执行。你可以帮我吗?

P/s: this is the quartz.properties: 
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool 
org.quartz.threadPool.threadCount = 2 
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true 

回答

0
  1. 如果您使用的是同样的工作,你只需要一个一个JobDetail实例(而不是两个)。
  2. Call storeDurably for you JobDetail。
  3. 设置触发相同的JobDetail和触发2
  4. 安排工作进度,如下所示:

    scheduler.start(); 
    scheduler.addJob(jobDetail, true); 
    scheduler.scheduleJob(trigger); 
    scheduler.scheduleJob(trigger2); 
    

你的代码的其他部分还是不错的。