Wie Sie verhindern, dass ein Speicherverlust in Quarz

Durch die Umsetzung org.Quarz.InterruptableJob können Sie richtig interrupt-threads ausgelöst durch servlet entladen.

@DisallowConcurrentExecution
public class Job implements InterruptableJob {

    private Thread thread;

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        thread = Thread.currentThread();
        //... do work
    }

    @Override
    public void interrupt() throws UnableToInterruptJobException {
        thread.interrupt();
        try {
            thread.join();
        } catch (InterruptedException e) {
            throw new UnableToInterruptJobException(e);
        } finally {
            //... do cleanup
        }
    }
}

Diesem Beispiel kann zu einer race-condition-bug auf den thread-variable, wenn der Auftrag wurde nicht ausgeführt, bevor es unterbrochen wird. Ich lasse die endgültige Lösung für alles offen, je nach Lebenszyklus der Ziel-Anwendung. Wenn Sie brauchen, gleichzeitige Ausführung durch die gleiche job-Instanz, erweitern Sie die Lösung für den Umgang mit mehreren threads, und entfernen Sie die @DisallowConcurrentExecution annotation.

Um für diese zu arbeiten, die Quarz-Eigenschaft org.quartz.scheduler.interruptJobsOnShutdownWithWait muss true. Dies kann durch die Definition einer property-Datei für den scheduler, oder durch eine bean-Referenzen bei Verwendung von spring framework.

Beispiel quartz.properties Datei:

org.quartz.scheduler.interruptJobsOnShutdownWithWait=true

Hinweis, dass die Unterbrechung nur dann ausgelöst wird, wenn der scheduler konfiguriert ist, warten Sie auf Herunterfahren, was in einem Aufruf scheduler.shutdown(true).

InformationsquelleAutor Martin

Wenn Sie Ihre eigene Implementierung der ServletContextListener Schnittstelle für Ihre web-Anwendung, können Sie Herunterfahren Quarz anmutig in die contextDestroyed Methode. Im folgenden finden Sie den Beispiel-code für die Quarz-version 2.1.7.

Ihren job:

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class CronJob implements Job {
    public void execute(JobExecutionContext context)
            throws JobExecutionException {
        //TODO: do you job
    }
}

Ihren job scheduler:

import org.quartz.CronScheduleBuilder;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class CronJobScheduler {

    private static CronJobScheduler instance = new CronJobScheduler();  
    private Scheduler scheduler;

    private CronJobScheduler() {    
        try {
            scheduler = new StdSchedulerFactory().getScheduler();
        } catch (SchedulerException e) {
            //TODO
        }
    }

    public static CronJobScheduler getInstance() {
        return instance;
    }

    public void trigger() {
        JobKey jobKey = JobKey.jobKey("myJobName", "myJobGroup");       
        JobDetail job = JobBuilder.newJob(CronJob.class).withIdentity(jobKey).build();

        Trigger trigger = TriggerBuilder
                .newTrigger()
                .withIdentity("myTriggerName", "myJobGroup")
                .withSchedule(CronScheduleBuilder.cronSchedule("0 0 1,13 * * ?"))
                .build();

        try {
            scheduler.start();
            scheduler.scheduleJob(job, trigger);
        } catch (SchedulerException e) {    
            //TODO
        }
    }

    public void shutdown(boolean waitForJobsToComplete) {
        try {
            scheduler.shutdown(waitForJobsToComplete);
        } catch (SchedulerException e) {
            //TODO
        }
    }

}

Ihre Implementierung der ServletContextListener Schnittstelle:

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;

public class MyServletContextListener implements ServletContextListener {

    @Override
    public void contextDestroyed(ServletContextEvent arg0) {
        CronJobScheduler.getInstance().shutdown(true);
    }

    @Override
    public void contextInitialized(ServletContextEvent arg0) {
        CronJobScheduler.getInstance().trigger();
    }

}

Ihre web.xml

<listener>
    <listener-class>my.package.name.MyServletContextListener</listener-class>
</listener>

InformationsquelleAutor Yuci