Java任務(wù)調(diào)度的幾種解決方案(定時任務(wù))


Java任務(wù)調(diào)度的幾種解決方案(定時任務(wù))

一锈拨、JDK原生定時工具Timer

1.定時任務(wù)調(diào)度：基于給定的時間點肺然、給定的時間間隔、給定的執(zhí)行次數(shù)的自動執(zhí)行的任務(wù)

2.Timer位于java.util包下释树，內(nèi)部僅包含一個后臺線程（TimeThread）對多個業(yè)務(wù)任務(wù)（TimeTask）進行定時碰逸、定頻率的調(diào)度乡小。

3.schedule的四種用法和shceduleAtFixedRate的兩種用法：

void schedule(TimerTask task, long delay);

void schedule(TimerTask task, Date time);

void schedule(TimerTask task, long delay, long period);

void schedule(TimerTask task, Date firstTime, long period);

void scheduleAtFixedRate(TimeTask task,? long delay, long period );

void scheduleAtFixedRate(TimeTask task,? Date firstTime, long period );

? 參數(shù)說明：

task：所要實行的任務(wù)（需要繼承TimeTask的run()方法）

time/firstTime：首次執(zhí)行任務(wù)的時間

period：周期性執(zhí)行task的時間間隔，單位是毫秒

delay：執(zhí)行task任務(wù)前延遲的時間花竞，單位是毫秒

4.注意事項

? ? 4.1.如果time/firstTime指定在當前時間之前劲件，立刻執(zhí)行task；

? ? 4.2.scheduleAtFixedRate在任務(wù)開始時向后延遲一個period的時間執(zhí)行下一次任務(wù)

? ? ? 而schedule在任務(wù)結(jié)束時向后延遲一個period的時間執(zhí)行下一次任務(wù)

? ? 4.3.如果TimeTask拋出RuntimeException约急，那么Timer會停止所有任務(wù)的運行

? ? 4.4.單線程無法滿足并發(fā)任務(wù)的需求，所有的任務(wù)都是串行執(zhí)行意味著同一時間只能有一個任務(wù)得到執(zhí)行

5.其他

Timer.cancel()：終止Timer計時器苗分，丟棄當前所有已安排的任務(wù)

TimerTask.cancel()：終止TimeTask

Timer.purge()：從計時器的任務(wù)列表中移除已取消的任務(wù)厌蔽，并返回個數(shù)

6.Demo

public classTimerDemo {

? ? public static voidmain(String[] args) {

? ? ? ? Timer timer =new Timer();

? ? ? ? //timer.schedule(new MyTask(),new Date(),20000);

? ? ? ? timer.schedule(new MyTask(), 30000, 20000);

? ? ? ? //timer.cancel();

? ? }

}

class MyTaskextends TimerTask{

? ? @Override

? ? public voidrun() {

? ? ? ? System.out.println("execute time start :"

? ? ? ? ? ? ? ? +new SimpleDateFormat().format(

? ? ? ? ? ? ? ? ? ? ? ? this.scheduledExecutionTime()

? ? ? ? ? ? ? ? )

? ? ? ? );

? ? ? ? try{

? ? ? ? ? ? Thread.sleep(2000);

? ? ? ? } catch (InterruptedException e) {

? ? ? ? ? ? e.printStackTrace();

? ? ? ? }

? ? ? ? //this.cancel();

? ? }

}

二、JDK對定時任務(wù)調(diào)度的線程池支持：ScheduleExecutorService

? ? 雖然ScheduleExcutorServiced對Timer進行了線程池的改進摔癣，但無法滿足復(fù)雜的定時任務(wù)調(diào)度場景奴饮。

Demo：

public class ScheduleExecutorServiceDemo{

? ? public static voidmain(String[] args) {

? ? ? ? ScheduledExecutorService scheduledExecutorService=

? ? ? ? ? ? ? ? Executors.newScheduledThreadPool(10);

? ? ? ? scheduledExecutorService.scheduleAtFixedRate(

? ? ? ? ? ? ? ? new MyTask(),2000,2000, TimeUnit.MILLISECONDS

? ? ? ? );

? ? }

}

classMyTask implementsRunnable{

?? @Override

?? public voidrun() {

?? ? System.out.println("execute time start :”+new Date());

?? }

}

三纬向、Quartz(OpenSymphony)

1.作為Spring默認的調(diào)度框架，Quartz是純Java實現(xiàn)的戴卜。

? ? ? 由于Quartz強大的調(diào)度功能逾条、靈活的使用方式、還具有分布式集群能力投剥，可以說Quartz出馬輕松搞定一切任務(wù)調(diào)度服務(wù)师脂。

2.相較于Timer，Quartz增加的功能：

? ? 2.1.持久性作業(yè)：保持調(diào)度定時的狀態(tài)

? ? 2.2.作業(yè)管理：對調(diào)度作業(yè)進行有效的管理

3.Demo

public classPrintWordJob implementsJob {

? ? @Override

? ? public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException{

? ? ? ? Calendar calendar= jobExecutionContext.getCalendar();

? ? ? ? String dateFormat =new SimpleDateFormat("yy-mm-dd hh:mm:ss").format(calendar);

? ? ? ? System.out.println("打印文字時間："+dateFormat+"江锨，打印內(nèi)容：Hello Job-"+new Random().nextInt(100));

? ? }

}

public static void main(String[] args) throws SchedulerException, InterruptedException{

? ? //1.創(chuàng)建調(diào)度器Scheduler

? ? SchedulerFactory schedulerFactory=new StdSchedulerFactory();

? ? Scheduler scheduler=schedulerFactory.getScheduler();

? ? //2.創(chuàng)建JobDetail實例吃警，并與PrintWordJob類綁定（Job執(zhí)行內(nèi)容）

? ? JobDetail jobDetail= JobBuilder.newJob(PrintWordJob.class)

? ? ? ? ? ? .withIdentity("myFirstJob","myGroup")

? ? ? ? ? ? .build();

? ? //3.構(gòu)建Trigger實例，設(shè)置每隔三秒執(zhí)行一次

? ? Trigger trigger=TriggerBuilder.newTrigger()

? ? ? ? ? ? .withIdentity("trigger1","triggerGroup1")

? ? ? ? ? ? .startNow()

? ? ? ? ? ? .withSchedule(

? ? ? ? ? ? ? ? ? ? SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(3).repeatForever()

? ? ? ? ? ? ).build();

? ? //4.執(zhí)行

? ? scheduler.scheduleJob(jobDetail,trigger);

? ? System.out.println("==========================scheduler start !======================");

? ? scheduler.start();

? ? //5.睡眠

? ? TimeUnit.MINUTES.sleep(1);

? ? scheduler.shutdown();

? ? System.out.println("==========================scheduler shutdown !======================");

}

4.Job和JobDetail?

4.1.Job是Quartz中的一個接口啄育，接口下只有execute方法酌心，在該方法中編寫業(yè)務(wù)邏輯

4.2.JobDetail用來綁定Job并為實例提供屬性：name、group挑豌、jobClass安券、jobDataMap

? ? ? JobDetail綁定指定的Job，每次Scheduler調(diào)度執(zhí)行一個Job的時候氓英，首先會先拿到對應(yīng)的Job并創(chuàng)建Job實例侯勉，再去執(zhí)行Job中的exxcute方法的內(nèi)容。任務(wù)執(zhí)行結(jié)束后關(guān)聯(lián)的Job對象實例會被釋放债蓝，且會被JVM GC清除壳鹤。

4.3.JobDetail的任務(wù)就是在Scheduler執(zhí)行時創(chuàng)建一個新的Job實例，避免并發(fā)直接訪問同一Job實例饰迹。


5.JobExecutionContext

JobExecutionContext包含Quartz運行時的環(huán)境以及Job本身的詳細數(shù)據(jù)信息芳誓。當Schedule調(diào)度執(zhí)行了一個Job的時候，就會將JobExecutionContext傳遞到該Job的execute()中啊鸭，Job就可以通過JobExecutionCOntext對象獲取信息锹淌。

6.JobDataMap

JobDataMap實現(xiàn)了JDK的Map接口，可以以key-value的形式存儲數(shù)據(jù)赠制。JobDetail赂摆、Trigger都可以使用JobDataMap來設(shè)置一些參數(shù)信息，Job執(zhí)行execute()方法的時候钟些，JobExecutionContext可以獲取到JobDataMap里的信息烟号。

Demo：

初始化JobDetail時：

JobDetail jobDetail= JobBuilder.newJob(PrintWordJob.class)

? ? ? ? .withIdentity("myFirstJob", "myGroup")

? ? ? ? .usingJobData("key", "value")

? ? ? ? .build();

Job實例中獲取

Object value= jobExecutionContext.getMergedJobDataMap().get("key");

7.Trigger:Trigger是Quartz的觸發(fā)器，會去通知Scheduler合適去執(zhí)行對應(yīng)的Job

new Trigger().startAt()：設(shè)置觸發(fā)器首次被觸發(fā)的時間政恍；

new Trigger().endAt()：設(shè)置觸發(fā)器接觸觸發(fā)的時間汪拥；

new Trigger().startNow()：設(shè)置觸發(fā)器啟動后即刻觸發(fā)

7.1. TriggerWithSimpleSchedule

Demo：

Date startDate= new Date();

startDate.setTime(startDate.getTime() +5000);

Date endDate= new Date();

endDate.setTime(startDate.getTime() +5000);

Trigger trigger =TriggerBuilder.newTrigger().withIdentity("trigger1", "triggerGroup1")

? ? ? ? .usingJobData("trigger1", "這是jobDetail1的trigger")

? ? ? ? .startNow()//立即生效

? ? ? ? .startAt(startDate)

? ? ? ? .endAt(endDate)

? ? ? ? .withSchedule(SimpleScheduleBuilder.simpleSchedule()

? ? ? ? ? ? ? ? .withIntervalInSeconds(1)//每隔1s執(zhí)行一次

? ? ? ? ? ? ? ? .repeatForever()).build();//一直執(zhí)行

7.2. CronTrigger（常用）

CronTrigger基于日歷的作業(yè)調(diào)度，而SimpleTrigger是精準指定間隔篙耗。

Cron表達式：[秒][分][時][日][月][周][年]

Demo：

CronTrigger cronTrigger= TriggerBuilder.newTrigger().withIdentity("trigger1", "triggerGroup1")

? ? ? ? .usingJobData("trigger1", "這是jobDetail1的trigger")

? ? ? ? .startNow()//立即生效

? ? ? ? .startAt(startDate)

? ? ? ? .endAt(endDate)

? ? ? ? .withSchedule(CronScheduleBuilder.cronSchedule("* 30 10 ? * 1/5 2018"))

? ? ? ? .build();

最后編輯于 ：
?著作權(quán)歸作者所有,轉(zhuǎn)載或內(nèi)容合作請聯(lián)系作者
  • 人面猴
    序言：七十年代末迫筑，一起剝皮案震驚了整個濱河市宪赶，隨后出現(xiàn)的幾起案子，更是在濱河造成了極大的恐慌脯燃，老刑警劉巖搂妻，帶你破解...
    沈念sama閱讀 222,104評論 6贊 515
  • 死咒
    序言：濱河連續(xù)發(fā)生了三起死亡事件，死亡現(xiàn)場離奇詭異辕棚，居然都是意外死亡欲主，警方通過查閱死者的電腦和手機，發(fā)現(xiàn)死者居然都...
    沈念sama閱讀 94,816評論 3贊 399
  • 救了他兩次的神仙讓他今天三更去死
    文/潘曉璐 我一進店門坟募，熙熙樓的掌柜王于貴愁眉苦臉地迎上來岛蚤，“玉大人，你說我怎么就攤上這事懈糯〉佣剩” “怎么了？”我有些...
    開封第一講書人閱讀 168,697評論 0贊 360
  • 道士緝兇錄：失蹤的賣姜人
    文/不壞的土叔 我叫張陵赚哗，是天一觀的道長她紫。 經(jīng)常有香客問我，道長屿储，這世上最難降的妖魔是什么贿讹？ 我笑而不...
    開封第一講書人閱讀 59,836評論 1贊 298
  • ?港島之戀（遺憾婚禮）
    正文 為了忘掉前任，我火速辦了婚禮够掠，結(jié)果婚禮上民褂，老公的妹妹穿的比我還像新娘。我一直安慰自己疯潭，他們只是感情好赊堪，可當我...
    茶點故事閱讀 68,851評論 6贊 397
  • 惡毒庶女頂嫁案：這布局不是一般人想出來的
    文/花漫 我一把揭開白布。 她就那樣靜靜地躺著竖哩，像睡著了一般哭廉。 火紅的嫁衣襯著肌膚如雪。 梳的紋絲不亂的頭發(fā)上相叁，一...
    開封第一講書人閱讀 52,441評論 1贊 310
  • 城市分裂傳說
    那天遵绰，我揣著相機與錄音，去河邊找鬼增淹。 笑死椿访，一個胖子當著我的面吹牛，可吹牛的內(nèi)容都是我干的虑润。 我是一名探鬼主播赎离，決...
    沈念sama閱讀 40,992評論 3贊 421
  • 雙鴛鴦連環(huán)套：你想象不到人心有多黑
    文/蒼蘭香墨 我猛地睜開眼，長吁一口氣：“原來是場噩夢啊……” “哼端辱！你這毒婦竟也來了梁剔？” 一聲冷哼從身側(cè)響起，我...
    開封第一講書人閱讀 39,899評論 0贊 276
  • 萬榮殺人案實錄
    序言：老撾萬榮一對情侶失蹤舞蔽，失蹤者是張志新（化名）和其女友劉穎荣病，沒想到半個月后，有當?shù)厝嗽跇淞掷锇l(fā)現(xiàn)了一具尸體渗柿，經(jīng)...
    沈念sama閱讀 46,457評論 1贊 318
  • ?護林員之死
    正文 獨居荒郊野嶺守林人離奇死亡个盆，尸身上長有42處帶血的膿包…… 初始之章·張勛 以下內(nèi)容為張勛視角 年9月15日...
    茶點故事閱讀 38,529評論 3贊 341
  • ?白月光啟示錄
    正文 我和宋清朗相戀三年，在試婚紗的時候發(fā)現(xiàn)自己被綠了朵栖。 大學時的朋友給我發(fā)了我未婚夫和他白月光在一起吃飯的照片颊亮。...
    茶點故事閱讀 40,664評論 1贊 352
  • 活死人
    序言：一個原本活蹦亂跳的男人離奇死亡，死狀恐怖陨溅，靈堂內(nèi)的尸體忽然破棺而出终惑，到底是詐尸還是另有隱情，我是刑警寧澤门扇，帶...
    沈念sama閱讀 36,346評論 5贊 350
  • ?日本核電站爆炸內(nèi)幕
    正文 年R本政府宣布雹有，位于F島的核電站，受9級特大地震影響臼寄，放射性物質(zhì)發(fā)生泄漏霸奕。R本人自食惡果不足惜，卻給世界環(huán)境...
    茶點故事閱讀 42,025評論 3贊 334
  • 男人毒藥：我在死后第九天來索命
    文/蒙蒙 一吉拳、第九天 我趴在偏房一處隱蔽的房頂上張望质帅。 院中可真熱鬧，春花似錦留攒、人聲如沸煤惩。這莊子的主人今日做“春日...
    開封第一講書人閱讀 32,511評論 0贊 24
  • 一樁弒父案稼跳，背后竟有這般陰謀
    文/蒼蘭香墨 我抬頭看了看天上的太陽盟庞。三九已至，卻和暖如春汤善，著一層夾襖步出監(jiān)牢的瞬間什猖，已是汗流浹背。 一陣腳步聲響...
    開封第一講書人閱讀 33,611評論 1贊 272
  • 情欲美人皮
    我被黑心中介騙來泰國打工红淡， 沒想到剛下飛機就差點兒被人妖公主榨干…… 1. 我叫王不留不狮，地道東北人。 一個月前我還...
    沈念sama閱讀 49,081評論 3贊 377
  • 代替公主和親
    正文 我出身青樓在旱，卻偏偏與公主長得像摇零，于是被迫代替她去往敵國和親。 傳聞我的和親對象是個殘疾皇子桶蝎，可洞房花燭夜當晚...
    茶點故事閱讀 45,675評論 2贊 359