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

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

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

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

ExecutorService executorService = Executors.newFixedThreadPool(4);

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

除了 newFixedThreadPool，還有幾個(gè)常用的類(lèi)型：

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

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

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

execute() 方法

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

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

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

submit() 方法

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

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

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

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

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

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

shutdown()

executorService.shutdown();

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

shutdownNow()

executorService.shutdownNow();

這個(gè)更狠一點(diǎn)，不僅拒絕新任務(wù)，還會(huì)嘗試中斷正在執(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)雅又安全。

實(shí)際開(kāi)發(fā)中的小貼士

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

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

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