在Java中創建自定義線程池需使用threadpoolexecutor類。1. 設置corepoolsize為核心線程數，maximumpoolsize為最大線程數，keepalivetime為空閑線程超時時間，unit為時間單位，workqueue為任務隊列，threadfactory（可選）用于創建線程，handler為拒絕策略。2. 常用任務隊列包括linkedblockingqueue、arrayblockingqueue和synchronousqueue。3. 拒絕策略有abortpolicy（默認）、callerrunspolicy、discardoldestpolicy和discardpolicy。4. 關閉線程池建議使用shutdown()配合awaittermination()確保任務完成，必要時調用shutdownnow()強制停止。合理配置參數可提升性能并避免資源浪費。
在Java中創建一個自定義線程池，主要是通過java.util.concurrent包中的ThreadPoolExecutor類來實現。它允許你靈活地配置核心線程數、最大線程數、空閑線程存活時間、任務隊列以及拒絕策略等參數。
下面是一些關鍵點和建議，幫助你更好地理解和使用自定義線程池。
確定線程池的基本參數
創建線程池時，最常用的方式是使用ThreadPoolExecutor的構造函數。你需要明確以下幾個關鍵參數：
立即學習“Java免費學習筆記（深入）”；
- corePoolSize：核心線程數，即使線程處于空閑狀態也不會被銷毀（除非設置了allowCoreThreadTimeOut）。
- maximumPoolSize：最大線程數，線程池允許的最大并發線程數量。
- keepAliveTime：非核心線程空閑后的超時時間。
- unit：keepAliveTime的時間單位。
- workQueue：用于存放待執行任務的阻塞隊列。
- threadFactory（可選）：用于創建新線程的工廠。
- handler：拒絕策略，當任務無法提交時采取的動作。
示例代碼：
ThreadPoolExecutor executor = new ThreadPoolExecutor( 2, // corePoolSize 4, // maximumPoolSize 60, // keepAliveTime TimeUnit.SECONDS, new LinkedBlockingQueue<>(100), // workQueue new ThreadPoolExecutor.AbortPolicy()); // handler
合理選擇任務隊列和拒絕策略
任務隊列決定了任務如何排隊等待執行。常用的有：
- LinkedBlockingQueue：無界或有界的鏈表結構隊列。
- ArrayBlockingQueue：有界數組結構隊列。
- SynchronousQueue：不存儲元素的隊列，每個插入操作必須等到另一個線程調用移除操作。
拒絕策略決定當線程池和隊列都滿時如何處理新任務：
- AbortPolicy（默認）：拋出異常。
- CallerRunsPolicy：由調用線程自己執行任務。
- DiscardOldestPolicy：丟棄隊列中最老的任務。
- DiscardPolicy：靜默丟棄任務。
如果你希望系統在這種情況下優雅降級，可以選擇CallerRunsPolicy，這樣主線程會稍微“慢下來”，而不是直接崩潰。
注意線程池的關閉方式
使用完線程池后，應該主動關閉它以釋放資源。常見的方法有兩個：
- shutdown()：不再接受新任務，但已提交的任務會繼續執行。
- shutdownNow()：嘗試立即停止所有任務，返回尚未開始執行的任務列表。
建議在程序結束前調用shutdown()，并配合awaitTermination()等待任務完成：
executor.shutdown(); try { if (!executor.awaitTermination(60, TimeUnit.SECONDS)) { executor.shutdownNow(); } } catch (InterruptedException e) { executor.shutdownNow(); }
這種方式可以避免任務被意外中斷，也能確保資源正常釋放。
基本上就這些。創建一個自定義線程池并不復雜，但要根據實際業務場景合理設置參數，才能發揮最佳性能。
