如何創(chuàng)建和使用Java的ExecutorService？ 1.使用Executors工廠類創(chuàng)建線程池，如newFixedThreadPool(4)創(chuàng)建固定大小線程池；2.通過execute()提交無返回值任務(wù)，或submit()提交有返回值任務(wù)並獲取Future結(jié)果；3.關(guān)閉線程池時優(yōu)先調(diào)用shutdown()，配合awaitTermination()等待任務(wù)完成，必要時調(diào)用shutdownNow()中斷執(zhí)行。

Java 的ExecutorService是並發(fā)編程中非常實用的工具，用來管理線程池、執(zhí)行任務(wù)，避免頻繁創(chuàng)建和銷毀線程帶來的開銷。如果你只是想快速看個例子，了解怎麼用，那咱們直接上乾貨。

如何創(chuàng)建一個基本的ExecutorService

最簡單的做法是使用Executors工廠類來創(chuàng)建一個線程池。比如你想創(chuàng)建一個固定大小的線程池，可以這樣寫：

 ExecutorService executorService = Executors.newFixedThreadPool(4);

這表示你創(chuàng)建了一個最多能同時運行4 個任務(wù)的線程池。你可以根據(jù)實際需求調(diào)整數(shù)字，比如CPU 核心數(shù)或者預(yù)期並發(fā)量。

除了newFixedThreadPool ，還有幾個常用的類型：

• newCachedThreadPool() ：按需創(chuàng)建線程，適合短期任務(wù)。
• newSingleThreadExecutor() ：只有一個線程，保證任務(wù)順序執(zhí)行。
• newScheduledThreadPool(n) ：支持定時和周期性任務(wù)。

提交任務(wù)的幾種方式

創(chuàng)建好線程池之後，就可以往裡面提交任務(wù)了。常用的方法有execute()和submit() 。

execute() 方法

適用於不需要返回值的任務(wù)（Runnable）：

 executorService.execute(() -> {
    System.out.println("執(zhí)行一個任務(wù)");
});

這個方法簡單直接，但不能獲取任務(wù)結(jié)果。

submit() 方法

如果你想拿到任務(wù)的結(jié)果，可以用submit() ，它接受Callable或Runnable ，並返回一個Future對象：

 Future<Integer> future = executorService.submit(() -> {
    return 123;
});

try {
    Integer result = future.get(); // 獲取結(jié)果，可能會阻塞System.out.println("任務(wù)返回值：" result);
} catch (Exception e) {
    e.printStackTrace();
}

注意這裡調(diào)用get()是會阻塞當(dāng)前線程，直到任務(wù)完成。如果任務(wù)耗時很長，可能要考慮加超時處理。

正確關(guān)閉線程池

很多人用了ExecutorService卻沒關(guān)它，導(dǎo)致程序一直掛著不退出。所以一定要記得在適當(dāng)?shù)臅r候關(guān)閉線程池。

shutdown()

 executorService.shutdown();

調(diào)用後，線程池不再接受新任務(wù)，但會等已提交的任務(wù)執(zhí)行完。

shutdownNow()

 executorService.shutdownNow();

這個更狠一點，不僅拒絕新任務(wù)，還會嘗試中斷正在執(zhí)行的任務(wù)。

通常建議先調(diào)用shutdown() ，再配合awaitTermination()等待所有任務(wù)完成：

 executorService.shutdown();
try {
    if (!executorService.awaitTermination(60, TimeUnit.SECONDS)) {
        executorService.shutdownNow();
    }
} catch (InterruptedException e) {
    executorService.shutdownNow();
}

這樣既優(yōu)雅又安全。

實際開發(fā)中的小貼士

• 別用無界隊列：默認(rèn)的newFixedThreadPool使用的是無界隊列，任務(wù)太多可能導(dǎo)致OOM。
• 線程命名很重要：自定義線程工廠可以給線程起名字，排查問題方便很多。
• 異常處理要小心：任務(wù)拋異常不會自動打印，記得try-catch 或者設(shè)置未捕獲異常處理器。
• 別忘了關(guān)閉：特別是在Web 應(yīng)用或Spring Boot 中，關(guān)閉時機(jī)也很關(guān)鍵。

基本上就這些。 ExecutorService不復(fù)雜，但細(xì)節(jié)容易忽略，尤其是關(guān)閉和異常處理部分。只要用對了，它能大大簡化並發(fā)任務(wù)的管理。

以上是Java ExecutorService示例的詳細(xì)內(nèi)容。更多資訊請關(guān)注PHP中文網(wǎng)其他相關(guān)文章！