quartz: gleichzeitige Instanzen eines Jobs in jobs.xml verhindern

Question

Dies sollte wirklich einfach sein. Ich benutze Quartz läuft unter Apache Tomcat 6.0.18, und ich habe eine jobs.xml file, die meinen geplanten Job eingerichtet, die jede Minute ausgeführt wird.

Was ich tun möchte, ist, wenn der Job noch läuft, wenn die nächste Triggerzeit rollt, will ich keinen neuen Job starten, damit ich die alte Instanz abschließen kann.

Gibt es eine Möglichkeit, dies in jobs.xml anzugeben (gleichzeitige Instanzen zu verhindern)?

Wenn nicht, gibt es eine Möglichkeit, den Zugriff auf ein In-Memory-Singleton innerhalb der Job Implementierung meiner Anwendung zu teilen (ist dies durch die JobExecutionContext?), So dass ich die Nebenläufigkeit selbst behandeln kann? (Und erkennen, ob eine vorherige Instanz läuft)

---

Update: Nach zappelte um in der Dokumentation, hier ein paar Ansätze, die ich bin am überlegen, aber entweder nicht wissen, wie sie an die Arbeit, oder es gibt Probleme.

1. Verwenden Sie StatefulJob. Dies verhindert den gleichzeitigen Zugriff ... aber ich bin nicht sicher, welche anderen Nebenwirkungen auftreten würden, wenn ich es benutze, auch möchte ich die folgende Situation vermeiden:

   Angenommen, die Triggerzeiten würden jede Minute sein, dh Trigger # 0 = zum Zeitpunkt 0, Auslöser # 1 = 60000 ms, # 2 = 120000, # 3 = 180000 usw. und der Auslöser # 0 zum Zeitpunkt 0 löst meinen Job aus, der 130000 ms benötigt. Bei einem einfachen Job würde dies die Trigger # 1 und # 2 ausführen, während der Job-Trigger # 0 noch läuft. Mit einem StatefulJob würde dies die Trigger # 1 und # 2 in der Reihenfolge ausführen, unmittelbar nachdem # 0 bei 130000 endet. Ich möchte das nicht, ich möchte # 1 und # 2 nicht ausführen und der nächste Trigger, der einen Job ausführt, sollte stattfinden bei # 3 (180000msec). Ich muss also noch etwas anderes mit StatefulJob tun, damit es so funktioniert, wie ich es möchte. Daher sehe ich keinen großen Vorteil darin, es zu benutzen.

2. Verwenden Sie eine TriggerListener, um von vetoJobExecution() den Wert true zurückzugeben.

   Obwohl die Implementierung der Schnittstelle einfach scheint, muss ich herausfinden, wie man eine Instanz eines TriggerListener deklarativ aufbaut. Can't find the docs for the xml file.

3. Verwenden Sie ein static freigegebenes Thread-sicheres Objekt (z. B. ein Semaphor oder was auch immer), das zu meiner Klasse gehört, die Job implementiert.

   Ich mag nicht die Idee der Verwendung von Singletons über das Schlüsselwort static unter Tomcat/Quarz, nicht sicher, ob es Nebenwirkungen gibt. Ich will auch nicht, dass sie echte Singletons sind, nur etwas, das mit einer bestimmten Jobdefinition in Verbindung gebracht wird.

4. Implementieren Sie meine eigenen Trigger, die erweitert und Shared-Status enthält, die einen eigenen TriggerListener ausführen könnte.

   Noch einmal, ich weiß nicht, wie Sie die XML-Datei für die Verwendung dieses Triggers anstelle des Standards <trigger><simple>...</simple></trigger> einrichten.

Answer 1

wenn Ihr Quartz Job aufwacht können Sie tun:

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())) { 
       //String message = jobName + " is already running."; 
       //log.info(message); 
       //throw new JobExecutionException(message,false); 
      } 
     } 
     //sched.deleteJob(jobName, jobGroup); if you want to delete the scheduled but not-currently-running job 
    } 

Answer 2

ich erreichte etwas ähnliches meiner Job-Klassen StatefulJob implementieren zu machen, die dafür sorgt, dass keine andere Aufträge beginnen, bevor der laufende Job beendet.

Hoffnung, die hilft;)

PD: Ich setzte sie JBoss mit ... aber ich glaube nicht, dass ein Unterschied macht.

Answer 3

Sie den Job als StatefulJob einstellen könnte, und für jeden Trigger Sie die MisfireInstruction für den Job eingestellt schaffen, um nicht ausgelöst, wenn es verpasst? Sie sind sich nicht sicher, welche Art von Job Sie verwenden, aber Sie müssen etwas über die Fehlzündungsanweisungen herausfinden, die für Ihren Triggertyp verfügbar sind.

Danke, D

Answer 4

Antwort des dimitrisli nicht so hier vollständig ist meins.

Wenn Quartz Job aufwacht, gibt es seinen JobExecutionContext zurück. Ich nehme an, Sie möchten Jobs mit dem gleichen Auslöser überspringen.

Wir erhalten derzeit Jobkontexte und prüfen, ob es eine vorherige Jobinstanz mit dem gleichen Trigger gibt. Wenn dies der Fall ist, überspringen wir einfach mit der Rückkehr.

Answer 5

Es gibt eine andere einfachere Lösung. Der Job kann eine Annotation zu DisallowConcurrentExecution erhalten, die verhindert, dass mehrere gleichzeitige Instanzen ausgeführt werden. Siehe Dokumentation here.

Die Verbindung bricht, also hier ist das relevante Beispiel.

Answer 6

Geringfügige Abweichung von der Scaramouche-Lösung.

List<JobExecutionContext> jobs = jobExecutionContext.getScheduler().getCurrentlyExecutingJobs(); 
for (JobExecutionContext job : jobs) { 
    if (job.getTrigger().equals(jobExecutionContext.getTrigger()) && !job.getFireInstanceId().equals(jobExecutionContext.getFireInstanceId()) { 
     logger.info("There's another instance running, so leaving" + this); 
     return; 
    } 

} 

scaramouche Lösung schlägt fehl, wenn eine einzelne Instanz dort für alle JobExecutions (Rückgabe des Singleton mit einer benutzerdefinierten JobFactory Klasse, anstatt Aufruf newInstance() für jede Ausführung)

Answer 7

Wenn Sie org.springframework.scheduling.quartz.QuartzJobBean verwenden verwendet wird:

protected void executeInternal(JobExecutionContext context) throws JobExecutionException { 
    try { 
     Scheduler scheduler = context.getScheduler(); 
     List<JobExecutionContext> jobs = scheduler.getCurrentlyExecutingJobs(); 
     for (JobExecutionContext job : jobs) { 
      if (job.getTrigger().equals(context.getTrigger()) && job.getJobDetail() != context.getJobDetail()) { 
       LOG.warn("Ignored!"); 
       return; 
      } 
     } 
     ... 
    } catch (SchedulerException e) { 
     LOG.error("What a luck! :'(", e); 
    } 
    ... 
}