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

這是一個(gè)示例：

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í)行的原型，任何線程示例都是不完整的。

它輸出，

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

現(xiàn)在想象一下有一個(gè)無窮無盡的任務(wù)隊(duì)列，而你不知道其中的數(shù)量。也許它們是由數(shù)據(jù)庫中動(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() 會(huì)使主線程立即退出，但后臺(tái)線程仍然處理已接受的任務(wù)直至完成。有什么方法可以讓您收到完成通知嗎？

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

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

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

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

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

我真的建議閱讀這里的 ThreadPoolExecutor 文檔。 ExecutorService 是 ThreadPoolExecutor 的便捷包裝。

...強(qiáng)烈建議程序員使用更方便的Executors工廠方法Executors.newCachedThreadPool()（無界線程池，具有自動(dòng)線程回收功能）、Executors.newFixedThreadPool(int)（固定大小線程池）和Executors.newSingleThreadExecutor( )（單后臺(tái)線程），為最常見的使用場(chǎng)景預(yù)配置設(shè)置。

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

鉤子方法

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

我們可以使用終止方法來通知我們同樣的事情！但我們?cè)撊绾问褂盟兀?br>

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 來創(chuàng)建自定義類。

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>());
}

您還使用了哪些其他相對(duì)未知的片段？請(qǐng)?jiān)谠u(píng)論中告訴我！

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