一.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拒绝策略
- AbortPolicy:直接抛出异常,阻止系统正常运行
- CallerRunPolicy:该策略会把任务队列中的任务放在调用者的线程中运行,如果线程已关闭则会丢弃任务
- DiscardOledestPolicy:该策略会丢弃任务队列中最早放入的任务
- DiscardPolicy:该策略会丢弃所有被线程池拒绝的任务,不予任何处理