Java多线程4种拒绝策略

news2024/10/6 18:20:54

文章目录

  • 一、简介
  • 二、AbortPolicy拒绝策略
    • A. 概述
    • B. 拒绝策略实现原理
    • C. 应用场景
    • D. 使用示例
  • 三、CallerRunsPolicy拒绝策略
    • A. 概述
    • B. 拒绝策略实现原理
    • C. 应用场景
    • D. 使用示例
  • 四、DiscardPolicy拒绝策略
    • A. 概述
    • B. 拒绝策略实现原理
    • C. 应用场景
    • D. 使用示例
  • 五、DiscardOldestPolicy拒绝策略
    • A. 概述
    • B. 拒绝策略实现原理
    • C. 应用场景
    • D. 使用示例
  • 六、总结
    • 各种拒绝策略的特点和适用场景

一、简介

在Java多线程编程中，我们通常使用线程池来管理和调度任务。线程池由一组预先创建的线程组成，可以重复利用这些线程来执行多个任务，避免频繁地创建和销毁线程而带来的性能开销。

当线程池中的任务队列已满且无法再接受新的任务时，就需要采取拒绝策略来处理这种情况。拒绝策略定义了当无法再接受新的任务时如何处理这些被拒绝的任务。

Java提供了四种常见的拒绝策略：

  1. AbortPolicy（抛出异常）：默认的拒绝策略。当任务无法被提交给线程池时，会直接抛出RejectedExecutionException异常。

  2. CallerRunsPolicy（调用者运行）：当任务无法被提交给线程池时，会由提交任务的线程自己执行该任务。

  3. DiscardPolicy（直接丢弃）：当任务无法被提交给线程池时，直接丢弃该任务，没有任何提示或处理。

  4. 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：适用于新任务优先级高，丢弃旧任务以保证及时处理新任务。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.coloradmin.cn/o/989402.html

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

966SEO扫地僧站群·万能HTML模板[V1.9.1]

966SEO扫地僧站群·万能HTML模板[V1.9.1]

扫地僧站群万能HTML模板是一款站点管理软件,其主要特点是可以将原始的html模板放入程序中,无需编写任何标签,程序会全自动替换处理,从而快速构建出一个完整的网站,这种模式相对于传统的网站建设方式更加快速、简单,同时可以大幅度降低网站建设的成本和难度.服务器及域名量的配置…
阅读更多...
【Linux】进程优先级,环境变量,进程地址空间

【Linux】进程优先级,环境变量,进程地址空间

文章目录 1.进程优先级基本概念查看系统进程PRI and NIPRI vs NI修改进程优先级的命令其他概念 2. 环境变量基本概念查看环境变量方法常见环境变量测试PATH环境变量相关的命令环境变量的组织方式通过代码如何获取环境变量通过系统调用获取或设置环境变量环境变量通常是具有全局…
阅读更多...
1DM+下载器_11.2.1魔改增强版下载

1DM+下载器_11.2.1魔改增强版下载

1DM「原&#xff1a;IDM」下载器是一款安卓端的下载工具&#xff0c;多语言解锁版直安装版本&#xff0c;号称是目前 Android 平台最快、最先进的下载管理器应用「支持通过Torrent下载」&#xff0c;而这个版本是改线程的最新idm版本&#xff0c;可用来下载视频、音乐、电影、T…
阅读更多...
2023-9-8 求组合数(三)

2023-9-8 求组合数(三)

题目链接&#xff1a;求组合数 IV #include <iostream> #include <algorithm>using namespace std;const int N 5010;int primes[N], cnt; bool st[N]; // 每个质数的次数 int sum[N];void get_primes(int n) {for(int i 2; i < n; i){if(!st[i]) primes[cnt]…
阅读更多...
bean的管理-bean的获取

bean的管理-bean的获取

获取bean 默认情况下&#xff0c;在Spring项目启动时&#xff0c;会把bean都创建好&#xff08;但是还会受到作用域及延迟初始化的影响&#xff09;放在IOC容器中&#xff0c;如果想主动获取这些bean&#xff0c;可以通过如下方式 根据name获取bean Object getBean&#xff08…
阅读更多...
智能机器人：打造自动化未来的关键技术

智能机器人：打造自动化未来的关键技术

文章目录 1. 智能机器人的基本概念2. 智能机器人的关键技术2.1 机器视觉2.2 机器学习与深度学习2.3 传感器技术 3. 智能机器人的应用领域3.1 制造业3.2 医疗保健3.3 农业3.4 服务业 4. 智能机器人的未来趋势4.1 自主决策能力的提升4.2 协作与互操作性4.3 个性化定制4.4 环境感知…
阅读更多...
正弦信号的平均功率和峰值电压计算举例

正弦信号的平均功率和峰值电压计算举例

正弦信号的平均功率和峰值电压计算举例 一、问题 假设加载在纯电阻为R1Ω&#xff0c;频率为50Hz和60Hz的正弦信号的平均功率分别为0.5W和2W,请求解这两个信号的峰值电压 U p 1 U_{p1} Up1​和 U p 2 U_{p2} Up2​。 二、解答&#xff1a; 根据欧姆定律可知&#xff1a;对于…
阅读更多...
Java虚拟机内存模型和垃圾回收机制

Java虚拟机内存模型和垃圾回收机制

1 Java虚拟机内存模型是怎样的&#xff1f; 2 常见垃圾回收器及其作用内存&#xff1f;
阅读更多...
激活函数总结（三十）：激活函数补充(Logit、Softsign)

激活函数总结（三十）：激活函数补充(Logit、Softsign)

激活函数总结&#xff08;三十&#xff09;&#xff1a;激活函数补充 1 引言2 激活函数2.1 Logit激活函数2.2 Softsign激活函数 3. 总结 1 引言 在前面的文章中已经介绍了介绍了一系列激活函数 (Sigmoid、Tanh、ReLU、Leaky ReLU、PReLU、Swish、ELU、SELU、GELU、Softmax、So…
阅读更多...
基于 SpringBoot 的大学生体质测试管理系统，附源码

基于 SpringBoot 的大学生体质测试管理系统，附源码

文章目录 简介效果图系统首页模块管理员功能模块用户功能模块教师功能模块 部分源码源码下载地址 简介 本次设计任务是要设计一个大学生体质测试管理系统&#xff0c;通过这个系统能够满足大学生体质测试管理系统功能。系统的主要功能包括首页、个人中心、用户管理、教师管理、…
阅读更多...
记一次opencv安装过程

记一次opencv安装过程

环境为anaconda&#xff0c;python选择3.9 上图&#xff0c;def仅为了可以折叠&#xff0c;方便观察 (simswap) C:\Windows\system32>conda install opencv def 执行后失败:无科学上网Retrieving notices: ...working... DEBUG:urllib3.connectionpool:Starting new HTTPS …
阅读更多...
高频golang面试题：简单聊聊内存逃逸？

高频golang面试题：简单聊聊内存逃逸？

文章目录 问题怎么答举例 问题 知道golang的内存逃逸吗&#xff1f;什么情况下会发生内存逃逸&#xff1f; 怎么答 golang程序变量会携带有一组校验数据&#xff0c;用来证明它的整个生命周期是否在运行时完全可知。如果变量通过了这些校验&#xff0c;它就可以在栈上分配。…
阅读更多...
了解 Java 并发编程中的 volatile 关键字

了解 Java 并发编程中的 volatile 关键字

&#x1f60a; 作者&#xff1a; 一恍过去 &#x1f496; 主页&#xff1a; https://blog.csdn.net/zhuocailing3390 &#x1f38a; 社区&#xff1a; Java技术栈交流 &#x1f389; 主题&#xff1a; 了解 Java 并发编程中的 volatile 关键字 ⏱️ 创作时间&#xff1a; …
阅读更多...
[NLP]LLM---FineTune自己的Llama2模型

[NLP]LLM---FineTune自己的Llama2模型

一 数据集准备 Let’s talk a bit about the parameters we can tune here. First, we want to load a llama-2-7b-hf model and train it on the mlabonne/guanaco-llama2-1k (1,000 samples), which will produce our fine-tuned model llama-2-7b-miniguanaco. If you’re …
阅读更多...
5分钟生成10条短视频,AI重构电商营销

5分钟生成10条短视频,AI重构电商营销

点击关注 文&#xff5c;姚 悦&#xff0c;编&#xff5c;王一粟 “我们将正式告别过去单一渠道投放的时代&#xff0c;走向一站式跨渠道品效联合经营的全新时代。”9月6日&#xff0c;在2023年其最重要的营销峰会上&#xff0c;淘天集团阿里妈妈市场部总经理穆尔说道。 当天…
阅读更多...
【C++】模拟实现二叉搜索树的增删查改功能

【C++】模拟实现二叉搜索树的增删查改功能

个人主页&#xff1a;&#x1f35d;在肯德基吃麻辣烫 我的gitee&#xff1a;C仓库 个人专栏&#xff1a;C专栏 文章目录 一、二叉搜索树的Insert操作&#xff08;非递归&#xff09;分析过程代码求解 二、二叉搜索树的Erase操作&#xff08;非递归&#xff09;分析过程代码求解…
阅读更多...
java从入门到起飞（八）——循环和递归

java从入门到起飞（八）——循环和递归

文章目录 Java循环1. 什么是循环&#xff1f;1.1 为什么需要循环&#xff1f;1.2 循环的分类 2. Java中的循环结构2.1 for循环2.2 while循环2.3 do-while循环 3. 循环控制语句3.1 break语句3.2 continue语句 4. 总结 Java递归1. 什么是递归2. 递归的原理3. 递归的实现4. 递归的…
阅读更多...
鼠标右键使用VSCode打开文件或文件夹配置

鼠标右键使用VSCode打开文件或文件夹配置

天行健&#xff0c;君子以自强不息&#xff1b;地势坤&#xff0c;君子以厚德载物。 每个人都有惰性&#xff0c;但不断学习是好好生活的根本&#xff0c;共勉&#xff01; 文章均为学习整理笔记&#xff0c;分享记录为主&#xff0c;如有错误请指正&#xff0c;共同学习进步。…
阅读更多...
算法通关村17关 | 透析跳跃游戏

算法通关村17关 | 透析跳跃游戏

1. 跳跃游戏 题目 LeetCode55 给定一个非负整数数组&#xff0c;最初位于数组的第一个位置&#xff0c;数组中的每个元素代表你再该位置可以跳跃的最大长度&#xff0c;判断你是否能够达到最后一个位置。 思路 如果当前位置元素如果是3&#xff0c;我们无需考虑是跳几步&#…
阅读更多...
04、javascript 修改对象中原有的属性值、修改对象中原有属性的名字(两种方式)、添加对象中新属性等的操作

04、javascript 修改对象中原有的属性值、修改对象中原有属性的名字(两种方式)、添加对象中新属性等的操作

1、修改对象中原有的属性值 其一、代码为&#xff1a; // 想将 obj 中的 flag 值&#xff0c;根据不同的值来变化(即&#xff1a;修改对象中原有的属性值)&#xff1b; let obj {"port": "port_0","desc": "desc_0","flag&quo…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023