池化
线程池是在计算机开发中的一种池化技术，是为了提高资源的利用率，将一些资源重复利用，避免重复的构建来提高效率。类似字符串常量池，数据库连接池，HttpClient连接池等，都是用的池化技术。
线程池
在没有线程池概念之前，我们要使用线程必须先通过创建一个Thread类来完成线程的构建，并调用start()方法开启，在线程执行完会将线程销毁，而线程资源是很宝贵的，创建和销毁线程会造成资源的浪费。而线程池是将创建的线程存储到一个池中，在需要使用时从池中去拿，使用完之后再讲线程归还到池中，下一次接着使用。
举个栗子，好比我们去银行办理业务时，银行会有窗口为客户办理业务，如果没有线程池，就好比每次来一个客户，银行都打开一个窗口，办理完业务之后将窗口关闭，这样确实很浪费时间，所以银行会默认开几个窗口，比如三个，等客户来办理业务；一个客户办理完，下一个客户可以继续在这个窗口办理。
核心线程数
在线程池初始化时，会指定创建核心线程的数量，有任务提交给线程池时，先判断是否有空闲线程，如果有空闲线程，则直接使用，如果没有则看当前线程池中的数量是不是小于核心线程数，如果是则创建新的线程，如果已经到达核心线程数，则需要做下一步操作。
等待队列
下一步操作就是要进入等待队列，等待队列好比是去银行办业务时没有空闲窗口，需要坐在大厅的座椅上排队；线程池也是一样，如果没有核心线程，则需要将任务放入等待队列，等待有空闲线程再执行。
最大线程数
那我们都知道银行有时候人特别多的时候，会增加窗口，一般是当大厅的座椅坐满人时，窗口都很紧张处理不过来，这是会增加窗口；线程池也是一样，如果等待的任务已经放满了等待队列，并且核心线程都在繁忙，这时会查看线程池中的线程数量是否到达最大线程数，如果没有则会创建新的线程来继续处理。
拒绝策略
那如果说，线程池中的线程已经到达最大线程数并且都在繁忙，还有新的任务进来，好比银行已经坐满人了，窗口也都在忙，客户都排到门口了，这时要是还有人要办理，应该怎么处理呢？银行一般会让这个人先回家，改天再来办，或者如果是个大客户，银行可能会单独带去VIP办公室办理等等。线程池在这种情况下也有相应的处理方式，这种处理方式我们称之为拒绝策略，如果会放任务在当前线程执行，或者直接将任务丢弃等等，在后面的章节中我会详细给大家介绍。
JDK中的线程池
在JDK中提供了相应的API来创建线程池，这些API也是在我们最近讲到过的JUC包中。
Executor
首先，线程池需要具备能够执行任务的能力，这个任务通过一个线程来处理。而这个执行任务的能力通过Executor接口来约定。
public interface Executor {
void execute(Runnable command);
}
ExecutorService
在某些场景我们需要知道任务执行完之后的结果，拿到返回值，而Runnable接口是没有返回值的；以及一些可以关闭线程池中的线程，执行线程中的任务的方法，定义在ExecutorService接口中。
ThreadPoolExecutor
ThreaPoolExecutor是对ExecutorService的具体实现类，通过ThreaPoolExecutor类可以创建出一个线程池，我们先来看一下代码。
ThreadPoolExecutor executor = new ThreadPoolExecutor(
// 核心线程数 corePoolSize
3,
// 最大线程数 maximumPoolSize
5,
// 空闲线程保留存活的时间和时间单位
10, TimeUnit.SECONDS,
// 等待队列
new ArrayBlockingQueue<>(3),
// 创建线程的工厂
Executors.defaultThreadFactory(),
// 拒绝策略
new ThreadPoolExecutor.AbortPolicy()
);
从代码我们可以看出，创建一个线程池，需要指定我们上面说到的核心线程数，最大线程数，等待队列，拒绝策略等，并且还要指定创建线程的工厂对象。
当然ThreadPoolExecutor也有其他的构造方法，可以不显式指定拒绝策略和工厂对象。
new ThreadPoolExecutor(3,5,10,TimeUnit.SECONDS,new ArrayBlockingQueue<>(3));
// 构造方法
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue) {
// 使用默认的线程工厂和默认的拒绝策略。
this(corePoolSize, maximumPoolSize, keepAliveTime, unit, workQueue,
Executors.defaultThreadFactory(), defaultHandler);
}
7个线程池参数
- corePoolSize：核心线程数
- maximumPoolSize：最大线程数
- keepAliveTime：空闲线程保持存活时间
- unit：空闲线程保持存活时间单位
- workQueue：等待队列
- threadFactory：线程工厂
- RejectedExecutionHandler：拒绝策略
4种拒绝策略
这里我们说一下4中拒绝策略。接口RejectedExecutionHandler定义了拒绝策略，所有的拒绝策略都需要实现该接口。
public interface RejectedExecutionHandler {
void rejectedExecution(Runnable r, ThreadPoolExecutor executor);
}
在ThreadPoolExecutor类中定义了4个拒绝策略的具体实现。
- AbortPolicy：拒绝处理，抛出异常
- CallerRunsPolicy：由创建该线程的线程（main）执行
- DiscardPolicy：丢弃，不抛出异常
- DiscardOldestPolicy：和最早创建的线程进行竞争，不抛出异常
可通过如下方式进行拒绝策略的创建。
// 拒绝处理，抛出异常
new ThreadPoolExecutor.AbortPolicy();
// 由创建该线程的线程（main）执行
new ThreadPoolExecutor.CallerRunsPolicy();
// 丢弃，不抛出异常
new ThreadPoolExecutor.DiscardPolicy();
// 和最早创建的线程进行竞争，不抛出异常
new ThreadPoolExecutor.DiscardOldestPolicy();
4种线程池种类
那么具体我们在使用时应该创建怎样的线程池呢？在JDK的Executors工具类为我们提供了4种线程池的创建方式。
// 只有一个线程
Executors.newSingleThreadExecutor();
// 固定线程数
Executors.newFixedThreadPool(5);
// 可伸缩的
Executors.newCachedThreadPool();
// 可延迟执行，使用优先队列DelayedWorkQueue
Executors.newScheduledThreadPool(3);
小结
好的，通过今天的内容我们先对线程池的使用有一个初步的了解，下期内容再跟大家深入解析一下线程池中的具体实现原理。
作者：小黑说Java
链接：https://t.1yb.co/B5C1
网友评论