Java线程池ThreadPoolExcutor

叁歲伎倆 2023-06-15 13:28 30阅读 0赞

### 1.线程池的工作原理： ###

![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hbWVuZzE5ODg_size_16_color_FFFFFF_t_70]

#### 1.1 线程池刚创建时，里面没有一个线程。任务队列是作为参数传进来的。不过，就算队列里面有任务，线程池也不会马上执行它们。 ####

#### 1.2 当调用execute()方法添加一个任务时，线程池会做如下判断： ####

a.如果正在运行的线程数小于corePoolSize，那么马上创建线程运行这个任务。
    b.如果正在运行的线程数大于或者等于corePoolSize,那么将这个任务放入队列。
    c.如果这个时候队列满了，而且正在运行的线程数量小于maximumPoolSize,那么还是要创建线程运行这个任务。
    d.如果队列满了，而且正在运行的线程数量大于或等于 maximumPoolSize，那么线程池会抛出异常，告诉调用者“我不能再接受任务了”

#### 1.3 当一个线程完成任务时，它会从队列中取下一个任务来执行。 ####

#### 1.4 当一个线程无事可做，超过一定的时间（keepAliveTime）时，线程池会判断，如果当前运行的线程数大于corePoolSize时，那么这个线程会被停用掉，所以线程池的所有任务完成后，它最终会收缩到corePoolSize的大小。 ####

### 2.线程池有哪些配置 ###

线程池可以使用java.util.concurrent.ThreadPoolExecutor来创建，在该类中包含最全参数的构造函数

public ThreadPoolExecutor(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  TimeUnit unit,
                                  BlockingQueue<Runnable> workQueue,
                                  ThreadFactory threadFactory,
                                  RejectedExecutionHandler handler)

1、maximumPoolSize:线程池最大线程数，表示在线程池中最多能创建多少个线程。如果当线程池中的数量到达这个数字时，
    新来的任务会抛出异常。
    2、keepAliveTime：表示线程没有任务执行时最多能保持多少时间会停止，然后线程池的数目维持在corePoolSize。
    3、unit:参数keepAliveTime的时间单位
    4、workQueue:一个阻塞队列，用来存储等待执行的任务，如果当前对线程的需求超过了5、corePoolSize大小，才会放在这里。
    6、threadFactory:线程工厂，主要用来创建线程，比如指定线程的名字。
    7、handler:如果线程池已满，新的任务处理方式。

### 3.线程池的阻塞队列包含哪几种选择 ###

1. ArrayBlockingQueue
    2. LinkedBlockingQueue
    3. PriorityBlockingQueue
    4. SynchronousQueue

1. ArrayBlockingQueue是一个有边界的阻塞队列，它的内部实现是一个数组。它的容量在初始化时就确定不变。
    2. LinkedBlockingQueue：阻塞队列大小的配置是可选的，其内部实现是一个链表。
    3. PriorityBlockingQueue：是一个没有边界的队列，所有插入到PriorityBlockingQueue的对象必须实现
    java.lang.Comparable接口，队列优先级的排序就是按照我们对这个接口的实现来定义的。
    4. SynchronousQueue队列内部仅允许容纳一个元素。当一个线程插入一个元素后会被阻塞，除非这个元素被另一个线程消费。

### 4.如果线程池已经满了可是还有新的任务提交怎么办 ###

线程池已经满的定义，是指运行线程数 == maximumPoolSize,并且workQueue是有界队列并且已满。
    这时候再提交任务怎么办呢？线程池会将任务传递给最后一个参数RejectedExecutionHandler来处理，
    比如打印报错日志、抛出异常、存储到Mysql/redis用于后续处理等等，线程池默认也提供了几种处理方式；

参考：1、[https://blog.csdn.net/wojiushiwo945you/article/details/41944291][https_blog.csdn.net_wojiushiwo945you_article_details_41944291]  
2、[拒绝策略][Link 1]  
3、[https://blog.csdn.net/yanluandai1985/article/details/82423767][https_blog.csdn.net_yanluandai1985_article_details_82423767]

#### 欢迎关注我的微信公众号，不定期更新文章和大家一起学习共勉 ####

![在这里插入图片描述][2019121114380610.png]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hbWVuZzE5ODg_size_16_color_FFFFFF_t_70]: https://img-blog.csdnimg.cn/20191122172918614.png?x-oss-process=image/watermark,type_ZmFuZ3poZW5naGVpdGk,shadow_10,text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L21hbWVuZzE5ODg=,size_16,color_FFFFFF,t_70
[https_blog.csdn.net_wojiushiwo945you_article_details_41944291]: https://blog.csdn.net/wojiushiwo945you/article/details/41944291
[Link 1]: https://mp.weixin.qq.com/s?__biz=MzU2NzY3MjU4NA==&mid=2247487620&idx=1&sn=becb47f1f02cd04a5331a0fa37d0aefd&chksm=fc98fae3cbef73f5cde3551f559ad6a43d7ec93b418fa987612410fa50a55f8236110121800e&scene=0&xtrack=1&key=38da6f0e83e9a2aa9e347befb29df2654fe7bf61217108b3c485df2ae0992462ddb25b65ea3d78ffe6d0b65da1d83f8dc6b786f2433e0c927bc41e21f9929edc02656e6dd61fb2c365c3e869578ebbdb&ascene=1&uin=MzQ3ODIzNzgzNA==&devicetype=Windows%2010&version=62070158&lang=zh_CN&pass_ticket=F3joByIcVp6Y1aKsS59//VnK8cOYGUuGJefDGxHNpj3HQNGtMz6nl6qQKRI0CdYW
[https_blog.csdn.net_yanluandai1985_article_details_82423767]: https://blog.csdn.net/yanluandai1985/article/details/82423767
[2019121114380610.png]: https://img-blog.csdnimg.cn/2019121114380610.png