前言

本篇对java的线程池进行讲解，线程池对java应用的性能来说有很重要的影响。

1、什么是线程池

类似数据库连接池，主要是为了避免线程不断创建销魂造成的大量资源消耗。

线程池按照设定管理线程。控制运行的线程的数量，将任务放入队列，然后在线程创建后启动这些任务，如果线程数量超过了最大数量超出数量的线程排队等候，等其它线程执行完毕，再从队列中取出任务来执行。主要特点为：线程复用；控制最大并发数；管理线程。

【线程池的处理流程】

如上图，有几个概念，下面进行简单讲解：

a、核心线程：核心线程是在空闲时也不会被回收的线程，可以说是常驻线程，数量由corePoolSize参数控制

b、非核心线程：当核心线程都在处理任务，阻塞队列也满了的情况下，有任务进来，当前线程数没有达到maximumPoolSize参数设置的最大值的时候，就会创建新的线程处理队列中的任务，这些非核心线程不是常驻的，空闲时间超过keepAliveTime 参数设置的时间（时间单位由unit 参数设置）就会被回收

c、阻塞队列/工作队列：核心线程数满之后，新进入的任务加入到队列中等待被执行，队列也有四种，由workQueue参数设置，下面会单独讲解

d、拒绝策略：当阻塞队列满，且线程数已达到最大线程数限制，就会执行拒绝策略，拒绝策略也有四种，由handler参数设置，下面会单独讲解

2、线程池配置

创建线程池的时候一共有7个参数：

a、corePoolSize：核心线程数

b、maximumPoolSize：最大线程数

c、keepAliveTime：非核心线程的最大空闲时间（为0表示非核心线程空闲就立即回收），只有当线程池中的线程数大于corePoolSize时keepAliveTime才会起作用，直到线程中的线程数不大于corepoolSIze。

d、unit：时间单位，作用于keepAliveTime，

e、threadFactory：线程工厂，可以设置线程名，是否为守护线程等

f、workQueue：阻塞队列

g、handler：拒绝策略

如下为线程池创建代码：

public ExecutorService executorService(){
    return new ThreadPoolExecutor(
            POLLER_THREAD_COUNT,
            POLLER_THREAD_COUNT * 8,
            10L,
            TimeUnit.SECONDS,
            new ArrayBlockingQueue<>(64),
            new ThreadFactoryBuilder().setNameFormat("AppName_FutureTask-%d").setDaemon(true).build(),
            new ThreadPoolExecutor.CallerRunsPolicy());
}

3、线程池状态

（1）RUNNING：线程池创建之后的初始状态，这种状态下可以执行任务。

（2）SHUTDOWN：该状态下线程池不再接受新任务，但是会将工作队列中的任务执行完毕。

（3）STOP：该状态下线程池不再接受新任务，也不会处理工作队列中的剩余任务，并且将会中断所有工作线程。

（4）TIDYING：该状态下所有任务都已终止或者处理完成，将会执行terminated()钩子方法。

（5）TERMINATED：执行完terminated()钩子方法之后的状态。terminated钩子方法在Executor终止时调用，默认实现不执行任何操作

4、常见线程池

线程池	描述	corePoolSize	maximumPoolSize	keepAliveTime	阻塞队列
FixedThreadPool	创建指定数量线程，且线程一直存在，阻塞队列很大	创建时传参	和corePoolSize一样	0	无界队列 LinkedBlockingQueue
CachedThreadPool	没有常驻线程，根据需要增加和减少，使用无容量的同步阻塞队列	0	Integer.MAX_VALUE	60秒	`同步队列` `SynchronousQueue`
ScheduledThreadPool	该线程池用于执行定时任务和周期性任务。可以指定线程池中的线程数量。	创建时传参	Integer.MAX_VALUE	0	无界队列（延迟、排序） DelayedWorkQueue
SingleThreadExecutor	该线程池只会创建一个线程，用于执行所有的任务。	1	1	0	无界队列 LinkedBlockingQueue
SingleThreadScheduledExecutor	一个可以周期性执行任务的单线程线程池	1	Integer.MAX_VALUE	0	无界队列（延迟、排序） DelayedWorkQueue