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 * 10，隊列大小為 10000，拒絕策略為 AbortPolicy。服務器為 8 核 16 線程。在處理 588179 個任務后，拋出 RejectedExecutionException，提示隊列已滿 (queued tasks = 10000)。
立即學習“Java免費學習筆記（深入）”；
異常原因：
AbortPolicy 拒絕策略導致異常。當所有線程繁忙且隊列已滿 (10000 個任務等待) 時，任何新任務都會被拒絕并拋出異常。這表明任務提交速度遠超線程池處理速度。
解決方案：
-
調整線程池參數： 增加核心線程數、最大線程數或隊列大小。但需謹慎，盲目增加線程數可能導致資源耗盡。需根據服務器資源和實際負載進行合理調整。增加隊列大小雖然能緩解問題，但可能增加任務延遲。
-
更換拒絕策略： 考慮更合適的拒絕策略，例如：
- CallerRunsPolicy：提交任務的線程直接執行任務，降低提交速度，避免任務堆積。
- DiscardPolicy 或 DiscardOldestPolicy：丟棄任務，但需根據業務場景評估是否可接受任務丟失。 選擇策略需權衡應用的容錯性需求。
-
優化任務處理邏輯： 分析任務處理效率，優化代碼以縮短任務執行時間。例如，考慮異步處理或批量處理以提高效率。
總結：
RejectedExecutionException 通常表示線程池配置與實際負載不匹配。通過調整線程池參數、選擇合適的拒絕策略以及優化任務處理邏輯，可以有效解決此問題。 需根據具體應用場景和性能要求選擇最優方案。
