Java多线程4种拒绝策略小结

更新时间：2024年03月04日 09:03:43 作者：皮卡冲撞

当线程池中的任务队列已满且无法再接受新的任务时,就需要采取拒绝策略来处理这种情况,本文主要介绍了Java多线程拒绝策略,包含了四种常见的拒绝策略,具有一定的参考价值,感兴趣的可以了解一下

一、简介

在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面试题冲刺第十七天--基础篇3
这篇文章主要为大家分享了最有价值的三道java基础面试题，涵盖内容全面，包括数据结构和算法相关的题目、经典面试编程题等，感兴趣的小伙伴们可以参考一下
2021-08-08
Spring菜鸟教你看源码冲面试
这篇文章主要介绍了Spring菜鸟教你看源码冲面试,本文给大家介绍的非常详细，对大家的学习或工作具有一定的参考借鉴价值，需要的朋友可以参考下
2021-03-03
Java8生成时间方式及格式化时间的方法实例
这篇文章主要给大家介绍了关于Java8生成时间方式及格式化时间的相关资料，文中通过示例代码介绍的非常详细，对大家的学习或者工作具有一定的参考学习价值，需要的朋友们下面随着小编来一起学习学习吧
2020-08-08
java实现的xml格式化实现代码
这篇文章主要介绍了java实现的xml格式化实现代码,需要的朋友可以参考下
2016-11-11
Java SpringBoot启动指定profile的8种方式详解
这篇文章主要介绍了spring boot 如何指定profile启动的操作，具有很好的参考价值，希望对大家有所帮助。如有错误或未考虑完全的地方，望不吝赐教
2021-09-09
Spring Aop之AspectJ注解配置实现日志管理的方法
下面小编就为大家分享一篇Spring Aop之AspectJ注解配置实现日志管理的方法，具有很好的参考价值，希望对大家有所帮助。一起跟随小编过来看看吧
2018-01-01
Springboot 整合 Java DL4J 打造文本摘要生成系统
本文介绍了如何使用SpringBoot整合JavaDeeplearning4j构建文本摘要生成系统,该系统能够自动从长篇文本中提取关键信息,生成简洁的摘要,帮助用户快速了解文本的主要内容,技术实现包括使用LSTM神经网络进行模型构建和训练,并通过SpringBoot集成RESTfulAPI接口
2024-11-11
java Callable接口和Future接口创建线程示例详解
这篇文章主要为大家介绍了java Callable接口和Future接口创建线程示例详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪
2023-11-11
java枚举类型-Enum
本文详细介绍了 Java1.5 引入的新特性枚举中的关键字enum，运用大量的代码加以解释，相信可以帮助到正在学习该知识的小伙伴，大家可以参考一下
2021-08-08
java实现计算器模板及源码
这篇文章主要为大家详细介绍了java实现计算器模板及源码，文中示例代码介绍的非常详细，具有一定的参考价值，感兴趣的小伙伴们可以参考一下
2022-06-06