Có thể giết một công việc Quartz hiện đang chạy không?

Question

Tôi nhớ rằng chúng ta không thể giết công việc hiện tại đang chạy Quartz Job nhưng chúng ta có thể ngắt và kiểm tra boolean ở bất cứ nơi nào là cần thiết cho dù chúng ta cần tiếp tục với các hoạt động tiếp theo hay không.

Ngay cả khi chúng tôi triển khai InterruptableJob và gọi scheduler.interrupt để làm gián đoạn Công việc, công việc hiện tại sẽ vẫn đang chạy trên máy chủ.

Ex:

1. Một truy vấn SQL tên đã được kích hoạt bởi các công việc thông qua Hibernate mà phải mất một thời gian dài
2. Một cuộc gọi đã được thực hiện cho một máy chủ của bên thứ ba mà máy chủ của bên thứ ba phải mất một chặng đường dài thời gian để đáp ứng

http://neopatel.blogspot.in/2011/05/quartz-stop-job.html http://forums.terracotta.org/forums/posts/list/3191.page

Ai đó có thể sửa chữa sự hiểu biết của tôi và giải thích cho tôi cách chúng ta có thể giết hoặc ngừng việc thực hiện "hiện tại"?

Cảm ơn, Kathir

Answer 1

Như bạn nói, không có cách nào để làm gián đoạn "tàn nhẫn" một công việc trong thạch anh, không phải trong JAVA.

Bạn có thể đóng gói logic của công việc của mình trong một Thread riêng biệt và chạy nó với ExecutorService.

Hãy xem ví dụ này: https://stackoverflow.com/a/2275596/1517816

Giả QuartzJob của bạn là class Test và di chuyển logic kinh doanh của bạn trong lớp Task.

Hy vọng nó giúp

Answer 2

bạn có thể tạo lớp trừu tượng mới có tên gọi JobBase ví dụ mà thực hiện giao diện IJob và chèn phương pháp trừu tượng: public abstract void ExecuteJob(IJobExecutionContext context);

On JobBase bạn có thể thực hiện phương pháp Execute như thế này

public abstract class JobBase : IJob,IInterruptableJob 
{ 
    private Thread currentThread; 
    private ILog logger; 
    public JobBase(ILog logger) 
    { 
     this.logger=logger; 
    } 
     public void Execute(IJobExecutionContext context) 
     { 

      var thread = new Thread(()=> 
      { 
       try 
       { 
        this.ExecuteJob(context); 
       } 
       catch(Exception ex) 
       { 
        this.logger.ErrorFormat("Unhandled exception {0}",ex.ToString()); 

       } 
      }); 

      thread.Start(); 
      this.currentThread = thread; 
      this.currentThread.Join(); 
     } 
     public abstract void ExecuteJob(IJobExecutionContext context); 

     public void Interrupt() 
     { 
      currentThread.Abort(); 
     } 
} 

Mỗi công việc sẽ thực hiện phương thức JobExecute.

public class TestJob :JobBase 
{ 
    private ILog logger; 
    public TeJob(ILog logger):base(logger) 
    { 
    } 

    public override ExecuteJob(IJobExecutionContext context) 
    { 
    } 
} 

Giả rằng việc sử dụng một số nhà máy để tạo một Job

Đối Dừng một công việc bạn sẽ gọi phương thức scheduler.Interrupt(new JobKey(jobName));

Answer 3

Tôi không biết tại sao không ai nhắc đến điều này, hoặc có lẽ đây không phải là có sẵn tại thời điểm câu hỏi được hỏi.

Có một phương pháp được gọi là tắt máy cho phiên bản Trình lập lịch biểu.

SchedulerFactory factory = new StdSchedulerFactor(); 
Scheduler scheduler = factory.getScheduler(); 

Trên đây được sử dụng để bắt đầu một công việc như

scheduler.start(); 

Sử dụng một lá cờ hoặc một cái gì đó để biết khi nào phải ngừng công việc từ chạy.Sau đó sử dụng

scheduler.shutdown(); 

Làm thế nào tôi thực hiện yêu cầu của tôi:

if(flag==true) 
{ 
    scheduler.start(); 
    scheduler.scheduleJob(jobDetail, simpleTrigger); 
} 
else if(flag==false) 
{ 
    scheduler.shutdown(); 
} 

đâu jobDetail và simpleTrigger là tự giải thích.

Hy vọng điều đó sẽ hữu ích. :)