quartz---的Scheduler

 

 　　　　　　　　　　　　　　　　　　　　　　quartz---的Scheduler

　　　　

　　從這副圖中可以很直觀的看出來quartz的關系：

　　　　調度：Scheduler任務調度器，是實際執行任務調度的控制器。在spring中通過SchedulerFactoryBean封裝起來。

　　　　觸發器：Trigger 觸發器，用於定義任務調度的時間規則，有SimpleTrigger,CronTrigger,DateIntervalTrigger和NthIncludedDayTrigger，其中CronTrigger用的比較多，本文主要介紹這種方式。CronTrigger在spring中封裝在CronTriggerFactoryBean中。

　　　1）scheduler.start();scheduler.standby();用代碼解釋：

package com.imooc.demo.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException, InterruptedException {
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Time is:"+sf.format(date));
        // 創建一個jobDatail實例，將該實力與helloJob綁定
        JobDetail detail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob")
                .build();

        //美每秒觸發一次任務
        CronTrigger trigger = (CronTrigger)TriggerBuilder
                .newTrigger()
                .withIdentity("myTrigger", "group1")
                //2017-2019每月的第二周的星期5下午14開始觸發，每隔5秒允許一次
                .withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ?"))
                .build();
        // 創建Scheduler實例
        SchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        scheduler.start();
        // 把jobDetail和Trigger與scheuler綁定在一起：觸發啟動
        System.out.println("----:"+sf.format(scheduler.scheduleJob(detail, trigger)));;
        Thread.sleep(2000L);
        //掛起
        scheduler.standby();
        
        //scheduler掛起3秒后繼續執行
        Thread.sleep(3000L);
        scheduler.start();
    }
}

 

　　　　每秒執行一次，2秒后停止，執行3次后停止執行，運行結果：

 

　　2）shutdown();

 

package com.imooc.demo.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException, InterruptedException {
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Time is:"+sf.format(date));
        // 創建一個jobDatail實例，將該實力與helloJob綁定
        JobDetail detail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob")
                .build();

        //美每秒觸發一次任務
        CronTrigger trigger = (CronTrigger)TriggerBuilder
                .newTrigger()
                .withIdentity("myTrigger", "group1")
                //2017-2019每月的第二周的星期5下午14開始觸發，每隔5秒允許一次
                .withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ?"))
                .build();
        // 創建Scheduler實例
        SchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        scheduler.start();
        // 把jobDetail和Trigger與scheuler綁定在一起：觸發啟動
        System.out.println("----:"+sf.format(scheduler.scheduleJob(detail, trigger)));;
        Thread.sleep(2000L);
        //掛起
        scheduler.shutdown();
        
        //scheduler掛起3秒后繼續執行
        Thread.sleep(3000L);
        scheduler.start();
    }
}

 

運行結果為：

 

　　　　

 

　　　總結 ：

 　　　在shutdown()后，程序不能再從新start().

package com.imooc.demo.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException, InterruptedException {
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Time is:"+sf.format(date));
        // 創建一個jobDatail實例，將該實力與helloJob綁定
        JobDetail detail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob")
                .build();

        //美每秒觸發一次任務
        CronTrigger trigger = (CronTrigger)TriggerBuilder
                .newTrigger()
                .withIdentity("myTrigger", "group1")
                //2017-2019每月的第二周的星期5下午14開始觸發，每隔5秒允許一次
                .withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ?"))
                .build();
        // 創建Scheduler實例
        SchedulerFactory factory = new StdSchedulerFactory();
        Scheduler scheduler = factory.getScheduler();
        scheduler.start();
        // 把jobDetail和Trigger與scheuler綁定在一起：觸發啟動
        System.out.println("----:"+sf.format(scheduler.scheduleJob(detail, trigger)));;
        Thread.sleep(2000L);
        //shutdown(true)標志等待所有正在執行的job執行完之后，再關閉scheduler
        //shutdown(false)即shutdown()表示job執行完畢之后，再關閉scheduler
        //shutdown掛起3秒后繼續執行
        scheduler.shutdown(true);
        System.out.println("scheruler is shut down?:"+scheduler.isShutdown());

    }
}

運行結果：

　　

 

總結 ：

　　　　shutdown(true)標志等待所有正在執行的job執行完之后，再關閉scheduler

 

 

總結 ：
　　　　shutdown(false)即關閉scheduler ，然后執行job之后，關掉程序