详解什么是Java线程池的拒绝策略？

目录

• 一、拒绝策略
• 1.1 AbortPolicy（默认拒绝策略）
• 1.2 CallerRunsPolicy（使用调用线程池的线程来执行任务 ）
• 1.3 DiscardPolicy （忽略新任务）
• 1.4 DiscardOldestPolicy（忽略老任务）
• 1.5 自定义拒绝策略

一、拒绝策略

JDK 内置的拒绝策略如下：

1.AbortPolicy ： 直接抛出异常，阻止系统正常运行。

2.CallerRunsPolicy ： 只要线程池未关闭，该策略直接在调用者线程中，运行当前被丢弃的任务。显然这样做不会真的丢弃任务，但是，任务提交线程的性能极有可能会急剧下降。

3.DiscardPolicy ： 该策略默默地丢弃无法处理的任务，不予任何处理。如果允许任务丢失，这是最好的一种方案。

4.DiscardOldestPolicy ： 丢弃最老的一个请求，也就是即将被执行的一个任务，并尝试再次提交当前任务。

以上内置拒绝策略均实现了 RejectedExecutionHandler 接口，若以上策略仍无法满足实际需要，完全可以自己扩展 RejectedExecutionHandler 接口。

1.1 AbortPolicy（默认拒绝策略）

(也可以没有new ThreadPoolExecutor.AbortPolicy() 这个参数 ，隐式的默认拒绝策略)

 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo58 { public static void main(String[] args) { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.AbortPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务：" + finalI + "，线程名：" + Thread.currentThread().getName()); } }); } } } 

1.2 CallerRunsPolicy（使用调用线程池的线程来执行任务 ）

(即使用主线程来执行任务)

 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo59 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.CallerRunsPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务：" + finalI + "，线程名：" + Thread.currentThread().getName()); } }); // Thread.sleep(200); } } } 

1.3 DiscardPolicy （忽略新任务）

 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo59 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.AbortPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务：" + finalI + "，线程名：" + Thread.currentThread().getName()); } }); } } } 

1.4 DiscardOldestPolicy（忽略老任务）

（老任务指第一个进入阻塞队列里的）

 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo59 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new ThreadPoolExecutor.DiscardOldestPolicy()); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务：" + finalI + "，线程名：" + Thread.currentThread().getName()); } }); } } } 

1.5 自定义拒绝策略

 import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.RejectedExecutionHandler; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; public class ThreadDemo60 { public static void main(String[] args) throws InterruptedException { // 创建线程池 ThreadPoolExecutor executor = new ThreadPoolExecutor( 5, 5, 0, TimeUnit.SECONDS, new LinkedBlockingQueue<>(5), new RejectedExecutionHandler() { @Override public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) { // 自定义拒绝策略 System.out.println("执行了自定义拒绝策略"); } }); for (int i = 0; i < 11; i++) { int finalI = i; executor.execute(new Runnable() { @Override public void run() { System.out.println("任务：" + finalI + "，线程名：" + Thread.currentThread().getName()); } }); } } } 

到此这篇关于详解什么是线程池的拒绝策略？的文章就介绍到这了,更多相关线程池的拒绝策略内容请搜索本网站以前的文章或继续浏览下面的相关文章希望大家以后多多支持本网站！

您可能感兴趣的文章:

• Java线程池的拒绝策略实现详解
• java线程池ThreadPoolExecutor的八种拒绝策略示例详解
• Java线程池的四种拒绝策略详解
• java 线程池如何执行策略又拒绝哪些策略
• java ThreadPoolExecutor线程池拒绝策略避坑
• 详解Java ThreadPoolExecutor的拒绝策略
• java 线程池封装及拒绝策略示例详解
• Java中ThreadPoolExecutor拒绝策略踩坑
• Java多线程4种拒绝策略小结