1、拒絕策略

1.1、拒絕策略是什么？

用于等待的阻塞隊(duì)列滿了，當(dāng)前運(yùn)行的線程數(shù)又已經(jīng)達(dá)到了maximumPoolSize，無法為新的任務(wù)服務(wù)，這個(gè)時(shí)候使用拒絕策略做出反饋。

1.2、JDK內(nèi)置的拒絕策略

1.2.1、AbortPolicy（默認(rèn)）

直接拋出RejectedExecutionException異常阻止系統(tǒng)的正常運(yùn)行

1.2.2、CallerRunsPolicy

“調(diào)用者運(yùn)行”一種調(diào)節(jié)機(jī)制，該策略既不會(huì)拋棄任務(wù)，也不會(huì)拋出異常，而是將某些任務(wù)回退到調(diào)用者，從而降低新任務(wù)的流量。

1.2.3、DiscardOldestPolicy

丟棄隊(duì)列中等待最久的任務(wù)

1.2.4、DiscardPolicy

直接丟棄任務(wù)，不予處理，也不拋出異常。如果允許任務(wù)丟失，這是最好的一種方案。

1.3、以上內(nèi)置的拒絕策略均實(shí)現(xiàn)了RejectExecutionHandler接口

2、工作中單一的、固定數(shù)的、可變的三種創(chuàng)建線程池的方法，用哪一個(gè)比較多？

哪一個(gè)都不要用

• 生產(chǎn)上只能使用自定義的。
• JDK中Executors已經(jīng)給你提供了，為什么不用？

阿里巴巴開發(fā)手冊：
一、編程規(guī)約（六）并發(fā)處理
3.【強(qiáng)制】線程資源必須通過線程池提供，不允許在應(yīng)用中自行顯式創(chuàng)建線程。
4.【強(qiáng)制】線程池不允許使用Executors去創(chuàng)建，而是通過ThreadPoolExecutor的方式，這樣的處理方式讓寫的同學(xué)更加明確線程池的運(yùn)行規(guī)則，規(guī)避資源耗盡的風(fēng)險(xiǎn)
說明：Executors返回的線程池對象弊端如下：
1）FixedThreadPool和SingleThreadPool：
允許的請求隊(duì)列長隊(duì)為Integer.MAX_VALUE，可能會(huì)堆積大量的請求，從而導(dǎo)致OOM。
2）CachedThreadPool和ScheduleThreadPool：
允許創(chuàng)建線程數(shù)量為Integer.MAX_VALUE，可能會(huì)創(chuàng)建大量的線程，從而導(dǎo)致OOM.

3、你在工作中是如何使用線程池的，是否自定義過線程池使用

package com.company;


import java.util.concurrent.*;

//第四種Java使用多線程的方式：使用線程池
public class MyThreadPoolDemo {
    public static void main(String[] args) {
        ExecutorService threadPool = new ThreadPoolExecutor(
                2,
                5,
                5,
                TimeUnit.SECONDS,
                new LinkedBlockingDeque<Runnable>(3),
                Executors.defaultThreadFactory(),
                //new ThreadPoolExecutor.AbortPolicy());
                //new ThreadPoolExecutor.CallerRunsPolicy());
                //new ThreadPoolExecutor.DiscardPolicy());
                new ThreadPoolExecutor.DiscardOldestPolicy());

        //模擬十個(gè)用戶，每一個(gè)用戶對應(yīng)一個(gè)外部請求
        try
        {
            for (int i = 1; i <= 10 ; i++) {
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"\t辦理業(yè)務(wù)");
                });
                //try{TimeUnit.MILLISECONDS.sleep(5);}catch (InterruptedException e){e.printStackTrace();}
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            threadPool.shutdown();
        }
    }
    public static void threadPoolInit()
    {
        //一池5線程，一個(gè)銀行有五個(gè)工作人員
        ExecutorService threadPool = Executors.newFixedThreadPool(5);//一池5線程
        ExecutorService threadPool1 = Executors.newSingleThreadExecutor();//一池1線程
        ExecutorService threadPool2 = Executors.newCachedThreadPool();//一池N線程，自動(dòng)適配線程個(gè)數(shù)

        //模擬十個(gè)用戶，每一個(gè)用戶對應(yīng)一個(gè)外部請求
        try
        {
            for (int i = 1; i <= 10 ; i++) {
                threadPool.execute(()->{
                    System.out.println(Thread.currentThread().getName()+"\t辦理業(yè)務(wù)");
                });
                //try{TimeUnit.MILLISECONDS.sleep(5);}catch (InterruptedException e){e.printStackTrace();}
            }
        }catch(Exception e){
            e.printStackTrace();
        }finally{
            threadPool.shutdown();
        }
    }
}