線程池ThreadPoolExecutor分析: 線程池是什么時候創建線程的，隊列中的任務是什么時候取出來的？

本文轉載自查看原文 2018-12-15 10:28 4399 java jdk

帶着幾個問題進入源碼分析:

1. 線程池是什么時候創建線程的？

2. 任務runnable task是先放到core到maxThread之間的線程，還是先放到隊列？

3. 隊列中的任務是什么時候取出來的？

4. 什么時候會觸發reject策略？

5. core到maxThread之間的線程什么時候會die?

6. task拋出異常，線程池中這個work thread還能運行其他任務嗎?

先寫一段基礎代碼，進入分析

public static void main(String[] args) {

        ExecutorService executorService = new ThreadPoolExecutor(2, 5, 0, TimeUnit.DAYS,
                new ArrayBlockingQueue<>(1), new ThreadFactory() {
            @Override
            public Thread newThread(Runnable r) {
                Thread thread = new Thread(r);
//                thread.setDaemon(true);
                return thread;
            }
        });
        // 對象創建后，線程實際還沒開始創建

        // 執行execute時，檢查當前池中線程數大小是否小於core number, 如果是，則創建新線程
        executorService.execute(() -> {
            System.out.println("任務1@" + Thread.currentThread().getName());
            sleepTime();
            System.out.println(1);
        });

        //檢查當前池中線程數大小是否小於core number, 如果是，則創建新線程
        executorService.execute(() -> {
            System.out.println("任務2@" + Thread.currentThread().getName());
            sleepTime();
            System.out.println(2);
        });

        // 檢查當前池中線程數大小是否小於core number, 如果不是，則償試放入隊列
        // 這個任務是加到隊列去的, 注意隊列大小只有1，
        // TODO 隊列中的任務是什么時候取出來的？   任務1或者2結束后所占用的線程 會運行隊列中的任務，這個任務是在最后才運行，比4運行的還晚
        executorService.execute(() -> {
            System.out.println("任務3@" + Thread.currentThread().getName());
            sleepTime();
            System.out.println(3);
        });

        // 檢查當前池中線程數大小是否小於core number, 如果不是,則償試放入隊列,放入隊列也失敗，則增加新的worker線程
        // 這個任務是加到core以外的新線程去的
        executorService.execute(() -> {
            System.out.println("任務4@" + Thread.currentThread().getName());
            sleepTime();
            System.out.println(4);
        });
    }

注意第3行，創建一個核心池2, 最大池5, 隊列為1的線程池

至少在new ThreadPoolExecutor()時，Thread對象並沒有初始化. 這里僅僅指定了幾個初始參數