线程池ThreadPoolExecutor分析: 线程池是什么时候创建线程的，队列中的任务是什么时候取出来的？

客官°小女子只卖身不卖艺 2022-03-11 07:12 132阅读 0赞

带着几个问题进入源码分析:

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对象并没有初始化. 这里仅仅指定了几个初始参数

![1281466-20181215101721202-1181042592.png][]

执行第一个execute时，进入调试jdk源码

![1281466-20181215103807422-917915153.png][]代码块1

第一个if， 判断如果当前线程数小于corePoolSize, 则创建新的核心worker对象（Worker中指向Thread对象，保持引用，保证不会被GC回收）

我们的示例代码中，第1和第2个任务都是这样创建出线程的

第二个if,   判断如果当前线程数大于corePoolSize, 并偿试放入队列 workQueue.offer(command) , 放入成功后等待线程池调度【见后面的getTask()】

示例代码中，第3个任务是这样等待调度的，最后才执行

第三个if,  偿试放入队列 workQueue.offer(command) 失败， 增加一个非core的线程

示例代码中，第4个任务是这样开始的

然后再看addWorker（）的过程

![1281466-20181215112815685-1589665714.png][]

new Worker构造和线程启动

![1281466-20181215120113659-1790939901.png][]

线程启动后，又做了哪些工作：

![1281466-20181215122925271-895417465.png][]

异常分析

没抛异常时，此线程会一直在while（task !=null || (task = getTask())!=null）中跑

那么有异常时，再看一下processWorkerExit

![1281466-20181215125752761-1528165720.png][]

可以 看出，有异常时 旧的worker会被删除（GC回收），再创建新的Worker， 即有异常时 旧worker不可能再执行新的任务

总结：

Q. 线程池是什么时候创建线程的？

*A.任务提交的时候*

Q.任务runnable task是先放到core到maxThread之间的线程，还是先放到队列？

*A.先放队列!!!*

Q. 队列中的任务是什么时候取出来的？

A. worker中 runWorker() 一个任务完成后，会取下一个任务

Q. 什么时候会触发reject策略？

A.队列满并且maxthread也满了， 还有新任务，默认策略是reject

Q. core到maxThread之间的线程什么时候会die?

A.  没有任务时，或者抛异常时。

core线程也会die的，core到maxThread之间的线程有可能会晋升到core线程区间，

core max只是个计数，线程并不是创建后就固定在一个区间了

Q. task抛出异常，线程池中这个work thread还能运行其他任务吗?

A. 不能。 但是会创建新的线程, 新线程可以运行其他task。

对于 schedulerThreadPoolExecutor?   虽然有新线程，但是旧的循环任务不会再继续执行了， 开发实践推荐任务中捕获所有Exception

[1281466-20181215101721202-1181042592.png]: /images/20220311/660cdd43f82949deb86a65d37f7838c3.png
[1281466-20181215103807422-917915153.png]: /images/20220311/1621f50c022c4f22af54d18fbbbb21b6.png
[1281466-20181215112815685-1589665714.png]: /images/20220311/351fe12fbcbb44cc8d454afa1732fec5.png
[1281466-20181215120113659-1790939901.png]: /images/20220311/8f25a02bb566492ca30b5170a016ef0a.png
[1281466-20181215122925271-895417465.png]: /images/20220311/0e5204d59dd6490c8d438a21008acc62.png
[1281466-20181215125752761-1528165720.png]: /images/20220311/a6eac60974434c5eb50ff2f8eacf9cc9.png