Java線程池使用ThreadPoolExecutor創(chuàng)建，需關注核心參數(shù)配置。1.核心線程數(shù)控制常駐線程數(shù)量，計算密集型任務建議設為CPU核心數(shù)；2.最大線程數(shù)應對突發(fā)流量，過高會增加線程切換開銷；3.任務隊列大小需權衡內存占用與任務丟失風險；4.拒絕策略可自定義，如拋異?；蛘{用者執(zhí)行；5.關閉線程池應先調用shutdown再結合awaitTermination和shutdownNow確保安全退出。直接使用Executors工具類易造成內存溢出，submit()方法支持獲取任務結果，F(xiàn)uture.get()為阻塞操作，長時間任務可能導致線程“假死”，需設置超時機制避免。

Java 中的線程池實現(xiàn)與管理并不是什么高深技術，但用不好就容易出問題。直接 new Thread 雖然簡單，但頻繁創(chuàng)建銷毀線程會帶來不小的開銷。合理使用線程池能有效控制并發(fā)資源，提升系統(tǒng)性能。

線程池的基本創(chuàng)建方式

Java 提供了 ExecutorService 接口以及 Executors 工具類來簡化線程池的創(chuàng)建。最常用的方式是通過 ThreadPoolExecutor 來定義一個自定義線程池：

ExecutorService executor = new ThreadPoolExecutor(
    5, // 核心線程數(shù)
    10, // 最大線程數(shù)
    60, // 空閑線程存活時間
    TimeUnit.SECONDS,
    new LinkedBlockingQueue<>(100) // 任務隊列
);

這種方式讓你可以更精細地控制線程池行為。比如核心線程數(shù)決定了常駐線程數(shù)量，而最大線程數(shù)則用于應對突發(fā)流量。任務隊列的大小也很關鍵，太小容易丟任務，太大又可能占用過多內存。

常見誤區(qū)：很多人直接用 Executors.newFixedThreadPool(10)，這個方法雖然方便，但它的任務隊列是無界的，可能會導致內存溢出。

如何提交任務和處理結果

線程池主要用來執(zhí)行 Runnable 或 Callable 類型的任務。兩者區(qū)別在于 Callable 可以返回結果并拋出異常。

• 使用 execute() 方法提交 Runnable 任務：

  executor.execute(() -> System.out.println("執(zhí)行一個 Runnable 任務"));

• 使用 submit() 獲取執(zhí)行結果：

  Future<String> future = executor.submit(() -> "任務完成");
  String result = future.get(); // 阻塞直到結果返回

注意 Future.get() 是阻塞操作，如果任務還沒完成，調用線程會被掛起。如果你需要異步回調或者組合多個任務的結果，建議考慮使用 CompletableFuture。

合理配置參數(shù)避免常見問題

線程池配置不當會導致很多問題，比如 CPU 利用率低、OOM（內存溢出）、任務堆積等。以下是一些實際建議：

• 核心線程數(shù)：根據任務類型選擇。如果是計算密集型任務，通常設置為 CPU 核心數(shù)；如果是 IO 密集型，可以適當增加。
• 最大線程數(shù)：不要設得太高，否則反而因為線程切換帶來額外開銷。
• 拒絕策略：當任務隊列滿了并且線程數(shù)達到最大時，線程池會觸發(fā)拒絕策略，默認是拋異常。你可以自定義策略，比如記錄日志或丟棄任務。

new ThreadPoolExecutor.AbortPolicy() // 默認策略，拋出 RejectedExecutionException
new ThreadPoolExecutor.CallerRunsPolicy() // 由調用線程自己執(zhí)行

一個比較常見的問題是線程池“假死”——所有線程都在等待某個長時間任務完成，新任務又進不來。這種情況可以通過限制任務執(zhí)行時間或設置超時機制緩解。

正確關閉線程池

線程池不是用了就完事，不用的時候要記得關閉。否則 JVM 不會自動退出，可能造成資源泄露。

• shutdown()：不再接受新任務，但已提交的任務會繼續(xù)執(zhí)行。
• shutdownNow()：嘗試立即停止所有任務，不保證一定能成功中斷正在運行的線程。

推薦做法是先調用 shutdown，然后等待一段時間，如果還有未完成任務再考慮強制關閉：

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

關閉線程池的過程要考慮到任務是否可中斷，否則可能導致數(shù)據不一致等問題。

基本上就這些。線程池本身不復雜，但要用好卻有不少細節(jié)需要注意。

以上是在Java中實施和管理線程池的詳細內容。更多信息請關注PHP中文網其他相關文章！