这次用一个生活案例来让你快速的 get 到线程池的工作原理和七个参数的作用。 最近在复习面试题,巩固一下自己。学完看看面试题,可以很有效的知道的不足。也是为以后做准备。 你好,我是博主
宁在春
,希望文章能够让你有所收获,也让我们也一起努力!!!
本文主要针对线程池的七个参数及工作原理
做讲解。
阅读完本文能够通过自己的语言简单阐述线程池的工作原理和画出原理图。
在看很多Java面试题相关的文章或者博客中,对于线程池都会有这么几个常见连环问题。
👨💻面试官:
问题,都是一步一步深入。
我们在回答的时候,要尽可能的让面试官往自己更加有把握的地方问过去。
我们平常在使用线程池时,不是使用Executors
工具类来创建的,而是显式的使用ThreadPoolExecutor
来创建的。
原因:
【强制】线程资源必须通过线程池提供,不允许在应用中自行显式创建线程。 说明:线程池的好处是减少在创建和销毁线程上所消耗的时间以及系统资源的开销,解决资源不足的问题。 如果不使用线程池,有可能造成系统创建大量同类线程而导致消耗完内存或者“过度切换”的问题。 【强制】线程池不允许使用 Executors 去创建,而是通过 ThreadPoolExecutor 的方式,这 样的处理方式让写的同学更加明确线程池的运行规则,规避资源耗尽的风险。 说明:Executors 返回的线程池对象的弊端如下: 1) FixedThreadPool 和 SingleThreadPool: 允许的请求队列长度为 Integer.MAX_VALUE,可能会堆积大量的请求,从而导致 OOM。 2) CachedThreadPool: 允许的创建线程数量为 Integer.MAX_VALUE,可能会创建大量的线程,从而导致 OOM。 来自于阿里的Java开发手册
接下来来看我们今天的重点哈:
public ThreadPoolExecutor(int corePoolSize,
int maximumPoolSize,
long keepAliveTime,
TimeUnit unit,
BlockingQueue<Runnable> workQueue,
ThreadFactory threadFactory,
RejectedExecutionHandler handler) {
}
一个一个参数分析:
corePoolSize
– 核心线程数。要保留在池中的线程数,即使它们处于空闲状态,除非设置了allowCoreThreadTimeOut
maximumPoolSize
– 池中能够容纳同时执行的最大线程数,此值必须大于等于1.
keepAliveTime
– 当线程数大于核心数时,这是多余空闲线程在终止前等待新任务的最长时间。
当前线程池数量超过corePoolSize
时,当空闲时间达到KeepAliveTime
值时,多余空闲线程会被销毁直到只剩下corePoolSize
个线程为止。
unit
– keepAliveTime
参数的时间单位
workQueue
– 用于在执行任务之前保存任务的队列。 这个队列将只保存execute方法提交的Runnable任务。
threadFactory
– 执行程序创建新线程时使用的工厂 ,一般用默认即可。
handler
– 执行被阻塞时使用的处理程序,因为达到了线程边界和队列容量。平常称为拒绝策略。
看完这个概念一下肯定是没啥感觉的,我会用一个生活中的案列来讲解线程池的工作原理,确保大家都能理解。
先说说这张图:
1)当调用 execute()方法添加一个请求任务时,线程池会做出如下判断:
2)当一个线程完成任务时,它会从队列中取下一个任务来执行
3)当一个线程无事可做超过一定的时间(keepAliveTime)时,线程会判断:
4)拒绝策略,Jdk默认的拒绝策略有以下四种:
AbortPolicy
: 丢弃任务,并抛出拒绝执行 RejectedExecutionException 异常信息。线程池默认的拒绝策略。必须处理好抛出的异常,否则会打断当前的执行流程,影响后续的任务执行。CallerRunsPolicy
: 当触发拒绝策略,只要线程池没有关闭的话,则使用调用线程直接运行任务。一般并发比较小,性能要求不高,不允许失败。DiscardPolicy
: 直接丢弃.DiscardOldestPolicy
: 触发拒绝策略时,只要线程池没有关闭的话,丢弃阻塞队列 workQueue中最老的任务,并将新任务加入上面这个内容我第一次看的时候,也稍稍有些懵,学习的时候懂,过段时间再看又是陌生人啦。
这次为了让记忆更为深刻,举一个特别形象生动的例子。源自于 尚硅谷--周阳老师
相信我们大家肯定都去过银行哈。这次就是以银行来举例的。先看看场景
我来解释下哈:
原因
:在上文我说过,当调用 execute()方法添加一个请求任务时,线程池会做出如下判断:
如果这个时候队列满了且正在运行的线程数量还小于 maximumPoolSize,那么还是要创建非核心线程立刻运行这个任务;所以会立刻处理第6、7、8名顾客业务。
触发拒绝策略
。(这种情况就是陌生的哈,那个经理敢把顾客往外赶哈)
接下来我们用代码来模拟这个场景哈。
设置的数据就按照图上的来,
corePoolSize
核心线程数为:2,maximumPoolSize
最大线程数为:5,keepAliveTime
:等待时间为:3秒
workQueue
阻塞队列为:3,ThreadFactory
线程的创建方式就使用默认的:Executors.defaultThreadFactory()
RejectedExecutionHandler
拒绝策略:都会测试一遍。
public static void main(String[] args) {
BlockingDeque<Runnable> workQueue = new LinkedBlockingDeque<Runnable>(3);
ThreadPoolExecutor executor = new ThreadPoolExecutor(2,
5,
3, TimeUnit.SECONDS,
workQueue,
Executors.defaultThreadFactory(),
new ThreadPoolExecutor.AbortPolicy());
for (int i = 0; i <8 ; i++) {
final int temp=i;
executor.execute(()->{
System.out.println(Thread.currentThread().getName()+"\t"+"执行第 "+temp+" 个任务!!");
});
}
}
这个代码里设置的拒绝策略为:new ThreadPoolExecutor.AbortPolicy()
,超过maximumPoolSize
+workQueue
之和的数据。就会直接抛出异常,停止运行。
当设置为8的时候,还是可以正常的,我们调到9个任务来试一试。
当我们向上调整上,任务超过最大数,就会触发拒绝策略。
将策略改为new ThreadPoolExecutor.DiscardPolicy());
直接就抛弃了第八个任务。
策略改为:new ThreadPoolExecutor.CallerRunsPolicy()
,当触发拒绝策略,只要线程池没有关闭的话,则使用调用线程直接运行任务。一般并发比较小,性能要求不高,不允许失败。
还有最后一个DiscardOldestPolicy
: 触发拒绝策略时,只要线程池没有关闭的话,丢弃阻塞队列 workQueue中最老的任务,并将新任务加入
你好,我是博主
宁在春
:主页 希望本篇文章能让你感到有所收获!!! 祝我们:待别日相见时,都已有所成
。