多线程是程序开发的必经之路，裸线程是不安全的也是不可控制的，因此接入线程池很有必要
一 首先了解下线程池ThreadPoolExecutor 几个参数的概念
1 int corePoolSize 线程池核心线程数
2 int maximumPoolSize 线程池最大线程数
3 long keepAliveTime 空闲线程保持时间
4 TimeUnit unit 时间单位
5 BlockingQueue workQueue 等待线程队列
6 ThreadFactory threadFactory 创建线程池线程的工厂( 注意，是创建线程池线程的工厂，不是创建执行线程的工厂，创建于线程池核心线程初始化和线程队列满导致创建非核心线程时调用 )
7 RejectedExecutionHandler handler 饱和策略，线程池线程达到最大数量，线程队列满时执行的策略
二 线程池线程状态修改策略
![image]( "image")
三 线程池的使用
1 阿里开发文档中，要求禁止使用Executors 直接创建线程池，是因为Executors 提供的方法在创建线程池时，workQueue ，corePoolSize ，maximumPoolSize 不可控，有可能导致OOM ,
2 因此建议使用ThreadPoolExecutor 创建线程池，根据业务场景选择合适的maximumPoolSize，
3 建议使用单例模式进行线程池的创建，保证一个服务中每一个线程池仅被初始化一次
public class ThreadPoolManager {
private static ThreadPoolExecutor instance;
public static ThreadPoolExecutor getInstance() {
if (instance == null) {
synchronized (ThreadManager.class) {
if (instance == null) {
int cpuNum = Runtime.getRuntime().availableProcessors();// 获取处理器数量
int threadNum = cpuNum * 2 + 1;// 根据cpu数量,计算出合理的线程并发数
int corePoolSize = cpuNum * 2;
int maximumPoolSize = corePoolSize + 1;
long keepAliveTime = 60l;
instance = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,
TimeUnit.MILLISECONDS,new ArrayBlockingQueue<>(300),Executors.defaultThreadFactory(),
new ThreadPoolExecutor.AbortPolicy());
}
}
}
return instance;
}
}
四 线程池参数选择
1 corePoolSize 业务分为cpu密集型和io密集型，一般web应用都是io密集型，cpu密集型如数学计算，视频编解码等
java 可以使用int cpuNumber = Runtime.getRuntime().availableProcessors() 获取部署机器的cpu核心数(Intel cpu获取的是xianchengshu)线程数
cpu密集型业务corePoolSize = cpuNumber io密集型业务corePoolSize = cpuNumber*2 ,
2 maximumPoolSize 根据业务场景选择 一般 maximumPoolSize = corePoolSize +1
在业务存在偶尔短时间需要处理大量业务时，可以适当放大maximumPoolSize 的值，在短时间内增加并发数量处理业务
3 keepAliveTime 非核心线程空闲时间，根据自己业务，如果maximumPoolSize = corePoolSize 应该设置为0，
如果需要maximumPoolSize >corePoolSize 则需要根据实际业务场景，选择非核心线程的时间，根据newCachedThreadPool的构造函数看，可以设置为60s，在短时间处理洪峰业务处理时，减少线程创建带来的性能消耗，同时在高并发业务处理完成后能及时释放线程资源
4 unit 时间单位，配合keepAliveTime使用
5 workQueue 的选择 ArrayBlockingQueue和LinkedBlockingQueue 的区别请见另一篇博客ArrayBlockingQueue 和LinkedBlockingQueue 代码解析(JDK8)
6 threadFactory 创建线程池线程的工厂，也就是申请线程资源的工厂，执行线程(执行任务)的创建和这个无关，如果对线程资源申请没有特殊需求，可以使用默认的Executors.defaultThreadFactory()，如果想查看线程池什么时候申请了线程资源，比如非核心线程的创建，可以实现ThreadFactory 并重写newThread方法，可以记录线程资源申请时间和线程信息，在非核心线程被回收后，再次申请线程资源时，也是通过threadFactory进行重新创建线程
public class TThreadFactory implements ThreadFactory {
@Override
public Thread newThread(Runnable r) {
System.out.println(new Date());
Thread t= new Thread(r,"new Thread ");
return t;
}
}
7 handler 饱和策略 也就是当线程池没有没有空余线程，线程等待队列满，并且线程池线程数量等于最大线程数，执行饱和策略
饱和策略分为4种
（1）AbortPolicy 直接抛出异常，并抛弃该线程任务，不影响主线程和正在执行和等待的线程
可以使用ThreadPoolExecutor中的AbortPolicy进行创建
new ThreadPoolExecutor.AbortPolicy() {// 队列已满,而且当前线程数已经超过最大线程数时的异常处理策略
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
super.rejectedExecution(r, e);
}
}
（2）CallerRunsPolicy 在线程池执行饱和策略时，由主线程执行子线程任务，也就是说，主线程execute(）或者submit()被调用后，主线程执行子线程任务，主线程任务挂起等待子线程任务结束后继续执行
ThreadPoolExecutor中的CallerRunsPolicy 进行创建
（3） DiscardPolicy 线程池饱和后，抛弃所有新增的线程
ThreadPoolExecutor中的DiscardPolicy 进行创建
（4）DiscardOldestPolicy 抛弃queue中最老的线程任务，将新任务添加到queue的底部，抛弃掉的任务将不会执行
ThreadPoolExecutor中的DiscardOldestPolicy 进行创建
