快捷導(dǎo)航

java 優(yōu)雅關(guān)閉線程池的方案

更新時(shí)間：2020年11月23日 17:23:54 作者：AnonyStar

這篇文章主要介紹了java 優(yōu)雅關(guān)閉線程池的方案，幫助大家更好的理解和學(xué)習(xí)Java，感興趣的朋友可以了解下

我們經(jīng)常在項(xiàng)目中使用的線程池，但是是否關(guān)心過線程池的關(guān)閉呢，可能很多時(shí)候直接再項(xiàng)目中直接創(chuàng)建線程池讓它一直運(yùn)行當(dāng)任務(wù)執(zhí)行結(jié)束不在需要了也不去關(guān)閉，這其實(shí)是存在非常大的風(fēng)險(xiǎn)的，大量的線程常駐在后臺(tái)對(duì)系統(tǒng)資源的占用是巨大的，甚至引發(fā)異常。所以在我們平時(shí)使用線程池時(shí)需要注意優(yōu)雅的關(guān)閉，這樣可以保證資源的管控。

在 Java 中和關(guān)閉線程池相關(guān)的方法主要有如下：

void shutdown()
List<Runnable> shutDownNow
boolean awaitTermination
boolean isShutDown
boolean isTerminated

對(duì)于這些方法有著不同的使用和作用，下面我們真的會(huì)這些不同的方法做詳細(xì)的介紹。

ShutDown

shutDown 方法從字面意思我們可以看到是停止關(guān)閉的意思，我們先來看下面的一段代碼，首先我們通過 ThreadPoolExecutor 來創(chuàng)建一個(gè)容量是10的無界線程池，與 FixedThreadPool 類似的，這里手動(dòng)創(chuàng)建可以更好地理解線程池的創(chuàng)建。在后我們提交一千個(gè)任務(wù)執(zhí)行，再執(zhí)行 shutdown 方法進(jìn)行暫停。

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

  ExecutorService service = new ThreadPoolExecutor(
    10,
    10,
    0L,
    TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<>());

  for (int i = 0; i < 1000; i++) {
   service.submit(() ->{
    try {
     TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
     System.out.println("接受中斷，不處理~~");
    }
    System.out.println("args = " + Arrays.deepToString(args)+ Thread.currentThread().getName());
   });
  }

  service.shutdown();
 }

我們可以看到結(jié)果所以線程會(huì)正常執(zhí)行結(jié)束后再關(guān)閉線程池，對(duì)于 ShutDown 而言它可以安全的停止一個(gè)線程池，它有幾個(gè)關(guān)鍵點(diǎn)
ShutDown 會(huì)首先將線程設(shè)置成 SHUTDOWN 狀態(tài)，然后中斷所有沒有正在運(yùn)行的線程
正在執(zhí)行的線程和已經(jīng)在隊(duì)列中的線程并不會(huì)被中斷，說白了就是使用shutDown 方法其實(shí)就是要等待所有任務(wù)正常全部結(jié)束以后才會(huì)關(guān)閉線程池
調(diào)用 shutdown() 方法后如果還有新的任務(wù)被提交，線程池則會(huì)根據(jù)拒絕策略直接拒絕后續(xù)新提交的任務(wù)。

ShutDownNow

這個(gè)方法與上面方法相比較，直觀就是 now ，即立即停止任務(wù)，
同樣是上述案列，略作修改如下，

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

  ExecutorService service = new ThreadPoolExecutor(
    10,
    10,
    0L,
    TimeUnit.MILLISECONDS,
    new LinkedBlockingQueue<>(1000));

  for (int i = 0; i < 1000; i++) {
   service.submit(() ->{
    try {
     TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
     System.out.println("接受中斷，結(jié)束線程~~");
     //這里響應(yīng)中斷
     return;
    }
    System.out.println("args = " + Arrays.deepToString(args)+ Thread.currentThread().getName());
   });
  }

  final List<Runnable> runnables = service.shutdownNow();
  System.out.println(runnables);
 }

執(zhí)行上述代碼我們發(fā)現(xiàn)，當(dāng)執(zhí)行shutDownNow 方法后，會(huì)像全部正在運(yùn)行的隊(duì)列通知中斷，正在運(yùn)行的線程接收到中斷信號(hào)后選擇處理，而在隊(duì)列中的全部取消執(zhí)行轉(zhuǎn)移到一個(gè)list隊(duì)列中返回，如上述 List<Runnable> runnables ，這里記錄了所有終止的線程

awaitTermination

這個(gè)方法并不是用來關(guān)閉線程池的，首先我們看一下這個(gè)方法的定義：

boolean awaitTermination_(long timeout, TimeUnit unit)_

可以看到這個(gè)方法有兩個(gè)參數(shù)，timeout 表示等待的時(shí)間，unit 時(shí)間單位
這個(gè)方法的作用是，調(diào)用后等待timeout時(shí)間后，反饋線程池的狀態(tài)，
等待期間（包括進(jìn)入等待狀態(tài)之前）線程池已關(guān)閉并且所有已提交的任務(wù)（包括正在執(zhí)行的和隊(duì)列中等待的）都執(zhí)行完畢，相當(dāng)于線程池已經(jīng)“終結(jié)”了，方法便會(huì)返回 true；
等待超時(shí)時(shí)間到后，第一種線程池“終結(jié)”的情況始終未發(fā)生，方法返回 false；
等待期間線程被中斷，方法會(huì)拋出 InterruptedException 異常。
上面代碼可以修改來測(cè)試，這里不再粘貼代碼

isShutDown

isShutDown 方法正如名字，判斷線程池是否停止，返回的是 Boolean 類型，如果已經(jīng)開始停止線程池則返回 true 否則放回false
當(dāng)調(diào)用了shutDown 或shutDownNow 時(shí)之后，會(huì)返回 true 不過需要注意，這時(shí)候只是代表線程池關(guān)閉流程的開始，并不是說線程池已經(jīng)停止了

isTerminated

這個(gè)方法與上面的方法的區(qū)別就是這是正真檢測(cè)線程池是否真的終結(jié)了
這不僅代表線程池已關(guān)閉，同時(shí)代表線程池中的所有任務(wù)都已經(jīng)都執(zhí)行完畢了，因?yàn)樵谡{(diào)用 shutdown方法之后，線程池會(huì)繼續(xù)執(zhí)行里面未完成的任務(wù)，包括正在執(zhí)行的任務(wù)和在任務(wù)隊(duì)列中等待的任務(wù)。
如果調(diào)用了 shutdown 方法，但是有一個(gè)線程依然在執(zhí)行任務(wù)，那么此時(shí)調(diào)用 isShutdown方法返回的是 true，而調(diào)用 isTerminated方法返回的便是 false，因?yàn)榫€程池中還有任務(wù)正在在被執(zhí)行，線程池并沒有真正“終結(jié)”。
直到所有任務(wù)都執(zhí)行完畢了，調(diào)用 isTerminated()方法才會(huì)返回 true，這表示線程池已關(guān)閉并且線程池內(nèi)部是空的，所有剩余的任務(wù)都執(zhí)行完畢了。