Q: 什麼時候需要使用拒絕策略呢？
A: 當任務數量超過系統實際承載能力的時候就要用到拒絕策略了，可以說它是系統超負荷執行的補救措施。簡言之，就是執行緒用完，佇列已滿，無法為新任務服務，則需一套機制來合理的處理這些問題。

JDK 提供了四種內建拒絕策略，我們要理解並記住，有如下的四種：
1、DiscardPolicy: 默默丟棄無法處理的任務，不予任何處理
2、DiscardOldestPolicy: 丟棄佇列中最老的任務, 嘗試再次提交當前任務
3、AbortPolicy: 直接拋異常，阻止系統正常工作。
4、CallerRunsPolicy: 將任務分給呼叫執行緒來執行,運行當前被丟棄的任務，這樣做不會真的丟棄任務，但是提交的執行緒效能有可能急劇下降。

以下是我們通常的使用方式：

int corePoolSize = 1;
int maximumPoolSize = 1;
BlockingQueue queue = new  ArrayBlockingQueue<Runnable>(1);
ThreadPoolExecutor pool = new ThreadPoolExecutor(corePoolSize,  maximumPoolSize,0, TimeUnit.SECONDS, queue ) ;
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardPolicy ());
pool.setRejectedExecutionHandler(new
 
 ThreadPoolExecutor.AbortPolicy());
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.DiscardOldestPolicy());
pool.setRejectedExecutionHandler(new ThreadPoolExecutor.CallerRunsPolicy());

但有時候我們需要對改介面進行擴充套件，來滿足特別的需求就需要自定義了。

拒絕策略的介面實現

public interface RejectedExecutionHandler {
    void rejectedExecution(Runnable r, 
    ThreadPoolExecutor executor);
}
 

自定義拒絕策略的程式碼示例

public class RejectThreadPoolDemo {
    public static class MyTask implements Runnable {
        @Override
        public void run() {
            System.out.println(System.currentTimeMillis()
                    + ":Thread ID:" + Thread.currentThread().getId());
            try {
                Thread.sleep(100);
            } catch (InterruptedException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String args[]) throws InterruptedException {
        MyTask myTask = new MyTask();

        ExecutorService executorService = new ThreadPoolExecutor(5, 5, 0L,
            TimeUnit.SECONDS, 
            new LinkedBlockingDeque<Runnable>(10),   
            Executors.defaultThreadFactory()
                , new RejectedExecutionHandler() {
            @Override
            public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {
                //列印丟棄的任務
                System.out.println(r.toString() + " is discard");
            }
        });
        for (int i = 0; i < 100; i++) {
            executorService.submit(myTask);
            Thread.sleep(10);
        }
    }
}

上面自定義了一個執行緒池有5個常駐執行緒，最大執行緒數量也是5個，等待佇列設為10，同時在這裡自定義了拒絕策略，列印被丟棄的任務資訊。

輸出如下：
[email protected] is discard
[email protected] is discard
[email protected] is discard
[email protected] is discard
1528709221737:Thread ID:10
1528709221752:Thread ID:11

思考：

1. Java中有哪些無界佇列和有界佇列？
2. 為什麼生產上不能使用無界佇列？

下一次分享讓我們探討一下有界、無界佇列對ThreadPoolExcutor執行的影響，歡迎小夥伴們留言討論~~