淺談Scheduler

本文轉載自查看原文 2018-04-05 12:22 13358 quartz

1.Scheduler工廠模式

所有的Scheduler實例應該由SchedulerFactory來創建

2.SchedulerFactory類圖

　　最常用的是StdSchedulerFactory工程類，其出那個鍵Scheduler的兩種方式:

            //3. 創建scheduler
            Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

            // 3. 創建scheduler
            SchedulerFactory sfact = new StdSchedulerFactory();
            Scheduler scheduler = sfact.getScheduler();

3.　　回顧Quartz三個核心概念

調度器
任務
觸發器

1個job對應多個Trigger

4.Scheduler的創建方式


StdSchedulerFactory:

　　使用一組參數（Java.util.Properties）來創建和初始化Quartz調度器 　　配置參數一般存儲在quartz.properties中 　　調用getScheduler方法就能創建和初始化調度器對象

5..Scheduler的主要函數

// 綁定 jobDetail 和 trigger，將它注冊進 Scheduler 當中  ,返回值是最近一次任務執行的開始時間
Date scheduleJob(JobDetail jobDetail, Trigger trigger)
// 啟動 Scheduler
void start()
// 暫停 Scheduler
void standby()
// 關閉 Scheduler
void shutdown()

例一:測試:scheduleJob函數返回最近一次開始執行的時間

package cn.qlq.quartz;

import static org.quartz.JobBuilder.newJob;

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

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

public class HelloScheduler {
    public static void main(String[] args) {
        try {
            // 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
            JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
                    .withIdentity("myJob") // 定義name/group
                    .build();
            // 打印當前的時間
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date date = new Date();
            System.out.println("current time is :" + sf.format(date));

            // 2. 2018年內每天11點18開始執行，每隔5s執行一次
            CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
                    .withIdentity("myTrigger", "group1")// 定義名字和組
                    .withSchedule(    //定義任務調度的時間間隔和次數
                            CronScheduleBuilder
                            .cronSchedule("0/5 0 14,18 * * ? *")
                            )
                    .build();

            // 3. 創建scheduler
            SchedulerFactory sfact = new StdSchedulerFactory();
            Scheduler scheduler = sfact.getScheduler();

            // 4. 將trigger和jobdetail加入這個調度
//            scheduler.scheduleJob(jobDetail, trigger);

            // 5. 啟動scheduler
            scheduler.start();
            
            System.out.println("schedule time is:"+sf.format(scheduler.scheduleJob(jobDetail, trigger)));
            

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

結果:

current time is :2018-04-05 11:42:42
schedule time is:2018-04-05 02:00:00

例二:測試standby()掛起Scheduler之后3s后再次開啟Scheduler

package cn.qlq.quartz;

import static org.quartz.JobBuilder.newJob;

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

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

public class HelloScheduler {
    public static void main(String[] args) {
        try {
            // 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
            JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
                    .withIdentity("myJob") // 定義name/group
                    .build();
            // 打印當前的時間
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date date = new Date();
            System.out.println("current time is :" + sf.format(date));

            // 2. 2018年內每天11點18開始執行，每隔5s執行一次
            CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
                    .withIdentity("myTrigger", "group1")// 定義名字和組
                    .withSchedule(    //定義任務調度的時間間隔和次數
                            CronScheduleBuilder
                            .cronSchedule("* * * * * ? *")
                            )
                    .build();

            // 3. 創建scheduler
            SchedulerFactory sfact = new StdSchedulerFactory();
            Scheduler scheduler = sfact.getScheduler();

            // 4. 將trigger和jobdetail加入這個調度
            scheduler.scheduleJob(jobDetail, trigger);

            // 5. 啟動scheduler
            scheduler.start();
            
            //scheduler執行2s后掛起
            Thread.sleep(2000);
            scheduler.standby();
            //scheduler掛起3s后再次啟動scheduler
            Thread.sleep(3000);
            scheduler.start();
            

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

結果：

current time is :2018-04-05 11:49:28
current exec time is :2018-04-05 11:49:28 current exec time is :2018-04-05 11:49:29 current exec time is :2018-04-05 11:49:30 current exec time is :2018-04-05 11:49:33 current exec time is :2018-04-05 11:49:33 current exec time is :2018-04-05 11:49:33 current exec time is :2018-04-05 11:49:34 current exec time is :2018-04-05 11:49:35 ....

例三:測試shutdown函數(shutdown之后不能再次調用start重啟，會報錯)

shutdown(true)表示等待所有正在執行的任務執行完畢后關閉Scheduler
shutdown(false),即shutdown()表示直接關閉Scheduler

(1)Job中睡眠5s鍾

package cn.qlq.quartz;

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

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

public class HelloJob implements Job {
    

    public void execute(JobExecutionContext context) throws JobExecutionException {
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }
        //打印當前的時間
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
        Date date = new Date();
        System.out.println("current exec time is :"+sf.format(date));
    }
    
}

shutdown傳入true參數:(在程序執行完之后才殺死Scheduler)

package cn.qlq.quartz;

import static org.quartz.JobBuilder.newJob;

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

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

public class HelloScheduler {
    public static void main(String[] args) {
        try {
            // 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
            JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
                    .withIdentity("myJob") // 定義name/group
                    .build();
            // 打印當前的時間
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date date = new Date();
            System.out.println("current time is :" + sf.format(date));

            // 2. 2018年內每天11點18開始執行，每隔5s執行一次
            CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
                    .withIdentity("myTrigger", "group1")// 定義名字和組
                    .withSchedule(    //定義任務調度的時間間隔和次數
                            CronScheduleBuilder
                            .cronSchedule("* * * * * ? *")
                            )
                    .build();

            // 3. 創建scheduler
            SchedulerFactory sfact = new StdSchedulerFactory();
            Scheduler scheduler = sfact.getScheduler();

            // 4. 將trigger和jobdetail加入這個調度
            scheduler.scheduleJob(jobDetail, trigger);

            // 5. 啟動scheduler
            scheduler.start();
            
            //scheduler執行2s后掛起
            Thread.sleep(2000);
            scheduler.shutdown(true);
            //shutdown(true)表示等待所有正在執行的任務執行完畢后關閉Scheduler
            //shutdown(false),即shutdown()表示直接關閉Scheduler
            System.out.println("scheduler is shutdown?"+scheduler.isShutdown());

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

結果:

current time is :2018-04-05 11:58:25
current exec time is :2018-04-05 11:58:30
current exec time is :2018-04-05 11:58:31 current exec time is :2018-04-05 11:58:32 scheduler is shutdown?true

shutdown傳入false參數:(立即殺死Scheduler)

package cn.qlq.quartz;

import static org.quartz.JobBuilder.newJob;

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

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

public class HelloScheduler {
    public static void main(String[] args) {
        try {
            // 1. 創建一個JodDetail實例 將該實例與Hello job class綁定 (鏈式寫法)
            JobDetail jobDetail = newJob(HelloJob.class) // 定義Job類為HelloQuartz類，這是真正的執行邏輯所在
                    .withIdentity("myJob") // 定義name/group
                    .build();
            // 打印當前的時間
            SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss");
            Date date = new Date();
            System.out.println("current time is :" + sf.format(date));

            // 2. 2018年內每天11點18開始執行，每隔5s執行一次
            CronTrigger trigger = (CronTrigger) TriggerBuilder.newTrigger()
                    .withIdentity("myTrigger", "group1")// 定義名字和組
                    .withSchedule(    //定義任務調度的時間間隔和次數
                            CronScheduleBuilder
                            .cronSchedule("* * * * * ? *")
                            )
                    .build();

            // 3. 創建scheduler
            SchedulerFactory sfact = new StdSchedulerFactory();
            Scheduler scheduler = sfact.getScheduler();

            // 4. 將trigger和jobdetail加入這個調度
            scheduler.scheduleJob(jobDetail, trigger);

            // 5. 啟動scheduler
            scheduler.start();
            
            //scheduler執行2s后掛起
            Thread.sleep(2000);
            scheduler.shutdown(false);
            //shutdown(true)表示等待所有正在執行的任務執行完畢后關閉Scheduler
            //shutdown(false),即shutdown()表示直接關閉Scheduler
            System.out.println("scheduler is shutdown?"+scheduler.isShutdown());

        } catch (Exception e) {
            e.printStackTrace();
        }
    }
}

結果:

current time is :2018-04-05 12:00:11
scheduler is shutdown?true
current exec time is :2018-04-05 12:00:17 current exec time is :2018-04-05 12:00:17 current exec time is :2018-04-05 12:00:18 current exec time is :2018-04-05 12:00:19

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 quartz---的Scheduler 任務調度：Scheduler 事件event_scheduler dbms_scheduler介紹 k8s之scheduler RxJS——調度器（Scheduler） Reactor中的Thread和Scheduler Task Scheduler 介紹 linux DRM GPU scheduler 筆記 scheduler_default_filters 詳解