Java多線程之線程池的手寫改造和拒絕策略

---

目錄

自定義線程池的使用

四種拒絕策略代碼體現

---

1. 自定義線程池的使用

---

自定義線程池（拒絕策略默認AbortPolicy）

public class MyThreadPoolDemo {public static void main(String[] args) {ExecutorService threadPool = new ThreadPoolExecutor(2,5,1L,TimeUnit.SECONDS,new LinkedBlockingQueue<Runnable>(3),Executors.defaultThreadFactory(),new ThreadPoolExecutor.AbortPolicy());try { // 模擬10個用戶來辦理業務，每個用戶就是一個來自外部的請求線程。for (int i = 1; i <= 5; i++) {threadPool.execute(() -> {System.out.println(Thread.currentThread().getName() + "\t 辦理業務");});}} catch (Exception e) {e.printStackTrace();} finally {threadPool.shutdown();}} }

當線程為5時執行結果：

---

2. 四種拒絕策略代碼體現

---

AbortPolicy(默認）：直接拋出RejectedExecutionException異常阻止系統正常運行。

當線程數為9時，拋出異常。

---

CallerRunsPolicy："調用者運行"一種調節機制，該策略既不會拋棄任務，也不會拋出異常，而是將某些任務回退到調用者，從而降低新任務的流量。

CallerRunsPolicy 拒絕策略，將線程變為10時執行結果

DiscardOldestPolicy：拋棄隊列中等待最久的任務，然后把當前任務加入隊列中嘗試再次提交當前任務。

DiscardOldestPolicy拒絕策略，將線程變為10時執行結果：

DiscardPolicy：直接丟棄任務，不予任何處理也不拋出異常。如果允許任務丟失，這是最好的一種方案。
DiscardPolicy拒絕策略，直接丟包，將線程變為10時執行結果：

---

總結

以上是生活随笔為你收集整理的Java多线程之线程池的手写改造和拒绝策略的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。