在jdk中为我们提供了三种创建线程池的方式,但是在阿里的编码规范里面都是明确禁止使用这三种api去创建线程池,推荐我们去自定义线程池。为什么?
要回答为什么,我们需要明白创建线程池时,各参数的作用:
首先我们来看一下jdk提供的创建线程池的三个api:
1. newFixedThreadPool 创建固定数量线程的线程池。
2. newSingleThreadExecutor 创建单线程的线程池
3. newCachedThreadPool 创建一个带有缓存的线程池
发现这几种创建线程池的api,实质上都是依赖于ThreadPoolExecutor类来创建线程池。
那我们来看一下ThreadPoolExecutor 创建线程池时需要的参数,以及其作用。
创建一个线程池,需要7个参数。
1. corePoolSize: 线程池的核心线程数量。初始是不创建线程的。当有任务提交到线程池时,判定如果已经创建的线程数量小于核心数量,且没有空闲线程时,则会新建一个线程去执行新提交的任务。如果已经达到核心线程数量, 则会加入到阻塞队列中。
2.maximumPoolSize: 线程池的最大容量。当线程池的阻塞队列放满了, 并且线程数量还未达到线程池的最大线程数量, 则会创建新的线程,直到达到最大值
3.keepAliveTime 当阻塞队列里面的任务被执行完了, 且有空闲线程时,指定大于核心线程池数量的部分空闲线程的存活时间, 毕竟线程也是需要消耗资源的,及时回收很有必要。当线程空闲的时间超过这个时间后,会回收掉一部分空闲线程,使其线程池中的线程数量不大于核心线程的数量
4.unit 和keepAliveTIme 配套使用,上面指定了时间的数值,但是没有指定时间的单位(时,分,秒等), 这里需要指定时间的单位
5.workQueue 阻塞队列,当没有空闲线程时,多余的任务缓存的地方。
6.threadFactory 线程工厂,用来创建线程时,设定线程的一些参数。通常我们为了后续查看日志方便,可以通过这个来指定我们自定义的线程池的线程名称
7.handler 当线程数量达到最大值时,且阻塞队列慢了, 后续在提交任务时,没有地方可以接受继续的提交的任务。这种情况下的一个拒绝策略。
拒绝策略jdK,提供了四种:
// 由提交任务的线程执行任务
public static class CallerRunsPolicy implements RejectedExecutionHandler {
public CallerRunsPolicy() { }
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
r.run();
}
}
}
// 不在接收新的任务,直接抛出异常
public static class AbortPolicy implements RejectedExecutionHandler {
public AbortPolicy() { }
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
throw new RejectedExecutionException("Task " + r.toString() +
" rejected from " +
e.toString());
}
}
// 不接收也不抛出异常,空实现,忽略该任务
public static class DiscardPolicy implements RejectedExecutionHandler {
public DiscardPolicy() { }
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
}
}
// 抛弃最老的任务,从阻塞队列中移除最早提交的任务,然后将该任务加入。
public static class DiscardOldestPolicy implements RejectedExecutionHandler {
public DiscardOldestPolicy() { }
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
e.getQueue().poll();
e.execute(r);
}
}
}