溫馨提示×

您好,登錄后才能下訂單哦!

密碼登錄×
登錄注冊(cè)×
其他方式登錄
點(diǎn)擊 登錄注冊(cè) 即表示同意《億速云用戶服務(wù)條款》

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

發(fā)布時(shí)間:2021-03-10 14:01:39 來源:億速云 閱讀:264 作者:Leah 欄目:開發(fā)技術(shù)

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些?相信很多沒有經(jīng)驗(yàn)的人對(duì)此束手無策,為此本文總結(jié)了問題出現(xiàn)的原因和解決方法,通過這篇文章希望你能解決這個(gè)問題。

1、 sleep

這也是我們最常用的 sleep 休眠大法,不只是當(dāng)作休眠用,我們還可以利用它很輕松的能實(shí)現(xiàn)一個(gè)簡(jiǎn)單的定時(shí)任務(wù)。

實(shí)現(xiàn)邏輯:

新開一個(gè)線程,添加一個(gè) for/ while 死循環(huán),然后在死循環(huán)里面添加一個(gè) sleep 休眠邏輯,讓程序每隔 N 秒休眠再執(zhí)行一次,這樣就達(dá)到了一個(gè)簡(jiǎn)單定時(shí)任務(wù)的效果。

實(shí)現(xiàn)代碼如下:

private static void sleepTask() {
 new Thread(() -> {
  while (true) {
   System.out.println("hi, 歡迎關(guān)注:Java技術(shù)棧");

   try {
    // 每隔3秒執(zhí)行一次
    Thread.sleep(3000);
   } catch (InterruptedException e) {
    e.printStackTrace();
   }
  }
 }).start();
}

這種方式比較傻瓜化了,只能按固定頻率運(yùn)行,不能指定具體運(yùn)行的時(shí)間。

另外,上面的箭頭語法,棧長(zhǎng)使用了 JDK 8 中的 Lambda 表達(dá)式,這里就不再撰述了,Java 8 系列實(shí)戰(zhàn)教程我都寫了一堆了,不清楚的可以關(guān)注公眾號(hào):Java技術(shù)棧,在后臺(tái)回復(fù) "java" 閱讀,我都整理好了。

2、Timer

來看下 JDK 自帶的 java.util.Timer 類:

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

JDK 1.3 就內(nèi)置了 java.util.Timer 類,可以用來調(diào)度 java.util.TimerTask 任務(wù)。

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

幾個(gè)重要的方法:

  • schedule:開始調(diào)度任務(wù),提供了幾個(gè)包裝方法;

  • cancle:終止任務(wù)調(diào)度,取消當(dāng)前調(diào)度的所有任務(wù),正在運(yùn)行的任務(wù)不受影響;

  • purge:從任務(wù)隊(duì)列中移除所有已取消的任務(wù);

另外,java.util.TimerTask 就是實(shí)現(xiàn)了 Runnable 接口,具體任務(wù)邏輯則是在 run 方法里去實(shí)現(xiàn)。

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

實(shí)現(xiàn)代碼如下:

private static void timerTask() throws InterruptedException {
 Timer timer = new Timer();

 TimerTask timerTask = new TimerTask() {
  @Override
  public void run() {
   System.out.println("hi, 歡迎關(guān)注:Java技術(shù)棧");
  }
 };

 // 第一次任務(wù)延遲時(shí)間
 long delay = 2000;

 // 任務(wù)執(zhí)行頻率
 long period = 3 * 1000;

 // 開始調(diào)度
 timer.schedule(timerTask, delay, period);
 
 // 指定首次運(yùn)行時(shí)間
// timer.schedule(timerTask, DateUtils.addSeconds(new Date(), 5), period);

 Thread.sleep(20000);

 // 終止并移除任務(wù)
 timer.cancel();
 timer.purge();
}

這種實(shí)現(xiàn)方式比較簡(jiǎn)單,可以指定首次執(zhí)行的延遲時(shí)間、首次執(zhí)行的具體日期時(shí)間,以及執(zhí)行頻率,能滿足日常需要。

另外,需要注意的是,Timer 是線程安全的,因?yàn)楸澈笫菃尉€程在執(zhí)行所有任務(wù)。

Timer 也會(huì)有一些缺陷:

  • Timer 是單線程的,假如有任務(wù) A,B,C,任務(wù) A 如果執(zhí)行時(shí)間比較長(zhǎng),那么就會(huì)影響任務(wù) B,C 的啟動(dòng)和執(zhí)行時(shí)間,如果 B,C 執(zhí)行時(shí)間也比較長(zhǎng),那就會(huì)相互影響;

  • Timer 不會(huì)捕獲異常,如果 A,B,C 任何一個(gè)任務(wù)在執(zhí)行過程中發(fā)生異常,就會(huì)導(dǎo)致 TImer 整個(gè)定時(shí)任務(wù)停止工作;

  • Timer 是基于絕對(duì)時(shí)間調(diào)度的,而不是基于相對(duì)時(shí)間,所以它對(duì)系統(tǒng)時(shí)間的改變非常敏感;

所以,如果在使用 Timer 的過程中要注意這些缺陷,雖然可以用,但不推薦。

3、ScheduledExecutorService

因 Timer 有一些缺陷,所以不太建議使用 Timer,推薦使用 ScheduledExecutorService:

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

ScheduledExecutorService 即是 Timer 的替代者,JDK 1.5 并發(fā)包引入,是基于線程池設(shè)計(jì)的定時(shí)任務(wù)類:

java.util.concurrent.Executors.newScheduledThreadPool

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

上了線程池,每個(gè)調(diào)度任務(wù)都會(huì)分配到線程池中的某一個(gè)線程去執(zhí)行,任務(wù)就是并發(fā)調(diào)度執(zhí)行的,任務(wù)之間互不影響。

幾個(gè)重要的調(diào)度方法:

使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些

  • schedule:只執(zhí)行一次調(diào)度;

  • scheduleAtFixedRate:按固定頻率調(diào)度,如果執(zhí)行時(shí)間過長(zhǎng),下一次調(diào)度會(huì)延遲,不會(huì)同時(shí)執(zhí)行;

  • scheduleWithFixedDelay:延遲調(diào)度,上一次執(zhí)行完再加上延遲時(shí)間后執(zhí)行;

另外,可以看出,任務(wù)是支持 Runnable 和 Callable 調(diào)度的。

實(shí)現(xiàn)代碼如下:

public static void poolTask(){
 ScheduledExecutorService pool = Executors.newScheduledThreadPool(10);

 pool.scheduleAtFixedRate(() -> {
  System.out.println("hi, 歡迎關(guān)注:Java技術(shù)棧");
 }, 2000, 3000, TimeUnit.MILLISECONDS);
}

看完上述內(nèi)容,你們掌握使用Java實(shí)現(xiàn)定時(shí)任務(wù)的方法有哪些的方法了嗎?如果還想學(xué)到更多技能或想了解更多相關(guān)內(nèi)容,歡迎關(guān)注億速云行業(yè)資訊頻道,感謝各位的閱讀!

向AI問一下細(xì)節(jié)

免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場(chǎng),如果涉及侵權(quán)請(qǐng)聯(lián)系站長(zhǎng)郵箱:is@yisu.com進(jìn)行舉報(bào),并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI