java 线程池数量_Java的四种线程池

小鱼儿 2022-11-03 11:56 300阅读 0赞

四种线程池

newCachedThreadPool：可缓存的线程池

newFixedThreadPool ：定长线程池

newSingleThreadExecutor ：单线程线程池

newScheduledThreadPool ：支持定时的定长线程池

下面对这几个线程池一一讲解。

一、newCachedThreadPool：可缓存的线程池

源码：

![153149480\_1\_20190129101937493][153149480_1_20190129101937493]

newCachedThreadPool的方法中是返回一个ThreadPoolExecutor实例，从源码中可以看出该线程池的特点：

1、该线程池的核心线程数量是0，线程的数量最高可以达到Integer 类型最大值；

2、创建ThreadPoolExecutor实例时传过去的参数是一个SynchronousQueue实例，说明在创建任务时，若存在空闲线程就复用它，没有的话再新建线程。

3、线程处于闲置状态超过60s的话，就会被销毁。

用法：

![153149480\_2\_20190129101937618][153149480_2_20190129101937618]

上面的代码因为每次循环都是隔一秒执行，这个时间足够之前的线程工作完毕，并在新循环中复用这个线程，程序的运行结果如下：

![153149480\_3\_20190129101937915][153149480_3_20190129101937915]

二、newFixedThreadPool：定长线程池

源码：

![153149480\_4\_20190129101938196][153149480_4_20190129101938196]

线程池特点：

1、线程池的最大线程数等于核心线程数，并且线程池的线程不会因为闲置超时被销毁。

2、使用的列队是LinkedBlockingQueue，表示如果当前线程数小于核心线程数，那么即使有空闲线程也不会复用线程去执行任务，而是创建新的线程去执行任务。如果当前执行任务数量大于核心线程数，此时再提交任务就在队列中等待，直到有可用线程。

用法：

![153149480\_5\_20190129101938368][153149480_5_20190129101938368]

定义一个线程数为3的线程池，循环10次执行，可以发现运行的线程永远只有三个，结果如下：

![153149480\_6\_20190129101938587][153149480_6_20190129101938587]

三、newSingleThreadExecutor：单线程线程池

源码：

![153149480\_7\_20190129101938852][153149480_7_20190129101938852]

从源码就可以看出，该线程池基本就是只有一个线程数的newFixedThreadPool，它只有一个线程在工作，所有任务按照指定顺序执行。

用法：

和newFixedThreadPool类似，只是一直只有一个线程在工作，这里就不贴代码了。

四、newScheduledThreadPool：支持定时的定长线程池

源码：

![153149480\_8\_201901291019398][153149480_8_201901291019398]

newScheduledThreadPool的方法不是直接返回一个ThreadPoolExecutor实例，而是通过有定时功能的ThreadPoolExecutor，也就是ScheduledThreadPoolExecutor 来返回ThreadPoolExecutor实例，从源码中可以看出：

1、该线程池可以设置核心线程数量，最大线程数与newCachedThreadPool一样，都是Integer.MAX\_VALUE。

2、该线程池采用的队列是DelayedWorkQueue，具有延迟和定时的作用。

用法：

![153149480\_9\_20190129101939290][153149480_9_20190129101939290]

自定义ThreadFactory

四种线程池的使用就说到这里了，值得说明的是，除了上面的参数外，Executors类中还给这四种线程池提供了可传ThreadFactory的重载方法，以下是它们的源码：

![153149480\_10\_20190129101939555][153149480_10_20190129101939555]

ThreadFactory是一个接口类，也就是我们经常说的线程工厂，只有一个方法，可以用于创建线程：

Thread newThread(Runnable r);

默认情况下，ThreadPoolExecutor构造器传入的ThreadFactory 参数是Executors类中的defaultThreadFactory()，相当于一个线程工厂，帮我们创建了线程池中所需的线程。在此我向大家推荐一个架构学习交流圈：830478757  帮助突破瓶颈 提升思维能力

除此之外，我们也可以自定义ThreadFactory，并根据自己的需要来操作线程，下面是实例代码：

![153149480\_11\_20190129101939821][153149480_11_20190129101939821]

运行代码后，控制行会输出五行 “我是线程java.util.concurrent.ThreadPoolExecutor。。。。。”的信息，也证明了我们自定义的ThreadFactory起到了作用。原文：https://blog.csdn.net/honghailiang888/article/details/51690711

[153149480_1_20190129101937493]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_1_20190129101937493
[153149480_2_20190129101937618]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_2_20190129101937618
[153149480_3_20190129101937915]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_3_20190129101937915
[153149480_4_20190129101938196]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_4_20190129101938196
[153149480_5_20190129101938368]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_5_20190129101938368
[153149480_6_20190129101938587]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_6_20190129101938587
[153149480_7_20190129101938852]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_7_20190129101938852
[153149480_8_201901291019398]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_8_201901291019398
[153149480_9_20190129101939290]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_9_20190129101939290
[153149480_10_20190129101939555]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_10_20190129101939555
[153149480_11_20190129101939821]: http://image109.360doc.com/DownloadImg/2019/01/2910/153149480_11_20190129101939821