線程池ThreadPoolExecutor分析: 線程池是何時建立線程的，隊列中的任務是何時取出來的？

時間 2019-11-20

標籤線程 threadpoolexecutor 分析何時建立隊列任務取出來的简体版

原文原文鏈接

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

1. 線程池是何時建立線程的？java

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

3. 隊列中的任務是何時取出來的？源碼分析

4. 何時會觸發reject策略？spa

5. core到maxThread之間的線程何時會die?線程

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

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

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對象並無初始化. 這裏僅僅指定了幾個初始參數blog