重庆市城市建设综合开发办网站成都最新疫情
为什么要使用线程池？
JDK1.5后JUC包添加了线程池相关接口，在Java诞生之初并没有线程池这个概念。刚开始Java程序都是自行创建线程去处理任务。随着应用使用的线程越来越多，JDK开发者们发现有必要使用一个统一的类来管理这些线程，从而有效提高线程的执行效率，减少创建、销毁线程的开销。
大量线程的创建、销毁是非常消耗资源的。创建线程需要消耗一定的内存、CPU资源，大量的线程也会导致大量的线程上下文切换，上下文切换代码也是相当大的，过多的线程导致频繁切换更是可能使系统性能急速下降。另外操作系统对每个进程能创建的线程数也是有限制的，不可能无限创建。但是大量任务也不可能只在主线程处理吧，这样也太慢了。比如下面的例子，创建上万的线程，每个线程打印一下线程名字，观察一下任务管理器，CPU直接用完。这只是简单的任务，要是复杂长时间的任务，整个操作系统可能都会受到影响（CPU利用率长时间下不来，影响其他程序）
public class BadMultiThreadTest {public static void main(String[] args) {Runnable r = () -> {System.out.println("ThreadName-" + Thread.currentThread().getName());};//过多创建线程导致系统资源消耗严重for (int i = 0; i < 10000; i++) {Thread thread = new Thread(r);thread.start();}}
}
线程池就是为了解决上述问题出现的，解决问题的思路很清晰，就是创建好一定数量的线程，有任务来了就用这些线程来执行任务，任务过多把池里面的线程都占用了就放队列排队等候其他任务执行，一旦有空闲线程就可以从队列里面取出任务并执行。有了可控的线程池，系统就不会处于一种可能随时被大量并发导致线程大量创建，最终压跨系统的危险中。
如何使用线程池？
使用线程池去改造上面的例子：
public class MultiThreadPoolTest {public static void main(String[] args) {ExecutorService executorService = Executors.newFixedThreadPool(10);for (int i = 0; i < 10000; i++) {executorService.execute(() -> {System.out.println("ThreadName-" + Thread.currentThread().getName());});}}
}这次再观察任务管理器，这次CPU占用不会说飙长，而是相对平稳。打印的线程名称就是在ThreadName-pool-1-thread-1到ThreadName-pool-1-thread-10之间变化，说明这一万个任务都是这10个线程处理的。
线程池的参数含义
上面的例子简单的使用了Excutors工具类来创建了一个固定线程数的线程池。这个工具类还可以创建单线程线程池、可缓存线程池、定时执行任务的线程池等。这些线程池的创建事实上都是在创建一个ThreadPoolExecutor实例，只是通过传递不同参数，实现不同的线程池效果而已。如果我们把里面的参数都搞明白，我们就可以根据实际需求去自定义线程池，实际开发中，我们都应该使用自定义的线程池去处理相关业务，这样能最大提高线程池使用效率，提高系统性能。当然，这还得靠我们对业务的理解，从而定义出合理的线程池。
通过下面这句代码，跟踪源码
Executors.newFixedThreadPool(10);最终调用的函数如下，它包含了线程池的所有参数注释：
/*** Creates a new {@code ThreadPoolExecutor} with the given initial* parameters.** @param corePoolSize the number of threads to keep in the pool, even* if they are idle, unless {@code allowCoreThreadTimeOut} is set* @param maximumPoolSize the maximum number of threads to allow in the* pool* @param keepAliveTime when the number of threads is greater than* the core, this is the maximum time that excess idle threads* will wait for new tasks before terminating.* @param unit the time unit for the {@code keepAliveTime} argument* @param workQueue the queue to use for holding tasks before they are* executed. This queue will hold only the {@code Runnable}* tasks submitted by the {@code execute} method.* @param threadFactory the factory to use when the executor* creates a new thread* @param handler the handler to use when execution is blocked* because the thread bounds and queue capacities are reached* @throws IllegalArgumentException if one of the following holds:<br>* {@code corePoolSize < 0}<br>* {@code keepAliveTime < 0}<br>* {@code maximumPoolSize <= 0}<br>* {@code maximumPoolSize < corePoolSize}* @throws NullPointerException if {@code workQueue}* or {@code threadFactory} or {@code handler} is null*/public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler) {if (corePoolSize < 0 ||maximumPoolSize <= 0 ||maximumPoolSize < corePoolSize ||keepAliveTime < 0)throw new IllegalArgumentException();if (workQueue == null || threadFactory == null || handler == null)throw new NullPointerException();this.acc = System.getSecurityManager() == null ?null :AccessController.getContext();this.corePoolSize = corePoolSize;this.maximumPoolSize = maximumPoolSize;this.workQueue = workQueue;this.keepAliveTime = unit.toNanos(keepAliveTime);this.threadFactory = threadFactory;this.handler = handler;}下面简单总结一下参数的含义：
| 参数名称 | 含义 |
corePoolSize | 核心线程数 |
maximumPoolSize | 最大线程数 |
keepAliveTime+时间单位 | 空闲线程存活时间 |
workQueue | 任务队列 |
threadFactory | 创建线程的工厂类 |
handler | 被拒绝任务处理器 |
线程池处理任务的流程
看一下下面的流程图就能清晰知道任务从被提交再到被线程池中线程执行的流程了。
待补充...
使用线程池的优点
根据上面可以简略总结出使用线程池的几点优点：
- 解决线程创建、销毁等生命周期系统消耗过大问题。因为线程池中的线程一旦创建过，核心线程是会一直驻留在池中待用的，这样任务来了后，直接可以执行，消除了创建线程的系统开销。系统响应更及时，使用更丝滑。
- 线程池使得系统可控性更强。它避免了系统资源使用不当导致系统崩溃，能更合理的使用CPU和内存资源。