源碼分析Java中ThreadPoolExecutor的底層原理

更新時間：2023年05月07日 09:06:24 作者：向豬羊

這篇文章主要帶大家從源碼分析一下Java中ThreadPoolExecutor的底層原理，文中的示例代碼講解詳細，具有一定的學習價值，需要的可以參考一下

一、根據代碼查看jdk提供的3種線程池創(chuàng)建

public class TestController {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();//快
        ExecutorService executorService1 = Executors.newFixedThreadPool(10);//慢
        ExecutorService executorService2 = Executors.newSingleThreadExecutor();//很慢

        for (int i = 0; i < 100; i++) {
            executorService.execute(new MyTask(i));
        }
    }
}

class MyTask implements Runnable{
    private int i;

    public MyTask(int i) {
        this.i = i;
    }

    @Override
    public void run() {
        System.out.println(Thread.currentThread()+"-"+i);
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

在運行過程中可以發(fā)現(xiàn)3者速度有所差別，當然3者的速度要根據實際處理自行判別，此處只以此代碼業(yè)務為例。

二、3種方式源碼分析

1、Executors.newCachedThreadPool()

源碼參數為：

0,
Integer.MAX_VALUE,
60L,
TimeUnit.SECONDS,
new SynchronousQueue<Runnable>()

以下圖中的外包公司為例（結合圖觀看），corePoolSize為0，即核心員工數為0；maximumPoolSize為Integer.MAX_VALUE，即非核心員工數為2的31次方-1；且BlockingQueue為同步隊列。當任務進來后分配給隊列，通過隊列分配給非核心員工，下一個任務再進入隊列，以此循環(huán)執(zhí)行，直到任務執(zhí)行完成或者非核心員工都沒有空閑時，執(zhí)行拒絕策略。

2、Executors.newFixedThreadPool(10)

源碼參數為：

nThreads,
nThreads,
0L,
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()

以下圖中的外包公司為例（結合圖觀看），corePoolSize為10，即核心員工數為10；maximumPoolSize為10，即無非核心員工，且BlockingQueue為鏈表隊列，鏈表隊列最大數為2的31次方-1，若到達最大值后執(zhí)行拒絕策略。當任務進來后分配10個任務給10個核心員工，其余任務進入鏈表隊列，當核心員工有空閑時將鏈表隊列中的某任務給與空閑員工。以此循環(huán)執(zhí)行。

3、Executors.newSingleThreadExecutor()

源碼參數為：

1,
1,
0L,
TimeUnit.MILLISECONDS,
new LinkedBlockingQueue<Runnable>()

以下圖中的外包公司為例（結合圖觀看），corePoolSize為1，即核心員工數為1；maximumPoolSize為1，即無非核心員工，且BlockingQueue為鏈表隊列，鏈表隊列最大數為2的31次方-1，若到達最大值后執(zhí)行拒絕策略。當任務進來后分配1個任務給1個核心員工，其余任務進入鏈表隊列，當核心員工有空閑時將鏈表隊列中的某任務給與空閑員工。以此循環(huán)執(zhí)行。

三、自定義方式執(zhí)行

    public class TestController {
    public static void main(String[] args) {
        ExecutorService executorService = Executors.newCachedThreadPool();//快
        ExecutorService executorService1 = Executors.newFixedThreadPool(10);//慢
        ExecutorService executorService2 = Executors.newSingleThreadExecutor();//很慢
        ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(10, 20,
                                0L, TimeUnit.MILLISECONDS,
                                            new ArrayBlockingQueue<Runnable>(10));
        for (int i = 0; i < 100; i++) {
            threadPoolExecutor.execute(new MyTask(i));
        }
    }
}

運行結果如圖：