假設(shè)您想要執(zhí)行一些任務(wù)。由於透過單一執(zhí)行緒執(zhí)行它可能需要相當(dāng)長的時(shí)間才能獲得結(jié)果，因此您決定使用可靠的 ExecutorService 透過多個(gè)執(zhí)行緒處理它。

這是一個(gè)範(fàn)例：

public static void main(String[] args) {
    ExecutorService executorService = Executors.newFixedThreadPool(5);
    for (int i = 0; i < 5; i++) {
        int temp = i;
        executorService.submit(() -> {
            task(temp);
        });
    }
    executorService.shutdown();
    System.out.println("ExecutorService is shutdown");
}

private static void task(int temp) {
    try {
        TimeUnit.SECONDS.sleep(1L);
        System.out.println("Task " + temp + " completed");
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
}

當(dāng)然，像往常一樣，如果不使用「睡眠」作為任務(wù)執(zhí)行的原型，任何執(zhí)行緒範(fàn)例都是不完整的。

它輸出，

ExecutorService is shutdown
Task 1 completed
Task 2 completed
Task 0 completed
Task 4 completed
Task 3 completed

現(xiàn)在想像一下有一個(gè)無窮無盡的任務(wù)隊(duì)列，而你不知道其中的數(shù)量。也許它們是由資料庫中動(dòng)態(tài)添加的條目數(shù)量決定的。

例如，一家銀行，它必須全天處理大量交易。交易結(jié)束時(shí)間為下午5點(diǎn)，超過該時(shí)間將不再接受任何額外任務(wù)。

但是，您確實(shí)知道任務(wù)的數(shù)量是有限的，並且將在某個(gè)時(shí)間點(diǎn)結(jié)束。

如何知道所有任務(wù)完成的時(shí)間點(diǎn)？

如果您注意到上面的程式碼片段，ExecutorService.shutdown() 會使主執(zhí)行緒立即退出，但後臺執(zhí)行緒仍然處理已接受的任務(wù)直至完成。有什麼方法可以讓您收到完成通知嗎？

我想到了幾個(gè)解決方案：

1. 使用 CountDownLatch 來計(jì)算任務(wù) - 但由於您不知道任務(wù)的數(shù)量，所以使用它是不切實(shí)際的。
2. 使用ExecutorService.awaitTermination()。然而，這裡的時(shí)間仍然是不確定的。您可以使用非常自由的 ExecutorService.awaitTermination(Long.MAX_VALUE, TimeUnit.DAYS) 或類似的東西。但這又是一個(gè)阻塞呼叫。

有更好的方法來解決這個(gè)問題嗎？

Java 確實(shí)提供了一種更好且相對未知的方法來解決這個(gè)問題。這裡的「技巧」是要知道 Executors.newFixedThreadPool 本質(zhì)上是一個(gè)具有預(yù)定義值的 ThreadPoolExecutor。讓我們來看看 Executors.newFixedThreadPool 的實(shí)作。

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

我真的建議閱讀這裡的 ThreadPoolExecutor 文件。 ExecutorService 是 ThreadPoolExecutor 的便利包裝。

...強(qiáng)烈建議程式設(shè)計(jì)師使用更方便的Executors工廠方法Executors.newCachedThreadPool()（無界執(zhí)行緒池，具有自動(dòng)執(zhí)行緒回收功能）、Executors.newFixedThreadPool(int)（固定大小執(zhí)行緒池）和Executors.newSingleThreadExecutoringleThreadExecutoringle ( )（單後臺執(zhí)行緒），為最常見的使用場景預(yù)先配置設(shè)定。

將幫助我們解決問題的部分是：

鉤子方法

此類提供了受保護(hù)的可重寫 beforeExecute(Thread, Runnable) 和 afterExecute(Runnable, Throwable) 方法，這些方法在每個(gè)任務(wù)執(zhí)行之前和之後都被呼叫。這些可用於操縱執(zhí)行環(huán)境；例如，重新初始化 ThreadLocals、收集統(tǒng)計(jì)資料或新增日誌條目。此外，可以重寫方法終止（）以執(zhí)行執(zhí)行器完全終止後需要完成的任何特殊處理。

我們可以使用終止方法來通知我們同樣的事情！但我們該如何使用它呢？

public static void main(String[] args) {
    ExecutorService executorService = Executors.newFixedThreadPool(5);
    for (int i = 0; i < 5; i++) {
        int temp = i;
        executorService.submit(() -> {
            task(temp);
        });
    }
    executorService.shutdown();
    System.out.println("ExecutorService is shutdown");
}

private static void task(int temp) {
    try {
        TimeUnit.SECONDS.sleep(1L);
        System.out.println("Task " + temp + " completed");
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    }
}

如果您不喜歡匿名類別（像我一樣），您始終可以自行擴(kuò)展 ThreadPoolExecutor 來建立自訂類別。

ExecutorService is shutdown
Task 1 completed
Task 2 completed
Task 0 completed
Task 4 completed
Task 3 completed

這是驗(yàn)證它是否按照我們的預(yù)期工作的輸出。

public static ExecutorService newFixedThreadPool(int nThreads) {
    return new ThreadPoolExecutor(nThreads, nThreads,
                                  0L, TimeUnit.MILLISECONDS,
                                  new LinkedBlockingQueue<Runnable>());
}

您還使用了哪些其他相對未知的片段？請?jiān)谠u論中告訴我！

以上是掌握 ExecutorService 關(guān)閉：追蹤線程池終止的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！