Quartz Java reanudar un trabajo lo excede muchas veces

Question

Para mi aplicación, creo trabajos y los programo con CronTriggers. Cada trabajo tiene solo un disparador y tanto el nombre del trabajo como los nombres de los activadores son los mismos. Ningún trabajo comparte un disparador.

Ahora cuando creo un disparador de cron como este "0/1 * * * *?" que ordena al trabajo ejecutar cada segundo, funciona bien.

El problema se levanta cuando por primera vez una pausa en el trabajo llamando a:

scheduler.pauseJob(jobName, jobGroup); 

y luego reanudar el trabajo después de digamos 50 segundos con:

scheduler.resumeJob(jobName, jobGroup); 

lo que veo es que para estos 50 segundos el trabajo no se ejecutó según lo solicitado. ¡Pero en el momento en que reanudo el trabajo, veo 50 ejecuciones del trabajo al mismo tiempo!

pensé que esto era debido a la configuración predeterminada para la instrucción de fallo de encendido pero incluso después de ajustar instruciton fallo de encendido del gatillo sobre la creación de esta:

trigger.setMisfireInstruction(CronTrigger.MISFIRE_INSTRUCTION_DO_NOTHING); 

La misma cosa sucede. ¿Alguien puede sugerir una forma de arreglar esto?

Answer 1

El CronTrigger funciona recordando el nextFireTime. Después de crear el activador, se inicializa el nextFireTime. Cada vez que se desencadena el trabajo nextFireTime se actualiza. Dado que el trabajo no se activa cuando el nextFireTime en pausa permanece "viejo". Entonces, después de reanudar el trabajo, el activador devolverá cada tiempo de disparo anterior.

El problema es que el disparador no sabe que se está pausando. Para superar esto existe este manejo de fallo de encendido. Después de reanudar los trabajos, se invocará el método updateAfterMisfire() del desencadenante que corrige el nextFireTime. Pero no si la diferencia entre nextFireTime y ahora es menor que misfireThreshold. Entonces el método nunca se llama. El valor predeterminado de este umbral es 60,000. Por lo tanto, si su período de pausa fuera mayor de 60 años, todo estaría bien.

Como usted tiene problemas, asumo que no es así. ;) Para solucionar esto se puede modificar el umbral o utilizar un simple envoltorio alrededor CronTrigger:

public class PauseAwareCronTrigger extends CronTrigger { 
    // constructors you need go here 

    @Override 
    public Date getNextFireTime() { 
     Date nextFireTime = super.getNextFireTime(); 
     if (nextFireTime.getTime() < System.currentTimeMillis()) { 
      // next fire time after now 
      nextFireTime = super.getFireTimeAfter(null); 
      super.setNextFireTime(nextFireTime); 
     } 
     return nextFireTime; 
    } 
} 

Answer 2

Si pausa el trabajo, el disparador continuará disparando, pero las ejecuciones se pondrán en cola hasta que se reanude el trabajo. Esto no es un desencadenador de fallas, por lo que la configuración no tendrá ningún efecto.

Lo que quiere hacer, creo, es deshabilitar programáticamente o eliminar el desencadenador cron, en lugar de detener el trabajo. Cuando desee reanudar, vuelva a agregar el desencadenador.

Answer 3

Desde 1.6.5 al menos (la versión más antigua de cuarzo en mis manos), el programador tiene un método que pauseTrigger toma el nombre/grupo como parámetros. Esto significa que no tiene que tener una subclase de cada tipo de activador que use, ni tiene que hacer trucos de eliminación/inserción de funky.

Ambos son importantes para mí porque 1) nuestra base de datos tiene una política estricta de no eliminar y 2) el almacén de datos personalizado que utilizo no admite las subclases de activación.