ThreadPoolExecutor线程池解析

ThreadPoolExecutor线程池解析

一、ThreadPoolExecutor常见参数

jdk中Executors提供了几种常用的线程池,底层都是ThreadPoolExecutor。

    public ThreadPoolExecutor(int corePoolSize,//核心线程数int maximumPoolSize,// 最大线程数long keepAliveTime,//非核心线程空闲存活时间TimeUnit unit,// 时间单位BlockingQueue<Runnable> workQueue,// 工作队列ThreadFactory threadFactory,//线程工厂RejectedExecutionHandler handler //线程池拒绝策略
) {}

核心线程是正式工,最大线程数中除去这部分都是临时工(工作队列满了才用到),有活就干,没活就歇着,歇的时间长了就被干掉,工作队列中就是排好的活,当正式工和零时工都在干活,排期也排满了,就执行拒绝策略。

Pool

图片转载自https://blog.csdn.net/Anenan/article/details/115603481

二、ThreadPoolExecutor线程池中异常捕获处理方案

submit可以提交Callable和Runnable两种类型的task,execute只能执行Runnable.
submit在执行task的时候,会将其封装成RunnableFuture,这样使得有返回结果,可以通过get获取返回值,但是在异常处理方面和execute会有区分。

1、submit、execute执行task出现异常

使用ThreadPoolExecutor提交任务时,submit、execute两种方式都可,但submit只是提交了任务,即使任务中出现异常,也不会有任何提示。

 @org.junit.jupiter.api.Test
void testF1() {ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 5, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<>());executor.submit(new Task());executor.execute(new Task());System.out.println("over");}class Task implements Runnable {@Overridepublic void run() {int i = 1/0;}
}

结果 Exception in thread “pool-1-thread-2” java.lang.ArithmeticException: / by zero
submit提交任务都不会捕捉异常,在get才会得到异常。

 Future<?> future =executor.submit(new Task());future.get();

此时会抛出异常

2、异常处理
2.1 在task中try…catch
 @org.junit.jupiter.api.Testvoid testF1() throws ExecutionException, InterruptedException {List<String> list = Arrays.asList("hello", "world");ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 5, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<>());executor.submit(new Task());executor.execute(new Task());System.out.println("over");}class Task implements Runnable {@Overridepublic void run() {try {int i = 1/0;}catch (Exception e){System.out.println("异常");}}}

task会进入catch中

over 异常 异常

2.2使用Thread.setDefaultUncaughtExceptionHandler方法自定义ThreadFactory

通过自定义ThreadFactory中生产的Thread,线程池在execute方法中出发异常会执行setDefaultUncaughtExceptionHandler中定义的内容,同样对submit无效。

//1.实现一个自己的线程池工厂
ThreadFactory factory = (Runnable r) -> {//创建一个线程Thread t = new Thread(r);//给创建的线程设置UncaughtExceptionHandler对象 里面实现异常的默认逻辑t.setDefaultUncaughtExceptionHandler((Thread thread1, Throwable e) -> {System.out.println("线程工厂设置的exceptionHandler" + e.getMessage());});return t;
};ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 5, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<>(),factory);executor.execute(new Task());// 线程工厂设置的exceptionHandler
executor.submit(new Task()); // 无反应
2.3 重写ThreadPoolExecutor的afterExecute方法

通过重写ThreadPoolExecutor的afterExecute方法,可以处理submit和execute异常,但是submit提交的需要加一步判断。

ThreadPoolExecutor executor = new ThreadPoolExecutor(2, 5, 1, TimeUnit.SECONDS, new LinkedBlockingQueue<>()) {@Overrideprotected void afterExecute(Runnable r, Throwable t) {//默认捕获execute中的异常if (t != null) {System.out.println("afterExecute里面获取到excute提交的异常信息,处理异常" + t.getMessage());}//如果r的实际类型是FutureTask 那么是submit提交的,所以可以在里面get到异常if (r instanceof FutureTask) {try {Future<?> future = (Future<?>) r;//get获取异常future.get();} catch (Exception e) {System.out.println("afterExecute里面获取到submit提交的异常信息,处理异常" + e);}}}
};executor.execute(new Task());//处理异常
executor.submit(new Task());//处理异常

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

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

大数据产品有哪些分类?各类里知名大数据产品都有哪些?

随着互联网技术的持续进步和全球数字化转型的推进&#xff0c;我们正处于一个数据爆炸的时代。在这样的大背景下&#xff0c;大数据已经逐渐崭露头角&#xff0c;成为了推动各行各业发展的关键因素和核心资源。大数据不仅仅是指数据的规模巨大&#xff0c;更重要的是它蕴含的价…

安卓手机APP开发的媒体内容部分__重中之重的内容变现渠道___插入广告

安卓手机APP开发的媒体内容部分__重中之重的内容变现渠道___插入广告 目录 客户端的插入广告 声明式的广告的支持 有广告的播放列表 ExoPlayer IMA库 用户界面上的考虑 伴随广告 独立广告 使用第三方的广告SDK 服务器端的插入广告 ExoPlayer IMA库 用户界面上的考虑…

spring-aop的使用(注解 +配置类的方式)(多个增强类的优先级问题)

spring-aop 首先&#xff0c;准备一个接口以及其实现类 Calculator接口&#xff1a;src/main/java/com.atguigu.service/Calculator接口 package com.atguigu.service;public interface Calculator {int add(int i, int j);int sub(int i, int j);int mul(int i, int j);int…

docker 容器指定utf-8编码

在运行 Docker 容器的时候&#xff0c;如果容器内应用需要使用 UTF-8 编码来正常处理中文&#xff0c;你可以通过设置环境变量来指定编码。 可以使用 -e 或者 --env 标志来设置环境变量。比如&#xff0c;设置 LANG 和 LC_ALL 环境变量为 C.UTF-8 或者 en_US.UTF-8&#xff1a…

量子信息产业生态研究(一):关于《量子技术公司营销指南(2023)》的讨论

写在前面。量子行业媒体量子内参&#xff08;Quantum Insider&#xff09;编制的《量子技术公司营销指南》是一本实用的英文手册&#xff0c;它旨在帮助量子科技公司建立有效的营销策略&#xff0c;同时了解如何将自己定位成各自的行业专家。本文对这篇指南的主要内容进行了翻译…

ubuntu上安装截图工具-Flameshot及其使用步骤说明

Flameshot 火焰截图-推荐 安装命令&#xff1a; sudo apt install flameshot 操作方式&#xff1a; 1&#xff09;打开 2&#xff09;右上角弹窗 3&#xff09;点击后弹出 选择进行截图 4&#xff09;截图后再选择分享 5&#xff09;再重新选择区域&#xff0c;出现编辑…

【蓝桥杯】2024年第15届真题题目

试题 A: 握手问题 本题总分&#xff1a; 5 分 【问题描述】 小蓝组织了一场算法交流会议&#xff0c;总共有 50 人参加了本次会议。在会议上&#xff0c; 大家进行了握手交流。按照惯例他们每个人都要与除自己以外的其他所有人进 行一次握手&#xff08;且仅有一次&a…

Android bug Unresolved reference: BR

新建项目后 导入viewBinding 编译后提示 Unresolved reference: BR 解决办法 app 目录下 build.gradle 中 plugins 节点 添加 id kotlin-kapt参考 https://stackoverflow.com/questions/77409050/could-not-find-androidx-corecore-ktx1-8-10

npm包管理工具升降级

一、npm降级 1.接大版本号&#xff0c;降级到大版本最新的小版本 npm install npm5 -g 2.接指定版本号 npm install npm5.01.01 -g 二、npm升级 升级到最新版本 npm install npm -g 详细参考&#xff1a;nodejs与npm版本对应关系以及使用nvm管理node版本以及降npm版本-CSDN博…

CMD 汉字乱码处理

windows 11 cmd汉字乱码问题处理 一 查看CMD编码 win R 输入 cmd 输入 chcp 查看回显信息 “936”代表的意思就是 GBK (汉字内码扩展规范)&#xff0c;通常情况下GBK也是cmd的默认编码。 解决乱码需要把编码改为 utf-8 二 临时修改 在 终端中输入 chcp 65001 三 永久修改…

蓝桥杯嵌入式第十五届省赛真题题目

蓝桥杯昨天也考完了&#xff0c;大家可以看看题目 客观题题目 程序题题目

【复读EffectiveC++17】条款17:以独立语句将newed对象置入智能指针

条款17&#xff1a;以独立语句将newed对象置入智能指针 此条款&#xff0c;依然是针对智能指针的补充&#xff0c;内容分为两个部分&#xff1a; 有什么问题怎么解决 一、有什么问题 取原书的例子&#xff1a; 写一个函数&#xff0c;用来揭示程序处理的优先权。 再写一个函…

Opencv图像 ROI 与 mask 掩膜(找到感兴趣的区域)

在OpenCV中&#xff0c;可以使用ROI&#xff08;Region of Interest&#xff09;技术来处理图像中的感兴趣区域。ROI是指图像中的一个子区域&#xff0c;它可以是矩形、多边形或其他形状。使用ROI技术可以在不影响图像其他部分的情况下&#xff0c;对图像的某个区域进行操作。 …

【Python函数和类4/6】递归与匿名函数

目录 目标 匿名函数 多个形参 匿名函数的局限性 递归 语言例子 数学例子 递归的实现 递归代码 练习 总结 目标 在之前的博客中&#xff0c;我们学习了定义函数、调用函数以及设置函数的参数。在今天&#xff0c;我们会补充函数的两个常见的知识点&#xff0c;一个是匿…

学浪视频怎么缓存?

缓存学浪视频轻而易举&#xff01;推荐使用“小浪助手”&#xff0c;一款便捷的工具&#xff0c;助你轻松实现。工具已经预先打包好&#xff0c;需要的朋友可以自行下载。快试试&#xff0c;畅享学习吧&#xff01; 学浪下载器链接&#xff1a;https://pan.baidu.com/s/1y7vcq…

spring容器

spring容器 实现方式 spring中提供了各式各样的IOC容器的实现供用户选择和使用&#xff0c;使用什么样的容器取决于用户的需要 BeanFactory 该接口是最简单的容器&#xff0c;提供了基本的DI支持。最常用的BeanFactory实现是XmlBeanFactory类&#xff0c;根据XML文件中的定义加…

STL--什么是迭代器的失效

迭代器失效指的是当容器发生变化时&#xff0c;之前获取的迭代器不再指向有效的元素或者不再有意义&#xff0c;这种情况在 C STL 编程中比较常见。迭代器失效主要发生在以下几种情况&#xff1a; 1.元素被删除或修改: 如果你删除了某个迭代器所指向的元素&#xff0c;那么这个…

RetinalNet论文笔记

RetinalNet 概述1. 引言2. 相关工作3. 焦点损失4. RetinaNet Detector 检测器5. 实验6. 结论 3. Focal loss3.1. 平衡交叉熵3.2. 焦点损失定义3.3. 类别不平衡和模型初始化3.4. 类别不平衡和两阶段检测器 4. RetinaNet Detector特征金字塔网络骨干&#xff08;Feature Pyramid …

前端的导航栏数据是前端自己写好还是建议从后端拿数据渲染出来吗?

关于前端导航栏的数据来源&#xff0c;这实际上取决于具体的项目需求和应用场景。以下是两种方式的优缺点&#xff0c;供您参考&#xff1a; 前端自己写好&#xff1a; 优点&#xff1a; 加载速度快&#xff1a;导航栏数据直接嵌入前端代码中&#xff0c;无需等待后端接口响…

PostgreSQL入门到实战-第二十五弹

PostgreSQL入门到实战 PostgreSQL中表连接操作(九)官网地址PostgreSQL概述PostgreSQL中NATURAL JOIN命令理论PostgreSQL中NATURAL JOIN命令实战更新计划 PostgreSQL中表连接操作(九) 使用PostgreSQL NATURAL JOIN从两个表中查询数据。 官网地址 声明: 由于操作系统, 版本更新…