Java線程池RejectedExecutionException異常：深入分析與解決方案
在Java并發編程中，java.util.concurrent.RejectedExecutionException是線程池拒絕執行任務時拋出的異常。本文將通過一個實際案例，剖析該異常的成因并提供有效的解決方案。
案例分析：
開發者使用了一個ThreadPoolExecutor，其參數配置如下：new ThreadPoolExecutor(processNum * 10, processNum * 10, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue(10000), namedThreadFactory, new ThreadPoolExecutor.AbortPolicy())，其中processNum為處理器核心數（案例中為8核16線程）。異常信息顯示線程池狀態為運行中 (Running)，池大小 (pool size) 為160，活躍線程數 (active threads) 為160，隊列任務數 (queued tasks) 為10000，已完成任務數 (completed tasks) 為588179。異常反復出現，且每次都發生在completed tasks達到588179時。
立即學習“Java免費學習筆記（深入）”；
異常原因：
該異常源于線程池的拒絕策略ThreadPoolExecutor.AbortPolicy。ThreadPoolExecutor通過核心線程數、最大線程數、任務隊列和拒絕策略來控制任務執行。當任務提交速率超過線程池處理能力時，拒絕策略被觸發。AbortPolicy策略會直接拋出RejectedExecutionException。在本例中，最大線程數和核心線程數均為160，任務隊列大小為10000。當活躍線程數達到最大值，且隊列已滿時，任何新任務提交都會導致該異常。這表明系統任務生成速度超過了線程池的處理速度。
解決方案：
解決此問題，需要調整線程池配置或修改拒絕策略。
-
調整線程池配置： 增加核心線程數、最大線程數或隊列大小可以提高線程池處理能力。但需謹慎，盲目增加線程數可能導致資源競爭加劇，降低效率。
-
修改拒絕策略： ThreadPoolExecutor 提供了其他拒絕策略：
- ThreadPoolExecutor.CallerRunsPolicy：由提交任務的線程直接執行任務，降低新任務提交速率，避免系統過載。
- ThreadPoolExecutor.DiscardPolicy：直接丟棄任務，適用于對任務丟失容忍度高的場景。
- ThreadPoolExecutor.DiscardOldestPolicy：丟棄隊列中最舊的任務，然后嘗試重新提交被拒絕的任務。（需謹慎使用，可能導致任務丟失）。
選擇合適的策略取決于具體業務場景。對于本案例，ThreadPoolExecutor.CallerRunsPolicy 是一個較好的選擇，它能有效控制任務提交速率，防止系統崩潰，并方便監控任務積壓情況。
總結：
解決RejectedExecutionException的關鍵在于分析任務積壓的原因，并根據實際情況選擇合適的拒絕策略或調整線程池參數。 合理配置線程池，并選擇合適的拒絕策略，是保證系統穩定性和高效運行的關鍵。
