Java多线程4种拒绝策略小结
一、简介
在Java多线程编程中，我们通常使用线程池来管理和调度任务。线程池由一组预先创建的线程组成，可以重复利用这些线程来执行多个任务，避免频繁地创建和销毁线程而带来的性能开销。
当线程池中的任务队列已满且无法再接受新的任务时，就需要采取拒绝策略来处理这种情况。拒绝策略定义了当无法再接受新的任务时如何处理这些被拒绝的任务。
Java提供了四种常见的拒绝策略：
AbortPolicy（抛出异常）：默认的拒绝策略。当任务无法被提交给线程池时，会直接抛出RejectedExecutionException异常。
CallerRunsPolicy（调用者运行）：当任务无法被提交给线程池时，会由提交任务的线程自己执行该任务。
DiscardPolicy（直接丢弃）：当任务无法被提交给线程池时，直接丢弃该任务，没有任何提示或处理。
DiscardOldestPolicy（丢弃最旧任务）：当任务无法被提交给线程池时，会丢弃队列中最早的一个任务，然后尝试再次提交当前任务。
二、AbortPolicy拒绝策略
A. 概述
AbortPolicy是ThreadPoolExecutor的默认拒绝策略，当任务无法被提交给线程池时，会直接抛出RejectedExecutionException异常。
B. 拒绝策略实现原理
实现RejectedExecutionHandler接口，在rejectedExecution方法中抛出异常。
public class AbortPolicy implements RejectedExecutionHandler {
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
throw new RejectedExecutionException("Task " + r.toString() + " rejected from " + e.toString());
}
}
C. 应用场景
适用于对任务提交失败要求敏感的场景，需要明确知道任务是否被接受并执行。
D. 使用示例
当线程池的任务队列和线程队列都已满的情况下执行决绝策略
public class Task implements Runnable {
private final int index;
public Task(int index) {
this.index = index;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "：" + index);
}
}
public class Main {
public static void main(String[] args) {
// 创建线程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(1),
new ThreadPoolExecutor.AbortPolicy());
try {
// 提交任务
threadPool.execute(new Task(1));
threadPool.execute(new Task(2));
threadPool.execute(new Task(3));
} catch (RejectedExecutionException e) {
e.printStackTrace();
} finally {
// 关闭线程池
threadPool.shutdown();
}
}
}
三、CallerRunsPolicy拒绝策略
A. 概述
CallerRunsPolicy是一种简单的拒绝策略，当任务无法被提交给线程池时，会由提交任务的线程自己执行该任务。
B. 拒绝策略实现原理
实现RejectedExecutionHandler接口，在rejectedExecution方法中使用提交任务的线程来执行任务。
public class CallerRunsPolicy implements RejectedExecutionHandler {
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
r.run();
}
}
}
C. 应用场景
适用于对任务提交失败要求较低的场景，通过调用线程来执行任务，避免任务丢失。
D. 使用示例
public class Task implements Runnable {
private final int index;
public Task(int index) {
this.index = index;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "：" + index);
}
}
public class Main {
public static void main(String[] args) {
// 创建线程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(1),
new ThreadPoolExecutor.CallerRunsPolicy());
try {
// 提交任务
threadPool.execute(new Task(1));
threadPool.execute(new Task(2));
threadPool.execute(new Task(3));
} catch (RejectedExecutionException e) {
e.printStackTrace();
} finally {
// 关闭线程池
threadPool.shutdown();
}
}
}
四、DiscardPolicy拒绝策略
A. 概述
DiscardPolicy是一种简单的拒绝策略，当任务无法被提交给线程池时，会直接丢弃该任务，没有任何提示或处理。
B. 拒绝策略实现原理
实现RejectedExecutionHandler接口，在rejectedExecution方法中不做任何操作，即丢弃任务。
public class DiscardPolicy implements RejectedExecutionHandler {
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
// Do nothing, discard the task
}
}
C. 应用场景
适用于对任务提交失败不敏感的场景，对任务丢失没有特殊要求。
D. 使用示例
public class Task implements Runnable {
private final int index;
public Task(int index) {
this.index = index;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "：" + index);
}
}
public class Main {
public static void main(String[] args) {
// 创建线程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(1),
new ThreadPoolExecutor.DiscardOldestPolicy());
try {
// 提交任务
threadPool.execute(new Task(1));
threadPool.execute(new Task(2));
threadPool.execute(new Task(3));
} catch (RejectedExecutionException e) {
e.printStackTrace();
} finally {
// 关闭线程池
threadPool.shutdown();
}
}
}
五、DiscardOldestPolicy拒绝策略
A. 概述
DiscardOldestPolicy是一种拒绝策略，当任务无法被提交给线程池时，会丢弃最早的一个任务，然后尝试再次提交。
B. 拒绝策略实现原理
实现RejectedExecutionHandler接口，在rejectedExecution方法中从队列中获取最早的任务并丢弃，再次提交当前任务。
public class DiscardOldestPolicy implements RejectedExecutionHandler {
public void rejectedExecution(Runnable r, ThreadPoolExecutor e) {
if (!e.isShutdown()) {
e.getQueue().poll();
e.execute(r);
}
}
}
C. 应用场景
适用于对新任务优先级比较高的场景，可以丢弃旧的任务以保证及时处理新任务。
D. 使用示例
public class Task implements Runnable {
private final int index;
public Task(int index) {
this.index = index;
}
@Override
public void run() {
System.out.println(Thread.currentThread().getName() + "：" + index);
}
}
public class Main {
public static void main(String[] args) {
// 创建线程池
ThreadPoolExecutor threadPool = new ThreadPoolExecutor(1, 1, 0L,
TimeUnit.SECONDS,
new LinkedBlockingQueue<>(2),
new ThreadPoolExecutor.DiscardOldestPolicy());
try {
// 提交任务
threadPool.execute(new Task(1));
threadPool.execute(new Task(2));
threadPool.execute(new Task(3));
threadPool.execute(new Task(4));
} catch (RejectedExecutionException e) {
e.printStackTrace();
} finally {
// 关闭线程池
threadPool.shutdown();
}
}
}
六、总结
各种拒绝策略的特点和适用场景
- AbortPolicy：对任务提交失败要求敏感，需要明确知道任务是否被接受并执行。
- CallerRunsPolicy：对任务提交失败要求较低，通过调用线程来执行任务，避免任务丢失。
- DiscardPolicy：对任务提交失败不敏感，对任务丢失没有特殊要求。
- DiscardOldestPolicy：适用于新任务优先级高，丢弃旧任务以保证及时处理新任务。
到此这篇关于Java多线程4种拒绝策略小姐的文章就介绍到这了,更多相关Java多线程拒绝策略内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家！
相关文章
这篇文章主要为大家详细介绍了java NIO实现简单聊天程序，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下2021-11-11
本篇是Hadoop源码分析系列文章第五篇，主要介绍Hadoop的hdfs架构原理剖析，后续本系列文章会持续更新，有需要的朋友可以借鉴参考下2021-09-09
这篇文章主要介绍了Java编程用栈来求解汉诺塔问题的代码实例（非递归），具有一定参考价值，这里给大家分享下，供朋友们参考。2017-10-10
java开发少不了安装jdk,下面这篇文章主要给大家介绍了关于jdk21安装后无jre文件该如何解决的相关资料,文中通过图文介绍的非常详细,需要的朋友可以参考下2024-05-05
Object 是 Java 类库中的一个特殊类，也是所有类的父类。今天通过本文给大家介绍java object类的简单概念及常用方法，需要的朋友参考下吧2021-07-07
这篇文章主要介绍了关于TreeMap自定义排序规则的两种方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教2024-08-08
这篇文章主要介绍了Java使用ObjectMapper的简单示例，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧2020-09-09
这篇文章主要介绍了Java 8中的Collectors API，Stream.collect()是Java 8的流API的终端方法之一。它允许我们对流实例中保存的数据元素执行可变折叠操作，下文相关内容需要的小伙伴可以参考一下2022-04-04
关于@Component注解下的类无法@Autowired问题
这篇文章主要介绍了关于@Component注解下的类无法@Autowired问题，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-03-03
Collection中的size()和isEmpty()区别说明
这篇文章主要介绍了Collection中的size()和isEmpty()区别说明，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教2022-02-02
最新评论