在 java 中，线程池 ThreadPoolExecutor 是一个绕不过去的类，它是享元模式思想的体现，通过在容器中创建一定数量的线程加以重复利用，从而避免频繁创建线程带来的额外开销。一个设置合理的线程池可以提高任务响应的速度，并且避免线程数超过硬件能力带来的意外情况。
上一篇文章讲了有关线程池的一些简单的用法，这篇文章主要是从源码的角度进一步带大家了解线程池的工作流程和工作原理。
ThreadPoolExecutor 是 Java 中 java.util.concurrent 包提供的一个强大的线程池实现。它提供了多种构造方法，但最常用的构造函数如下：
我们知道应用停机时需要释放资源，关闭连接，而对于一些定时任务或者网络请求服务会使用线程池，当应用停机时我们需要正确安全的关闭线程池，如果处理不当，可能造成数据丢失，业务请求结果不正确等问题。
上篇文章 ShutdownHook- Java 优雅停机解决方案 提到应用停机时需要释放资源，关闭连接。对于一些定时任务或者网络请求服务将会使用线程池，当应用停机时需要正确安全的关闭线程池，如果处理不当，可能造成数据丢失，业务请求结果不正确等问题。
线程池能够帮助我们提高系统资源利用效率，并简化线程管理。通过并发包下的Executors（不是Executor）可以方便的创建如下几类线程池。分别为：
多线程编程中，为每个任务分配一个线程是不现实的，线程创建的开销和资源消耗都是很高的。线程池应运而生，成为我们管理线程的利器。Java 通过Executor接口，提供了一种标准的方法将任务的提交过程和执行过程解耦开来，并用Runnable表示任务。
1、线程是稀缺资源，使用线程池可以减少创建和销毁线程的次数，每个工作线程都可以重复使用。
ThreadPoolExecutor是jdk提供的线程池的服务类，基于ThreadPoolExecutor可以很容易将一个实现Runnable接口的任务放入线程池中执行，下面是ThreadPoolExecutor实现：
tips：这样的设计方案，可以避免频繁的线程创建，大部分的工作任务都会停留在第二步。
ThreadPoolExecutor继承AbstractExecutorService，层级实现了ExecutorService，ExecutorService继承了Executor
在【JAVA】一个线程两次调用 start() 方法会出现什么情况？中介绍过线程是不能够重复启动的，创建或销毁线程存在一定的开销，所以利用线程池技术来提高系统资源利用效率，并简化线程管理，已经是非常成熟的选择。
Java的线程与操作系统的线程一一对应，每创建一个Java线程对象，操作系统会负责创建与之对应的系统线程。线程是操作系统中宝贵的资源，创建和销毁非常昂贵且低效。（目前JDK19已经出现了虚拟线程-Virtual Threads 预览版 )。
线程是稀缺资源，如果无限制地创建，不仅会消耗系统资源，还会降低系统的稳定性，使用线程池可以进行统一分配、调优和监控
线程池应该是Web容器中必不可少的组件了，因为每一个请求我们都需要通过对应的线程来处理，所以线程资源是非常重要的，如果管理不好系统的性能会急剧下降。所以重要性不言而喻。来看看它的有点吧。
一般开发者是利用 Executors 提供的统一线程创建方法，取创建不同配置的线程池，主要区别在于不同的 ExecutorService类型或者不同的初始参数。
Java 7 引入了一种新的并发框架—— Fork/Join Framework。同时引入了一种新的线程池：ForkJoinPool（ForkJoinPool.coomonPool）
Fork/Join框架中两个核心类ForkJoinTask与ForkJoinPool,声明ForkJoinTask后,将其加入ForkJoinPool中,并返回一个Future对象。 ForkJoinPool:ForkJoinTask需要通过ForkJoinPool来执行,任务分割的子任务会添加到当前工作维护的双端队列中,进入队列的头部。当一个工作线程的队列里暂时没有任务时,它会随机从其它工作线程的队列尾部获取一个任务。 ForkJoinTask:我们需要使用ForkJoin框架,首先要创建一个ForkJo
线程池的核心实现类,基于ThreadPoolExecutor可以实现满足不同场景的线程池
本文来源：http://yeming.me/2016/05/07/threadPool1/
创建线程池要使用手动方式，自动创建线程使用newFixedThreadPool和newCachedThreadPool可能因为资源耗尽导致OOM问题。
ThreadPoolExecutor线程池是并发编程中用的比较多的一个类，项目和面试的时候经常会用到，所以了解一下是很有必要的。
上一篇我们介绍了线程池的使用，这一篇我们接着分析下线程池的实现原理。首先从创建线程池的核心类ThreadPoolExecutor类说起。
软件开发活动中，我们经常会听到数据库连接池、内存池、线程池等各种“池”概念，这些“池”到底是什么东西呢？程序的世界里，我们可以将池简单的理解为一种容器类数据结构，比如列表。程序处理信息的过程中，可能会依赖某些资源或者对象(暂且统一称之为对象)，比如数据库连接，来执行一些高频操作，比如数据表查询，此时，如果被依赖对象的存活时间比较短，那就意味着需要频繁的创建和销毁对象，这可能会很耗时、耗系统资源(CPU、内存、磁盘、网络等)。为了解决这个问题，进行程序设计时，可能会考虑在程序初始化时，预先创建一批所需对象，并存储到池中，或者根据需要即时创建对象，并在使用完成后，将对象添加到池中，这样，当程序需要(再次)使用对象时，可以直接从池中直接获取现有的对象，节省了频繁创建和销毁对象带来的资源浪费，这就是池的作用，为程序提供复用对象或者提前分配资源的能力。
多余的空闲线程的存活时间。当空闲时间达到keepAliveTime时，多余的线程将被销毁，直至只剩下corePoolSize的数量为止。
其实早在19年，就简单的写过ThreadPoolExecutor. 但是只涉及到了其中两个参数，理解也不深刻，今天重新看一下代码。
1. 线程池的原理 线程池优点： 降低资源消耗 提高响应速度 提高线程可管理性 线程池流程 判断核心线程池中线程是否都在执行任务，否则创建新工作线程，是则进入下一步 判断工作队列是否已满，否则提交新的任务存储在这个工作队列里，是则进入下一步 判断线程池中的线程是否都处于工作状态，否则创建一个新的工作线程来执行任务，是则交给饱和策略来处理这个任务 ThreadPoolExecutor执行execute方法有4中情况： 当前运行线程少于corePoolSize，创建新线程执行任务（需要全局锁）
线程池的作用是为了解决频繁创建和销毁线程的性能问题，类似的有MySQL连接池。
通常开发者都是利用 Executors 提供的通用线程池创建方法，去创建不同配置的线程池，主要区别在于不同的 ExecutorService 类型或者不同的初始参数。
java中的线程池是运用场景最多的并发框架，几乎所有需要异步或并发执行任务的程序都可以使用线程池。在开发过程中，合理使用线程池能够带来三个好处。
源码分析：上面的流程分析让我们很直观的了解的线程池的工作原理，让我们再通过源代码来看看是如何实现的。线程池执行任务的方法如下：
jdk中关于线程池一个比较核心的类是ThreadPoolExecutor,先来看一下他的实现.
Android中，系统为我们提供了4种标准线程池: FixedThreadPool SingleThreadExecutor CachedThreadPool ScheduledThreadPool 但是，需求是无止境的，我们总是会有一些需求，4种线程池都不能非常完美的满足到。所以，我们需要自己配置线程池。不难发现，4个标准线程池都是由ThreadPoolExecutor配置不同的参数生成的，所以我们通过阅读一下ThreadPoolExecutor的源码来学习如何建立自己的线程池。 有意思的是，Thread
线程池是并发编程中一个重要的概念和技术。大多数异步或并发执行任务都会用到线程池。 线程池，正如其名，它是有一定数量的线程的池子，它会执行被提交过来的任务，执行完一个任务后不会马上结束，它们会继续等待或执行新的任务。线程池有两个重要的概念一个是任务队列,另一个是工作者线程 。任务队列是存放任务的容器，工作者线程会依次不断地到队列中获取任务并执行。
默认情况下，即使核心线程最初只是在新任务需要时才创建和启动的，也可以使用方法 prestartCoreThread()或 prestartAllCoreThreads() 对其进行动态重写。
在J.U.C之executors框架：executors框架设计理念的章节中，我们已经简要介绍过ThreadPoolExecutor了，通过Executors工厂，用户可以创建自己需要的执行器对象。ThreadPoolExecutor，它是J.U.C在JDK1.5时提供的一种实现了ExecutorService接口的执行器，或者说线程池。
在我们的开发中“池”的概念并不罕见，有数据库连接池、线程池、对象池、常量池等等。下面我们主要针对线程池来一步一步揭开线程池的面纱。
随着在硬件上多核处理器的发展和广泛使用，并发编程成为程序员必须掌握的一门技术，在面试中也经常考查面试者并发相关的知识。
我们可以使用executor向线程池提交任务，但是此种方式没有返回值，无法判断任务是否已经执行成功，参数为runable对象实例；
简单地说，这个类继承自ThreadPoolExecutor，父类有的他都有。 除此之外.添加了对任务的延迟执行及周期性执行。
SynchronousQueue，实际上它不是一个真正的队列，因为它不会为队列中元素维护存储空间。与其他队列不同的是，它维护一组线程，这些线程在等待着把元素加入或移出队列。
当向线程池提交一个任务之后，线程池是如何处理这个任务的呢？ 本文来看一下线程池的主要处理流程，处理流程图下图所示。
JUC系列提供的又一个线程池，采用分治思想，及工作窃取策略，能获得更高的并发性能.
概述 减少了创建和销毁线程的次数，每个工作线程都可以被重复利用，可执行多个任务 可以根据系统的承受能力，调整线程池中工作线线程的数目，防止因为因为消耗过多的内存，而把服务器累趴下(每个线程需要大约1MB内存，线程开的越多，消耗的内存也就越大，最后死机) 线程池使得线程可以复用，就是执行完一个任务，并不被销毁，而是可以继续执行其他的任务，减少创建和销毁线程的次数。 java 中提供了3种实现 ThreadPoolExecutor：标准线程池 ScheduledThreadPoolExecutor：支持延迟
1 继承 Thread 类并重写 run 方法。实现简单，但不符合里氏替换原则，不可以继承其他类。步骤：
如果经常基于Executors提供的工厂方法创建线程池，很容易忽略线程池内部的实现。特别是拒绝策略，因使用Executors创建线程池时不会传入这个参数，直接采用默认值，所以常常被忽略。
线程的创建和销毁的开销是非常大的，线程创建，直接依靠操作系统。大量的线程的创建，会给操作系统和jvm虚拟机带来压力，同时，大量的销毁也会给垃圾回收器带来压力
我们会使用各种池化技术缓存 创建性能开销较大的 对象，比如线程池、连接池、内存池。 它们的原理都是预先创建一些对象入池，使用时直接取出，用完归还以复用，还会通过策略调整池中缓存对象的数量，实现动态伸缩性。
1. 为什么使用线程池？线程池是不是越多越好？ ---- 线程在 java 中是一个对象，更是操作系统的资源，线程创建、销毁需要时间。如果创建时间+销毁时间>执行任务时间就很不合算了。 Java 对象占用堆内存，操作系统线程占用系统内存，根据 jvm 规范，一个线程默认最大栈大小 1 M，这个栈空间是需要从系统内存中分配的。线程过多，会消耗很多的内存。 操作系统需要频繁切换线程上下文（大家都想被运行），影响性能。 线程池的推出，就是为了方便控制线程数量。 2. 线程池原理 - 概念
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
即时通信 IM
ICP备案
对象存储
实时音视频
