Java线程池

Posted 2020-12-05 小冷

一.Java提供Executors工具类来创建四种类型的线程池：

1.单线程的线程池：Executors.newSingleThreadExecutor()

 

2.定长线程池：Executors.newFixedThreadPool(int nThreads)

 

3.可缓存的线程池：Executors.newCachedThreadPool(int nThreads)

 

4.定期执行的线程池：Executors.newScheduledThreadPool(int corePoolSize)

 

 

 

二.ThreadPoolExecutors详解

通过源码可以发现，Exectuors内部其实是通过new ThreadPoolExecutor来创建线程池，而阿里开发手册中规定禁用Execotrs创建线程池，推荐用ThreadPoolExecutors来创建；

那么阿里为什么禁止使用Executors来创建线程池呢，首先来查看ThreadPoolExecutors构造函数的几个参数：

• int  corePoolSize：线程池核心线程数量，这些线程保持不会被销毁
• int  maximumPoolSize：线程池最大线程数量，当所需线程数超过核心线程池数量且工作队列中等待任务已满，则会创建新的线程直至到达设置的最大数量
• long  keepAliveTime：非核心线程的空闲时间
• TimeUnit  unit：时间单位(时、分、秒等)
• Queue<E>  queue：用于存放未被执行的任务队列，分为同步队列，有界队列，无界队列，优先队列
• ThreadFactory  threadFactory：用于创建线程的线程工场，一般用默认即可
• RejectedExecutionHandler  handler：拒绝策略，当线程数量超出最大线程数量的执行策略

再来看一下线程池的执行过程：

 

 

通过参数可以看出来，Executors创建的线程池最大线程数量以及线程队列都是Integer.MAX_VALUE，几乎相当于无限制创建，这样非常容易导致内存溢出；所以创建线程池最好通过自定义的

ThreadPoolExecutors来创建，这样更容易用过具体环境来优化线程池线程数量

 

 三.ThreadPoolExecutors拒绝策略

1. AbortPolicy：直接抛出异常，阻止系统正常运行
2. CallerRunPolicy：该策略会把任务队列中的任务放在调用者的线程中运行，如果线程已关闭则会丢弃任务
3. DiscardOledestPolicy：该策略会丢弃任务队列中最早放入的任务
4. DiscardPolicy：该策略会丢弃所有被线程池拒绝的任务，不予任何处理