起源：blog.csdn.net/dabusiGin/article/details/105327873/
Executor是不倡议的
Executors类为咱们提供了各种类型的线程池，常常应用的工厂办法有：
public static ExecutorService newSingleThreadExecutor()public static ExecutorService newFixedThreadPool(int nThreads)public static ExecutorService newCachedThreadPool()public static ScheduledExecutorService newSingleThreadScheduledExecutor()public static ScheduledExecutorService newScheduledThreadPool(int corePoolSize)书写一段很简略的测试代码：
public class ThreadDemo { public static void main(String[] args) { ExecutorService es = Executors.newSingleThreadExecutor(); }}当咱们用阿里巴巴的P3C查看代码时，会被教育的！！！！
阿里爸爸是不容许这么创立线程池的，下面的正告写的很明确“线程池不容许应用Executors去创立，而是通过ThreadPoolExecutor的形式，这样的解决形式让写的同学更加明确线程池的运行规定，躲避资源耗尽的危险。”（PS：很难得在编译器中看到中文提醒，对于英语不好的同学来说，几乎是福音，喜极而泣！！！！）
强制应用ThreadPoolExecutor
咱们应用ThreadPoolExecutor创立线程池：
public class ThreadDemo { public static void main(String[] args) { ExecutorService es = new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>(10), Executors.defaultThreadFactory(), new ThreadPoolExecutor.DiscardPolicy()); }}此时，再用P3C查看代码，终于没有报错了。
在富丽的分隔符之后，咱们还是有必要从JDK源码的层面深挖一下其中的原理。
首先是静态方法newSingleThreadExecutor()、newFixedThreadPool(int nThreads)、newCachedThreadPool()。咱们来看一下其源码实现（基于JDK8）。
public static ExecutorService newSingleThreadExecutor() { return new FinalizableDelegatedExecutorService (new ThreadPoolExecutor(1, 1, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>()));}public static ExecutorService newFixedThreadPool(int nThreads) { return new ThreadPoolExecutor(nThreads, nThreads, 0L, TimeUnit.MILLISECONDS, new LinkedBlockingQueue<Runnable>());}public static ExecutorService newCachedThreadPool() { return new ThreadPoolExecutor(0, Integer.MAX_VALUE, 60L, TimeUnit.SECONDS, new SynchronousQueue<Runnable>());}通过查看源码咱们晓得上述三种静态方法的外部实现均应用了ThreadPoolExecutor类。难怪阿里爸爸会倡议通过ThreadPoolExecutor的形式实现，原来Executors类的静态方法也是用的它，只不过帮咱们配了一些参数而已。
第二是ThreadPoolExecutor类的构造方法。既然当初要间接应用ThreadPoolExecutor类了，那么其中的初始化参数就要咱们本人配了，理解其构造方法势在必行。
ThreadPoolExecutor类一共有四个构造方法，咱们只须要理解之中的一个就能够了，因为其余三种构造方法只是帮咱们配置了一些默认参数，最初还是调用了它。
public ThreadPoolExecutor(int corePoolSize, int maximumPoolSize, long keepAliveTime, TimeUnit unit, BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, RejectedExecutionHandler handler)其中的参数含意是：
corePoolSize：线程池中的线程数量；maximumPoolSize：线程池中的最大线程数量；keepAliveTime：当线程池线程数量超过corePoolSize时，多余的闲暇线程会在多长时间内被销毁；unit：keepAliveTime的工夫单位；workQueue：工作队列，被提交然而尚未被执行的工作；threadFactory：线程工厂，用于创立线程，个别状况下应用默认的，即Executors类的静态方法defaultThreadFactory()；handler：回绝策略。当工作太多来不及解决时，如何回绝工作。
对于这些参数要有以下理解：
corePoolSize与maximumPoolSize的关系
首先corePoolSize必定是 <= maximumPoolSize。
其余关系如下：
- 若以后线程池中线程数 < corePoolSize，则每来一个工作就创立一个线程去执行；
- 若以后线程池中线程数 >= corePoolSize，会尝试将工作增加到工作队列。如果增加胜利，则工作会期待闲暇线程将其取出并执行；
- 若队列已满，且以后线程池中线程数 < maximumPoolSize，创立新的线程；
- 若以后线程池中线程数 >= maximumPoolSize，则会采纳回绝策略（JDK提供了四种，上面会介绍到）。
留神：关系3是针对的有界队列，无界队列永远都不会满，所以只有前2种关系。
workQueue
参数workQueue是指提交但未执行的工作队列。若以后线程池中线程数>=corePoolSize时，就会尝试将工作增加到工作队列中。次要有以下几种：
SynchronousQueue：间接提交队列。SynchronousQueue没有容量，所以实际上提交的工作不会被增加到工作队列，总是将新工作提交给线程执行，如果没有闲暇的线程，则尝试创立新的线程，如果线程数量曾经达到最大值（maximumPoolSize），则执行回绝策略。LinkedBlockingQueue：无界的工作队列。当有新的工作来到时，若零碎的线程数小于corePoolSize，线程池会创立新的线程执行工作；当零碎的线程数量等于corePoolSize后，因为是无界的工作队列，总是能胜利将工作增加到工作队列中，所以线程数量不再减少。若工作创立的速度远大于工作解决的速度，无界队列会快速增长，直到内存耗尽。
handler
JDK内置了四种回绝策略：
DiscardOldestPolicy策略：抛弃工作队列中最早增加的工作，并尝试提交当前任务；CallerRunsPolicy策略：调用主线程执行被回绝的工作，这提供了一种简略的反馈管制机制，将升高新工作的提交速度。DiscardPolicy策略：默默抛弃无奈解决的工作，不予任何解决。AbortPolicy策略：间接抛出异样，阻止零碎失常工作。
至此，咱们间接new ThreadPoolExecutor类就不必慌了！！！！
近期热文举荐：
1.1,000+ 道 Java面试题及答案整顿(2022最新版)
2.劲爆！Java 协程要来了。。。
3.Spring Boot 2.x 教程，太全了！
4.别再写满屏的爆爆爆炸类了，试试装璜器模式，这才是优雅的形式！！
5.《Java开发手册（嵩山版）》最新公布，速速下载！
感觉不错，别忘了顺手点赞+转发哦！