如何创建线程池[通俗易懂]

全栈程序员-站长 • 2022年10月1日下午4:16 • 未分类 • 阅读 1

大家好，又见面了，我是你们的朋友全栈君。如果您正在找激活码,请点击查看最新教程,关注关注公众号 “全栈程序员社区” 获取激活教程,可能之前旧版本教程已经失效.最新Idea2022.1教程亲测有效,一键激活。

Jetbrains全系列IDE稳定放心使用

在开发中有时候会需要异步操作，这个时候就需要自己写个线程，但是每次都需要重复写代码非常不方便也不安全，所以线程池就是更好的选择。那么如何创建一个线程池呢？

首先会想到使用Executors创建线程池，因为这是java中的工具类，提供工厂方法来创建不同类型的线程池。
在这里插入图片描述
从上图中也可以看出，Executors的创建线程池的方法，创建出来的线程池都实现了ExecutorService 接口。常用方法有以下几个：
newFiexedThreadPool(int Threads)：创建固定数目线程的线程池。

newCachedThreadPool()：创建一个可缓存的线程池，调用execute 将重用以前构造的线程（如果线程可用）。如果没有可用的线程，则创建一个新线程并添加到池中。终止并从缓存中移除那些已有 60 秒钟未被使用的线程。

newSingleThreadExecutor() 创建一个单线程化的Executor。

newScheduledThreadPool(int corePoolSize) 创建一个支持定时及周期性的任务执行的线程池，多数情况下可用来替代Timer类。

类看起来功能还是比较强大的，又用到了工厂模式、又有比较强的扩展性，重要的是用起来还比较方便，如：

ExecutorService executor = Executors.newFixedThreadPool(nThreads) ;

即可创建一个固定大小的线程池。虽然看起来很美好，却不鼓励大家使用。甚至在阿里Java 开发手册中是禁止使用的。
在这里插入图片描述
可以看出，不仅禁止使用，也给出了禁止使用的理由：就是Executors创建的线程其队列长度和允许创建的线程数太大了，可能导致内存溢出。既然知道了原因，那么我们创建线程池的时候指定堵塞队列长度和最大线程数不就好了？是的，所以开发手册也给出了解决方案，避免使用Executors创建线程池，主要是避免使用其中的默认实现，那么我们可以自己直接调用ThreadPoolExecutor的构造函数来自己创建线程池。在创建的同时，给BlockQueue 指定容量就可以了。如下：

private static ExecutorService executor = new ThreadPoolExecutor(10, 20,
60L, TimeUnit.SECONDS,
new ArrayBlockingQueue(10));

接下来看看该构造方法：

    public ThreadPoolExecutor(int corePoolSize,
                              int maximumPoolSize,
                              long keepAliveTime,
                              TimeUnit unit,
                              BlockingQueue<Runnable> workQueue) { 
   
        this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
             Executors.defaultThreadFactory(), defaultHandler);
    }