<kbd id="afajh"><form id="afajh"></form></kbd>
<strong id="afajh"><dl id="afajh"></dl></strong>
    <del id="afajh"><form id="afajh"></form></del>
        1. <th id="afajh"><progress id="afajh"></progress></th>
          <b id="afajh"><abbr id="afajh"></abbr></b>
          <th id="afajh"><progress id="afajh"></progress></th>

          Java中實(shí)現(xiàn)定時任務(wù)的3種方法!

          共 4442字,需瀏覽 9分鐘

           ·

          2021-03-13 00:18

          今天我們不用任何框架,用最樸素的 Java API 來實(shí)現(xiàn)定時任務(wù),本文會介紹 3 種實(shí)現(xiàn)方案,我們一起來看...

          1、 sleep

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

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

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

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

          /**
           * 休眠實(shí)現(xiàn)定時任務(wù)
           */
          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)行的時間。

          另外,上面的箭頭語法使用了 JDK 8 中的 Lambda 表達(dá)式。

          2、Timer

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

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

          幾個重要的方法:

          • schedule:開始調(diào)度任務(wù),提供了幾個包裝方法;
          • cancle:終止任務(wù)調(diào)度,取消當(dāng)前調(diào)度的所有任務(wù),正在運(yùn)行的任務(wù)不受影響;
          • purge:從任務(wù)隊列中移除所有已取消的任務(wù);

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

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

          /**
           * timer定時任務(wù)
           */
          private static void timerTask() throws InterruptedException {
              Timer timer = new Timer();

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

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

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

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

              Thread.sleep(20000);

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

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

          另外,需要注意的是,Timer 是線程安全的,因為背后是單線程在執(zhí)行所有任務(wù)。

          Timer 也會有一些缺陷:

          • Timer 是單線程的,假如有任務(wù) A,B,C,任務(wù) A 如果執(zhí)行時間比較長,那么就會影響任務(wù) B,C 的啟動和執(zhí)行時間,如果 B,C 執(zhí)行時間也比較長,那就會相互影響;
          • Timer 不會捕獲異常,如果 A,B,C 任何一個任務(wù)在執(zhí)行過程中發(fā)生異常,就會導(dǎo)致 TImer 整個定時任務(wù)停止工作;
          • Timer 是基于絕對時間調(diào)度的,而不是基于相對時間,所以它對系統(tǒng)時間的改變非常敏感;

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

          3、ScheduledExecutorService

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

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

          java.util.concurrent.Executors.newScheduledThreadPool

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

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

          • schedule:只執(zhí)行一次調(diào)度;
          • scheduleAtFixedRate:按固定頻率調(diào)度,如果執(zhí)行時間過長,下一次調(diào)度會延遲,不會同時執(zhí)行;
          • scheduleWithFixedDelay:延遲調(diào)度,上一次執(zhí)行完再加上延遲時間后執(zhí)行;

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

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

          /**
           * 線程池定時任務(wù)
           */
          public static void poolTask(){
              ScheduledExecutorService pool = Executors.newScheduledThreadPool(10);

              pool.scheduleAtFixedRate(() -> {
                  System.out.println("hi, 歡迎關(guān)注");
              }, 2000, 3000, TimeUnit.MILLISECONDS);
          }

          這是一個按固定頻率調(diào)度的任務(wù),創(chuàng)建了 10 個核心線程數(shù),首次執(zhí)行延遲 2 秒,后續(xù)每 3 秒執(zhí)行一次。

          這種方式簡單、好用,避免了使用 Timer 帶來的各種問題,推薦使用這種實(shí)現(xiàn)方式。

          總結(jié)

          本文分享了 3 種  Java 實(shí)現(xiàn)定時任務(wù)的方式,也相對簡單,但執(zhí)行頻率時間設(shè)置都太簡單,只適合簡單的業(yè)務(wù),不適合實(shí)際復(fù)雜業(yè)務(wù)的需求,實(shí)際業(yè)務(wù)要考慮分布式、故障轉(zhuǎn)移恢復(fù)等遠(yuǎn)要復(fù)雜的多。

          本文僅給大家一個參考吧,在不用框架的前提下也能實(shí)現(xiàn)定時任務(wù),在小而美的場景,還是很香的。


          往期推薦

          定時任務(wù)的實(shí)現(xiàn)原理,看完就能手?jǐn)]一個!


          一口氣說出 6 種延時隊列的實(shí)現(xiàn)方法,面試官滿意的笑了


          JDK 9 對字符串 String 的優(yōu)化,挺有意思!


          瀏覽 79
          點(diǎn)贊
          評論
          收藏
          分享

          手機(jī)掃一掃分享

          分享
          舉報
          評論
          圖片
          表情
          推薦
          點(diǎn)贊
          評論
          收藏
          分享

          手機(jī)掃一掃分享

          分享
          舉報
          <kbd id="afajh"><form id="afajh"></form></kbd>
          <strong id="afajh"><dl id="afajh"></dl></strong>
            <del id="afajh"><form id="afajh"></form></del>
                1. <th id="afajh"><progress id="afajh"></progress></th>
                  <b id="afajh"><abbr id="afajh"></abbr></b>
                  <th id="afajh"><progress id="afajh"></progress></th>
                  亚洲黄色A片 | 免费看一区二区三区A片 | 无码-ThePorn | 最新欧美日韩中文 | 免费三级成人爱做片 |