¿Cómo se interrumpe o se detiene la ejecución actual del trabajo de cuarzo?

Question

Tengo algunas tareas que se ejecutan con la ayuda de Java Quartz Jobs, pero tengo que detener algunas tareas por alguna condición en mi código. Leí que esto se puede hacer a través de InterruptableJob. Pero no entendí de qué manera debería hacerlo?

Answer 1

Necesita escribir su trabajo como una implementación de InterruptableJob. Para interrumpir este trabajo, es necesario manejar a Scheduler, y llamar a interrupt(jobKey<<job name & job group>>)

Por favor, tienen una mirada @ Javadoc para las clases anteriores, también cuarzo de distribución contiene un ejemplo para esto (Ejemplo 7).

Answer 2

En Cuarzo 2.1 con la primavera se puede:

@Autowired 
private Scheduler schedulerFactoryBean; //injected by spring 
... 
... 

List<JobExecutionContext> currentlyExecuting = schedulerFactoryBean.getCurrentlyExecutingJobs(); 

//verifying if job is running  
for (JobExecutionContext jobExecutionContext : currentlyExecuting) { 
    if(jobExecutionContext.getJobDetail().getKey().getName().equals("JobKeyNameToInterrupt")){ 
     result = schedulerFactoryBean.interrupt(jobExecutionContext.getJobDetail().getKey()); 
    } 
} 

Answer 3

La mejor solución en mi opinión es el que se describe en este tema: http://forums.terracotta.org/forums/posts/list/7700.page

yo sólo he introducido un "sueño" después de la parada conjunto marcar a verdadero para permitir que el trabajo termine limpiamente.

@Override 
public void interrupt() throws UnableToInterruptJobException { 
    stopFlag.set(true); 
    try { 
     Thread.sleep(30000); 
    } catch (InterruptedException e) { 
     //logger.error("interrupt()", e); 
    } 
    Thread thread = runningThread.getAndSet(null); 
    if (thread != null) 
     thread.interrupt(); 
} 

Answer 4

No sé por qué nadie mencionó esto, o tal vez esto no estaba disponible en el momento en que se realizó la pregunta.

Hay un método llamado shutdown para una instancia de Scheduler.

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

Lo anterior se utiliza para iniciar un trabajo como

scheduler.start(); 

uso de una bandera o algo para saber cuándo hay que parar la tarea no se ejecute. A continuación, utilice

scheduler.shutdown(); 

Cómo he implementado mis requisitos:

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

Dónde jobDetail y simpleTrigger son explica por sí mismo.

Espero que ayude. :)