【Java EE初阶九】多线程案例(线程池)
一、线程池的引入
引入池---->主要是为了提高效率;
最开始,进程可以解决并发编程的问题,但是代价有点大了,于是引入了 “轻量级进程” ---->线程
线程也能解决并发编程的问题,而且线程的开销比进程要小的多,但是如果线程太多,创建销毁线程的频率也会进一步提高,故此线程创建销毁的开销就不能忽视了。
为了解决上述问题,大佬们给出了两个解决方案:
1、引入轻量级线程---->也称为纤程/协程(节省了系统调度的开销)
协程的本质是程序员在用户态代码中进行调度,不是靠内核的调度器调度的—>节省了许多的调度上的开销;协程是在用户代码中,基于线程封装出来的,可能是N个协程对应1个线程,也可能是N个协程对应M个线程。
2、引入 “线程池”
线程池:把我们要使用的线程池提前创建好,这个线程执行完也不要直接释放而是存放到线程池中以备下次继续使用需要用这个线程的时候,再从线程池中拿,不需要的时候,就放在线程池中,并不会销毁它,这样就节省了创建/销毁线程的开销;
在这个使用的过程中,并没有真正的频繁创建销毁,而只是从线程池里面取线程使用,等使用完了在还给线程池;
为啥从线程池中取线程 比从系统中申请线程的创建更高效呢?
下面讲解一下关于用户态和内核态的说明;
假设在银行场景中,smallye要去这个银行办理一个业务,一般银行中大堂有复印机;这时,smallye没有带身份证复印件,此时smallye要去搞到身份证复印件,有两个选择:
其一选择:把身份证给柜员,让柜员帮smallye复印,但是这个操作是不可控的,可能这个柜员中途被老板安排了其他活,那这个时候,就不能帮smallye复印身份证了,要等忙完老板安排的活,再帮smallye复印身份证;
其二选择:smallye自己去大堂中复印身份证,这样就比较可控了,smallye可以很快的去到打印机,立马复印出来,再去办理他的业务。如下图所示:
上述例子中大堂就是用户态,柜台就是内核态;
从线程池中取线程,是纯用户态代码(可控) 通过系统申请创建线程,需要内核完成(不可控有风险);
2. 线程池的简单介绍
2.1 ThreadPoolExecutor类
在java标准库中,ThreadPoolExecutor类表示线程池,ThreadPoolExecutor类是参数最多的构造方法,如下图所示:
下面来详细讲解该构造方法里面的参数的具体含义:
1、核心线程数和最大线程数(int corePoolSize,int maximumPoolSize):
corePoolSize:核心线程数:(正式员工线程)
maximumPoolSize:最大线程数:(正式员工线程 + 实习员工线程)
eg:核心线程就是相当于公司里面的正式员工,同时最大线程数里面包含最大线程数和实习员工线程,对于实习员工线程来说就是就是可有可无的,当核心线程全部处于工作状态且还有大量的任务需要新的线程处理的时候,我们就会创建实习员工线程,来帮核心线程处理这些任务;当任务数量较少的时候,核心线程可以闲着,但是实习员工线程全部需要销毁;
2、保持存活时间和存活时间的单位(long KeepAliveTime,TimeUnit unit)
KeepAliveTime:保持存活时间:(实习生线程允许摸鱼的最大时间)
unit:存活时间的单位:可以是hour 、 min 、 s 、 ms
3、放任务的队列 (BlockkingQueue<Runnable> workQueue:)
和定时器类似,线程池中也可以持有多个任务,要执行的任务,使用Runnable来描述任务的主体。
4、线程工厂(ThreadFactory,threadFactory)
通过这个工厂类创建线程对象(Thread对象),工厂类里面有方法封装了new Thread的操作,同时给Thread设置了一些属性,我们想要创建线程的时候可以直接使用工厂类的方法创建。
eg:描述一个点,通过数学知识可以用二维坐标和极坐标来表示:二维坐标:(x,y) 极坐标:(r,α);故此我们通过new一个类来得到一个点,这个类里有两个构造方法,参数分别是(double x,double y),(double r,double α),那么这两个构造方法的参数类型都一样,构成不了重载,如下图所示:
以上显示出我们想要给java类提供更多的构造方法,但是受到重载的影响限制,为了解决上述问题,我们引入了“工厂模式”,做一下修改:
我们使用static修饰,更改方法名,通过不同的方法名获取类,在方法里new一个类,里面设置一些参数,再返回这个类,如下图所示:
这样的类,就称为工厂类,工厂类里面得到类的方法就称为工厂方法。
总的来说,通过静态方法来封装new操作,在这个静态方法设置不同的属性,构造对象的过程,就称为工厂模式。
5、拒绝策略(RejectExecutionHandler handler)
该参数是上述部分参数中最重要的一个;
在线程池中有一个阻塞队列,且该队列容纳线程数量有限,如果这个任务队列满了,这时有往线程池中添加任务,这时候线程池要学会拒绝,由拒绝策略,在java标准库中就提供了以下四种拒绝策略,如下图所示:
拒绝策略讲解:
第一个策略:会直接抛出一个异常,这样,旧的任务执行不了,新的任务也执行不了
第二个策略:把新的任务丢给添加任务队列的线程执行,不给入队列,同时旧的任务依然在执行
第三个策略:把最旧的任务丢弃,添加最新的任务进来
第四个策略:直接把新的任务丢弃了,不执行新的任务,旧的任务会继续执行
2.2 Executors类
ThreadPoolExecutor类本身使用起来比较复杂,java标准库给我们提供了另一个版本:把ThreadPoolExecutor封装了一下,这个类就是Executor工厂类,通过这个类创建出不同的线程池对象,在其内部,已经把ThreadPoolExecutor创建好了,并且设置了一些参数。
Executor的简单使用,其中主要方法有一下4个,如图:
eg:我们使用newFixedThreadPool(4)方法创建4固定个线程数目的线程池,再往里添加任务:
package thread;import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;public class ThreadDemo32 {public static void main(String[] args) {ExecutorService service = Executors.newFixedThreadPool(4);service.submit(new Runnable() {@Overridepublic void run() {System.out.println("smallye");}});}
}
结果如下:
至于如何确定使用Executor或ThreadPoolExecutor,主要是看具体的情况;
2.3 线程池的执行流程
主要有以下四个情况:
1、当有任务要让线程池里面的线程执行时,会比较工作线程数和核心线程数, 如果工作线程数 < 核心线程数,则会直接安排线程去执行这个任务。
2、当工作线程数 > 核心线程数,即线程池中的核心线程数满了,会添加进阻塞任务队列中,添加任务队列前也会判断任务队列是不是空,是空就阻塞等待。
3、如果线程池中的存活线程数 == 核心线程数,并且阻塞任务队列也满了,此时会判断是否到了最大线程数:maximumPoolSize,如果没有到达,就会让非核心线程去执行这个任务。
4、如果当前线程数到达了最大线程数,则会执行拒绝策略
2.4 关于线程池中创建多少线程
这是我们就需要关注该进程是cpu密集型还是io密集型;
假设一个进程中,所有线程都是cpu密集型,这时每个线程的工作都是在cpu上执行的,此时,线程池中的数目就不应该超过N(cpu的逻辑核心线程数)
假设一个进程中,所有线程都是IO密集型的,这时每个线程的大部分工作都是在等待IO,此时,线程池中的数目就可以远远超过N(cpu的逻辑核心线程数)
实际上一个进程中的线程,有cpu密集型的,也有IO密集型的,只是比例不同。由于程序的复杂性,很难直接对线程池进行预估,更准确的做法是通过实验 / 测试的方法,找出合适的线程数目;
3. 线程池的模拟实现
我们写代码实现一个简单的线程池:(直接写一个固定线程数目的线程池-->暂时不考虑线程的增加和减少),其中具体思路主要一下步骤:
- 提供构造方法,指定创建多少个线程池
- 在构造方法中,把这些线程都创建好
- 有一个阻塞队列,能够持有要执行的任务
- 提供submit方法,可以添加新的执行任务;
3.1 阻塞队列--->存放要执行的任务
// 就是一个用来保存任务的队列.private BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(1000);
3.2 submit方法--->添加任务的方法,任务添加到队列中
public void submit(Runnable runnable) throws InterruptedException {queue.put(runnable);}
3.3 构造方法--->指定创建多少个线程,线程在这个构造方法中都创建好了
// 通过 n 指定创建多少个线程public MyThreadPoolExecutor(int n) {for (int i = 0; i < n; i++) {Thread t = new Thread(() -> {// 线程要做的事情就是把任务队列中的任务不停的取出来, 并且进行执行while (true) {try {// 此处的 take 带有阻塞功能的.// 如果队列为 空, 此处的 take 就会阻塞.Runnable runnable = queue.take();// 取出一个任务就执行一个任务即可runnable.run();} catch (InterruptedException e) {e.printStackTrace();}}});t.start();threadList.add(t);}}
线程里面,取出一个任务就执行这个任务,如果队列里没有任务,就会阻塞等待,等有任务,再执行任务,如此循环往复;每创建一个线程,都要放进链表中,也要记得start,开启线程。
3.4 存放线程的链表--->每创建一个线程都放进链表中,这样也能让我们找到某个线程
//存放线程的链表
List<Thread> list = new ArrayList<>();
3.5 完整版代码
class MyThreadPoolExecutor {private List<Thread> threadList = new ArrayList<>();// 就是一个用来保存任务的队列.private BlockingQueue<Runnable> queue = new ArrayBlockingQueue<>(1000);// 通过 n 指定创建多少个线程public MyThreadPoolExecutor(int n) {for (int i = 0; i < n; i++) {Thread t = new Thread(() -> {// 线程要做的事情就是把任务队列中的任务不停的取出来, 并且进行执行while (true) {try {// 此处的 take 带有阻塞功能的.// 如果队列为 空, 此处的 take 就会阻塞.Runnable runnable = queue.take();// 取出一个任务就执行一个任务即可runnable.run();} catch (InterruptedException e) {e.printStackTrace();}}});t.start();threadList.add(t);}}public void submit(Runnable runnable) throws InterruptedException {queue.put(runnable);}
}public class ThreadDemo33 {
//指定线程池的数目为4个线程,添加1000次任务到阻塞队列中,
//让着4个线程从阻塞队列中拿任务,再执行任务
//任务:打印0~1000,并显示是哪个线程打印的;public static void main(String[] args) throws InterruptedException {MyThreadPoolExecutor executor = new MyThreadPoolExecutor(4);for (int i = 0; i < 1000; i++) {int n = i;executor.submit(new Runnable() {@Overridepublic void run() {System.out.println("执行任务" + n + " , 当前线程为: " + Thread.currentThread().getName());}});}}
}
结果如下:
ps:关于线程池案例的内容就到这里了,如果大家感兴趣的话,就请一键三连哦!!!
相关文章:
【Java EE初阶九】多线程案例(线程池)
一、线程池的引入 引入池---->主要是为了提高效率; 最开始,进程可以解决并发编程的问题,但是代价有点大了,于是引入了 “轻量级进程” ---->线程 线程也能解决并发编程的问题,而且线程的开销比进程要小的多&…...
理解 Node.js 中的事件循环
你已经使用 Node.js 一段时间了,构建了一些应用程序,尝试了不同的模块,甚至对异步编程感到很舒适。但是有些事情一直在困扰着你——事件循环(Event Loop)。 如果你像我一样,花费了无数个小时阅读文档和观看…...
Mac 软件出现「意外退出」及「打不开」解决方法
Mac 软件出现「意外退出」及「打不开」解决方法 软件出现意外退出及软件损坏的情况,这是因为苹果删除了TNT的证书,所以大部分TNT破解的Mac软件会出现无法打开,提示意外退出。 终端需先安装Xcode或Apple命令行工具 如未装Xcode可以使用下列命…...
随机森林 3(代码)
通过随机森林 1和随机森林 2 的介绍,相信大家对理论已经了解的很透彻,接下来带大家敲一下代码,不懂得可以加我入群讨论。 第一份代码是比较原始的代码,第二份代码是第一段代码中引用的primitive_plot,第三份代码是使用…...
勒索事件急剧增长,亚信安全发布《勒索家族和勒索事件监控报告》
近期(12.15-12.21)态势快速感知 近期全球共发生了247起攻击和勒索事件,勒索事件数量急剧增长。 近期需要重点关注的除了仍然流行的勒索家族lockbit3以外,还有本周top1勒索组织toufan。toufan是一个新兴勒索组织,本周共发起了108起勒索攻击&a…...
LeetCode1523. Count Odd Numbers in an Interval Range
文章目录 一、题目二、题解 一、题目 Given two non-negative integers low and high. Return the count of odd numbers between low and high (inclusive). Example 1: Input: low 3, high 7 Output: 3 Explanation: The odd numbers between 3 and 7 are [3,5,7]. Exam…...
E中国铜金属行业需求前景及未来发展机遇分析报告2024-2030年
E中国铜金属行业需求前景及未来发展机遇分析报告2024-2030年 &&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&&& 《报告编号》: BG471816 《出…...
python SVM 保存和加载模型参数
在 Python 中,你可以使用 scikit-learn 库中的 joblib 或 pickle 模块来保存和加载 SVM 模型的参数。以下是一个简单的示例代码,演示了如何使用 joblib 模块保存和加载 SVM 模型的参数: 保存模型参数: from sklearn import svm …...
JAVA进化史: JDK12特性及说明
JDK 12于2019年3月发布。这个版本相对于之前的版本来说规模较小,主要集中在一些改进和实验性的特性上。以下是JDK 12的一些主要特性: 引入了实验性的Shenandoah垃圾收集器 JDK 12引入了实验性的Shenandoah垃圾收集器,旨在实现极低的暂停时间…...
Databend 的算力可扩展性
作者:尚卓燃(PsiACE) 澳门科技大学在读硕士,Databend 研发工程师实习生 Apache OpenDAL(Incubating) Committer PsiACE (Chojan Shang) GitHub 对于大规模分布式数据处理系统,为了更好应对数据、流量、和复杂性的增长…...
「解析」Windows 如何优雅使用 Terminal
所谓工欲善其事必先利其器,对于开发人员 Linux可能是首选,但是在家学习的时候,我还是更喜欢使用 Windows系统,首先是稳定,其次是习惯了。当然了,我还有一台专门安装 Linux系统的小主机用于学习Linux使用&am…...
Linux第18步_安装“Ubuntu系统下的C语言编译器GCC”
Ubuntu系统没有提供C/C的编译环境,因此还需要手动安装build-essential软件包,它包含了 GNU 编辑器,GNU 调试器,和其他编译软件所必需的开发库和工具。本节用于重点介绍安装“Ubuntu系统下的C语言编译器GC&a…...
【Linux】Linux 基础命令 crontab命令
1.crontab命令 crond 是linux下用来周期性的执行某种任务或等待处理某些事件的一个守护进程,与windows下的计划任务类似,当安装完成操作系统后,默认会安装此服务 工具,并且会自动启动crond进程,crond进程每分钟会定期检查是否有要执行的任务,如果有要执行的任务,则自动…...
14:00面试,14:08就出来了,问的问题过于变态了。。。
从小厂出来,没想到在另一家公司又寄了。 到这家公司开始上班,加班是每天必不可少的,看在钱给的比较多的份上,就不太计较了。没想到10月一纸通知,所有人不准加班,加班费不仅没有了,薪资还要降40…...
Ubuntu envs setting
1. change the chmod of folders sudo chown -R $USER:$USER /home/anaconda3 2. torch.cuda.is_available()返回false change conda installation to pip. zai qi ta huan jing pei zhi dou mei wen ti de qing kuang xia , zai shi shi zhe ge fang fa. # CUDA 11.7 con…...
Windows 下用 C++ 调用 Python
文章目录 Part.I IntroductionChap.I InformationChap.II 预备知识 Part.II 语法Chap.I PyRun_SimpleStringChap.II C / Python 变量之间的相互转换 Part.III 实例Chap.I 文件内容Chap.II 基于 Visual Studio IDEChap.III 基于 cmakeChap.IV 运行结果 Part.IV 可能出现的问题Ch…...
九州金榜|家庭教育一招孩子不在任性
有一次和朋友一块聚餐,邻座是一位妈妈、和她大概七八岁的儿子,小男孩长得很帅气,没有像同龄人那样调皮捣乱,而是和妈妈很温馨的就餐。 看的出来一家人的素质很高,就餐过程中桌面保持的很整洁,交流声音也不…...
爬虫案列 --抖音视频批量爬取
""" 项目名称: 唯品会商品数据爬取 项目描述: 通过requests框架获取网页数据 项目环境: pycharm && python3.8 作者所属: 几许1. 对主页抓包 , 鼠标移动到视频位置视频自动播放获得视频数据包 2. 对视频数据包地址进行解析 , 复制链接 , 进行检索 3. 获…...
【React系列】React中的CSS
本文来自#React系列教程:https://mp.weixin.qq.com/mp/appmsgalbum?__bizMzg5MDAzNzkwNA&actiongetalbum&album_id1566025152667107329) 一. React中的css方案 1.1. react 中的 css 事实上,css 一直是 React 的痛点,也是被很多开发…...
基于Kettle开发的web版数据集成开源工具(data-integration)-应用篇
目录 📚第一章 基本流程梳理📗页面基本操作📗对应后台服务流程 📚第二章 二开思路📗前端📗后端 🔼上一集:基于Kettle开发的web版数据集成开源工具(data-integration)-介绍篇 *️⃣主…...
51单片机三种编译模式的相互关系
51单片机三种编译模式的相互关系 编译模式默认存储类型RAM使用规模变量使用特点SAMLLdata128B片内RAM使用规模CPU访问数据速度快,但存储容量较小COMPACTpdata258B片外分页RAM速度和容量介于上下两者之间LARGExdata64KB片外RAMCPU访问数据的速度较慢,但存…...
java 千帆大模型 流式返回
聊天有两个接口,第一个是获取token, 第二个是聊天接口,具体参照官方文档 下面是流式调用聊天接口,单次的,不含上下文 Value("${qianfan.apiKey}")private String apiKey;Value("${qianfan.secretKey}")private String secretKey;Value("${qianfan.to…...
全新互联网洗衣洗鞋小程序平台新模式
互联网洗衣洗鞋新模式, 全新软件升级 对接各大平台 扩大营销渠道,增加效益!...
js 对于一些脚本中对于url的一些参数获取
js 对于一些脚本中对于url的一些参数获取 获取当前浏览器的链接上的参数(不使用vue / react 等框架)仅用在一些脚本上的使用 获取当前浏览器的链接上的参数(不使用vue / react 等框架)仅用在一些脚本上的使用 const query {} const params new URLSear…...
IEDA中tomcat日志乱码解决
文章目录 乱码样式原因解决方案参考 乱码样式 原因 乱码原因是编码格式的问题,编码格式不统一,导致显示乱码。 解决方案 统一编码格式。 打开tomcat的配置文件,conf/logging.properties,进行如下修改 进入idea的安装文件中,b…...
计算机网络实验(六):三层交换机实现VLAN间路由
一、实验名称:三层交换机实现VLAN间路由 二、实验原理 2.1. VLAN基本配置 在交换网络中,为了实现对物理网络的逻辑划分,引入了VLAN(虚拟局域网)的概念。VLAN通过将不同的设备划分到不同的虚拟网络中,实现了逻辑隔离。基本配置包括在交换机上创建VLAN、将端口划分到相应…...
Flutter中showModalBottomSheet的属性介绍和使用
在Flutter中,showModalBottomSheet是一个常用的工具,用于在屏幕底部显示模态底部面板。了解其属性将帮助您更好地定制和控制底部模态框的外观和行为。 showModalBottomSheet的常用属性 1. context: 类型: BuildContext描述: 表示当前构建上下文&#…...
机器学习 -- k近邻算法
场景 我学习Python的初衷是学习人工智能,满足现有的业务场景。所以必须要看看机器学习这一块。今天看了很久,做个总结。 机器学习分为深度学习和传统机器学习 深度学习 深度学习模型通常非常复杂,包含多层神经网络,每一层都包含…...
安全测试之SSRF请求伪造
前言 SSRF漏洞是一种在未能获取服务器权限时,利用服务器漏洞,由攻击者构造请求,服务器端发起请求的安全漏洞,攻击者可以利用该漏洞诱使服务器端应用程序向攻击者选择的任意域发出HTTP请求。 很多Web应用都提供了从其他的服务器上…...
php composer安装
引言 Composer 是 PHP 中的依赖管理工具。它允许您声明您的项目所依赖的库,并且它将为您管理(安装/更新)它们。 官网链接:Introduction - Composer 安装 要在当前目录中快速安装 Composer,请在终端中运行以下脚本。…...
网站建设宣传单页/香蕉和忘忧草对焦虑的影响
8、DataGrid 显示表格数据。水很深。 详情见:MSDN:https://msdn.microsoft.com/enus/library/system.windows.c (1)构造函数,没有返回值,只有访问修饰符,名称跟类名称可一模一样 (…...
网站突然显示 建设中/微信营销软件哪个好用
m_Orchestrate learning system---十二、为什么thinkphp验证场景里面的多个属性之间是逗号一、总结一句话总结:因为是数组啊1 protected $scene [2 edit > [name,age],3 ];1、原生js如何获取html内容?1 2 functioncheck(){3 varrepassworddocument.g…...
专做国际时事评论网站/网络营销具有哪些特点
比如像比较简单的关键词“交流”、“心得”并没有可供选择的选项,怎么办?而且输入后按确定也没有用。 解决方法 可以直接在输入后回车,然后确定。 更新20200330 本篇博客的关键词可见:...
b2b平台如何赚钱/整站优化
##c ###算法一:vector做法 #include <bits/stdc.h> using namespace std;int main() {vector<int> arr;arr.reserve(10010); //将arr的容量(capacity)扩充至10010(放大到最大数据量)int num;cin >> num;for (int i 0; i …...
网站开发高级工程师专业/今日最新消息
imei 设备号 imsi 串号 客户号 都是15位 iccid 20位...
足球网站开发/媒体广告投放平台
题意:给你数组a,有两个操作 1 l r,计算l到r的答案:a[l]La[l1](L−1)⋯a[r−1]2a[r] (L is the length of [ l, r ] that equals to r - l 1),或者 2 i b:把第i个换成b 思路:用一个树状数组存i的…...