Làm thế nào để tránh hai công việc đang chạy cùng lúc với Quartz?

Question

Tôi đã cắt bên dưới mã mà tôi đang chạy hai công việc. Đầu tiên với khoảng thời gian 10 giây và người kia với khoảng thời gian là 3 giây. Nhưng cuối cùng tại một số thời điểm họ sẽ thực hiện cùng một lúc. Có cơ chế để tránh tình trạng này

JobDetail jDetail = new JobDetail("Job1", "group1", MyJob.class); 
    CronTrigger crTrigger = new CronTrigger("cronTrigger", "group1", "0/10 * * * * ?"); 
    sche.scheduleJob(jDetail, crTrigger); 

    jDetail = new JobDetail("Job2","group2",MyJob2.class); 
    crTrigger = new CronTrigger("cronTrigger2","group2","0/3 * * * * ?"); 
    sche.scheduleJob(jDetail, crTrigger); 

Answer 1

Bạn có thể tạo một đối tượng helper để làm cho hai công việc đồng bộ:

//In the base class 
public static Object lock = new Object(); 

//In the first class 
public void execute() { 
    synchronized(lock) { 
     //do stuff 
    } 
} 

//In the second class 
public void execute() { 
    synchronized(lock) { 
     //do stuff 
    } 
} 

Đọc thêm về đồng bộ hóa tại địa chỉ: http://docs.oracle.com/javase/tutorial/essential/concurrency/locksync.html

Answer 2

Không trả lời hoàn toàn câu hỏi của bạn nhưng đây là cách bạn có thể truy vấn một thứ gì đó chạy theo cách an toàn theo chủ đề:

//sched is your org.quartz.Scheduler 
     synchronized (sched) { 
      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())) { 
         // This job is currently executing 
        } 
       } 
      } 

Answer 3

Configure the Quartz threadpool chỉ có một chuỗi.

org.quartz.threadPool.threadCount=1 

Answer 4

Các bạn đã thử:

org.quartz.jobStore.isClustered: true 

Ngoài ra, bạn làm cho công việc của bạn thành một công việc Stateful (và thiết lập isClustered true), và rằng shoujld giải quyết vấn đề của bạn. (Rất tiếc, StatefulJob không được dùng nữa; hãy sử dụng DisallowConcurrentExecution.)