「视频版」当线程池溢出之后，程序会奔溃吗？面试突击 007 期

哈喽，大家好，我是老王，欢迎来到第 7 期的 Java 面试突击。

本文的面试题是，当线程池的任务溢出之后，程序会奔溃吗？

这个问题问的是关于线程池的任务数超过线程池的承载能力之后，会出现什么情况？

那么，我们本文就手撸模拟一个线程池溢出的情况，来看程序的执行情况。

涉及知识点

核心线程数和最大线程数有什么区别？
如何模拟线程池溢出？
拒绝策略的执行流程是什么？
什么是线程池的拒绝策略？
Java 自带的拒绝策略有哪些？
如何自定义拒绝策略？

视频面试答案

视频内容（因为视频比较大，分成了两个视频来展示）：

图文面试答案

当线程池的任务溢出之后，程序并不会奔溃，这时候会触发线程池的拒绝策略，Java 自带的拒绝策略有四种：

AbortPolicy：终止策略，线程池终止执行，并直接抛出异常，Java 默认此拒绝策略；
CallerRunsPolicy：把任务交给当前线程执行（本来是线程池自己要执行的，结果处理不过来就交给当前的主线程去处理）；
DiscardPolicy：忽略此任务（最新的任务）；
DiscardOldestPolicy：忽略最早的任务（最久的任务）。

拒绝策略的执行流程比较绕，这是因为线程池有三个重要的参数：核心线程数（corePoolSize）、最大线程数（maximumPoolSize）、线程池的任务队列（BlockingQueue），大部分搞不清楚核心线程数和最大线程数有什么区别？

核心线程数是指在正常情况下线程池内的线程数量；而最大线程数指的是当线程池的任务队列存储超过最大值之后，可以创建最多的线程数量。

当任务比较少的时候，线程数量会根据设置的超时时间，回归线程的数量为核心线程数量，这个时候最大线程数就暂时没用了（没有发挥的余地了）。

拒绝策略的执行流程是：当提交的任务数量大于核心线程数时，任务会被放入到线程池的任务队列中，当任务超过了最大队列值时，判断当前线程数量是否大于最大线程数，如果小于最大线程数则会新创建线程处理次任务，相反的情况下就会执行拒绝策略，如下图所示：

模拟线程池溢出

 public static void main(String[] args) {ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 4, 10, TimeUnit.SECONDS,new LinkedBlockingQueue<>(1),new ThreadPoolExecutor.AbortPolicy());for (int i = 0; i < 6; i++) {executor.execute(() -> {System.out.println(Thread.currentThread().getName());});}}

程序的执行结果如下：

pool-1-thread-2

pool-1-thread-2

pool-1-thread-1

pool-1-thread-3

pool-1-thread-4

Exception in thread "main" java.util.concurrent.RejectedExecutionException: Task org.example.App$$Lambda$1/1096979270@7cca494b rejected from java.util.concurrent.ThreadPoolExecutor@7ba4f24f[Running, pool size = 4, active threads = 4, queued tasks = 1, completed tasks = 0]

at java.util.concurrent.ThreadPoolExecutor$AbortPolicy.rejectedExecution(ThreadPoolExecutor.java:2063)

at java.util.concurrent.ThreadPoolExecutor.reject(ThreadPoolExecutor.java:830)

at java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:1379)

at org.example.App.main(App.java:13)

从执行结果可以看出，循环在执行第 6 次就抛出异常了，这是因为最大线程数为 4，而队列最大只能存储 1 个任务，所以在第 6 个任务过来的时候，线程池已经超负荷运行了，只能执行拒绝策略了，而我们设置的拒绝策略是 AbortPolicy 所以会抛出异常。

自定义拒绝策略

除了 Java 自带的四种拒绝策略外，我们还可以自定义拒绝策略，代码如下：

public static void main(String[] args) throws InterruptedException {ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 4, 10, TimeUnit.SECONDS,new LinkedBlockingQueue<>(1), new RejectedExecutionHandler() {@Overridepublic void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {// 添加业务处理代码System.out.println("自定义拒绝策略");}});for (int i = 0; i < 7; i++) {executor.execute(() -> {System.out.println(Thread.currentThread().getName());});}
}

以上程序执行结果如下：

自定义拒绝策略

自定义拒绝策略

pool-1-thread-1

pool-1-thread-1

pool-1-thread-2

pool-1-thread-3

pool-1-thread-4

可以看出自定义拒绝策略，只需要重写 RejectedExecutionHandler 接口的 rejectedExecution 方法即可，可以在此方法中添加自己的业务处理代码。

小结

本文讲了线程池任务新增时的执行流程，先判断是否有空闲线程，如果的话直接执行任务，如果没有的话再判断任务队列是否是否饱和，如果不饱和把任务存储到队列中，如果饱和需要判断当前线程数是否大于最大线程数，如果小于则新增线程执行此任务，反之则执行拒绝策略。Java 提供了四种拒绝策略，你可以通过重写 RejectedExecutionHandler 接口来自定义拒绝策略。

更多执行细节和更多知识点说明，详见本文的视频部分。

【END】

近期热文

HashMap 为什么会导致 CPU 100%？面试突击 006 期
面试突击 005 | Redis 是如何实现高可用的？它的实现方式有哪些？
面试突击 004 | 如何排查 Redis 中的慢查询？视频实战篇
面试突击 003 | Redis 如何实现查询附近的人？
面试突击 002 | Redis 是如何处理已过期元素的？
面试突击 001 | Redis 如何从海量数据中查询出某一个 Key？
Java面试详解(2020版)：500+ 面试题和核心知识点详解

关注下方二维码，订阅更多精彩内容

朕已阅