ThreadPoolExecutor线程池执行器

柔光的暖阳◎ 2023-06-11 06:29 30阅读 0赞

## ThreadPoolExecutor原理分析 ##

先看一下ThreadPoolExecutor构造器方法（参数最多的那个）

public ThreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  TimeUnit unit,
                                  BlockingQueue<Runnable> workQueue,
                                  ThreadFactory threadFactory,
                                  RejectedExecutionHandler handler) {
           //参数的初始化
           .......
        }

**参数解析：**

1.  corePoolSize ：线程池中的核心线程数
2.  maximumPoolSize：线程池允许的最大线程数，BlockingQueue满了，当线程池中的线程数< maximumPoolSize时，当有新的任务到来时，会继续创建新的线程去处理
3.  keepAliveTime：线程空闲下拉后，存活的时间，这个参数只在线程池中线程数量>corePoolSize才有效
4.  unit ： 存活时间单位值（秒，毫秒等）
5.  workQueue ： 保存任务的阻塞队列
6.  threadFactory：创建线程的工厂，给新建的线程赋予名字
7.  handler ： 任务饱和拒绝策略  
    AbortPolicy: 默认直接抛出异常；  
    CallerRunsPolicy: 用调用者所在的线程来执行任务；  
    DiscardOldestPolicy: 丢弃阻塞队列里面最老的任务，队列里面最靠前的任务；  
    DicardPolicy: 当前任务直接丢弃  
    当然我们也可以实现RejectedExecutionHandler接口来实现自己的饱和拒绝策略

**图解：**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RocXR6cQ_size_16_color_FFFFFF_t_70]

1.  当线程池中的线程（已开启的线程）个数 < corePoolSize时，每次进来新的任务，就启动一个线程去处理这个任务；
2.  当线程池中的线程个数 > corePoolSize时，这时每次进来的任务会加入到BlockingQueue队列中；
3.  当线程池中的线程个数 >= corePoolSize且< maximumPoolSize, 并且BlockingQueue队列也满了，这个时候再来新的任务时，就会继续创建新的线程去处理。这个时候创建的线程，当这些线程空闲下来的时候到keepAliveTime结束就会销毁；
4.  当线程池中的线程数 >= maximumPoolSize时，这个时候再来新的任务，就会执行拒绝策略。

[如何正确的创建线程池][Link 1]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3RocXR6cQ_size_16_color_FFFFFF_t_70]: /images/20230531/7eec73003ac540fa8f8fde5b4f167e51.png
[Link 1]: https://blog.csdn.net/yan88888888888888888/article/details/83927609