线程池的基本理解以及使用

2023-09-22 10:59:11

首先线程池是一种管理和复用线程的机制,它可以用来提高多线程编程的效率和性能。

线程池的概念:
线程池是一种线程管理的机制,它通常由一个线程池管理器(ThreadPoolExecutor)和一组线程组成。线程池管理器负责创建、管理和调度线程。当任务到达时,线程池会从线程池中预先创建的线程中选一个来执行任务,如果没有空闲线程,则将任务放入等待队列中,等待执行。

线程池的优点:
1. 资源管理:线程池可以避免频繁地创建和销毁线程,从而节约系统资源。
2. 提高性能:线程池可以提供线程复用,避免线程的频繁切换和创建,降低了线程创建和销毁的开销,提高了系统的响应速度和吞吐量。
3. 提供线程的可管理性:线程池可以限制并发线程的数量,通过对线程的管理和调度,防止线程的堆积和资源耗尽。
4. 控制并发:线程池可以通过设置线程数量限制来控制并发度,以避免系统因并发过高而导致资源抢占和竞争造成的问题。

线程池的缺点:
1. 配置管理复杂:合理配置线程池的核心线程数、最大线程数、队列大小等参数需要对系统负载特性和任务资源需求进行分析,配置不当可能导致性能下降或资源浪费。
2. 对于短时间的高并发请求,线程池可能无法满足需求,因为线程池的线程数是有限的。

线程池的工作流程如下:
1. 创建线程池,指定线程池的配置参数,如核心线程数、最大线程数、队列大小等。
2. 当有任务到达时,线程池会按照一定的策略选择一个空闲的线程来执行任务,如果没有空闲线程,则执行下一步。
3. 如果线程池的线程数小于最大线程数,则创建一个新的线程来执行任务,如果线程数已达到最大线程数,则执行下一步。
4. 将任务放入等待队列,等待执行。
5. 当有线程执行完任务后,会继续从等待队列中取出任务执行,直到所有任务执行完毕。
6. 关闭线程池。

总结:

线程池是一种用来管理和复用线程的机制,它可以提高多线程编程的效率和性能。线程池的优点包括资源管理、性能提升和线程的可管理性,缺点是配置管理复杂和对于短时间的高并发请求可能无法满足需求。

Java中提供了Executor框架,来创建和管理线程池。主要包括以下四种。

1. FixedThreadPool固定大小线程池:
 

ExecutorService executorService = Executors.newFixedThreadPool(5);


创建一个固定大小的线程池,一旦池中所有的线程都被使用完,新的任务就会等待,直到有线程空闲出来。

2. CachedThreadPool可缓存线程池:

 

ExecutorService executorService = Executors.newCachedThreadPool();


创建一个可缓存的线程池。如果线程池的当前规模超过了处理需求,那么就会回收空闲线程,当需求增加时,也可以添加新的线程。

3. SingleThreadExecutor单线程池:

 

ExecutorService executorService = Executors.newSingleThreadExecutor();



创建一个单线程执行程序,它可以进行串行执行所有提交的任务。

4. ScheduledThreadPool定时或周期执行线程池:

 

ScheduledExecutorService executorService = Executors.newScheduledThreadPool(5);



创建一个线程池,它可以安排在给定延迟后运行命令,或者定期执行任务。

以上创建线程池的方式都可使用execute(Runnable) 或 submit(Runnable/Callable) 去提交任务,其中submit()方法可有返回值。

使用线程池的主要原因是减少在创建和销毁线程上所花的时间以及系统资源的开销,解决资源不足,系统繁忙超负荷等问题。如果不使用线程池,自己手动创建线程的话,可能会遇到OOM等问题。

注:Executors对线程池的支持主要通过四种线程池工厂方法来体现:

1) newFixedThreadPool 创建一个可重用固定线程数的线程池
2) newCachedThreadPool 创建一个可缩小线程数的线程池
3) newSingleThreadExecutor 创建一个只包括一个线程的线程池
4) newScheduleThreadPool 创建一个线程池,执行定时任务,或者可以延迟执行的任务。

但在阿里巴巴Java开发手册中明确指出了:线程池不允许使用Executors去创建,而是通过ThreadPoolExecutor的方式,这样的处理方式让开发人员对线程池的运行规则有明确的认识,避免资源耗尽的风险。
一般构造一个ThreadPoolExecutor需要以下几个参数:

corePoolSize:线程池的基本大小
maximumPoolSize:线程池最大线程数

keepAliveTime(必需):线程闲置超时时长

unit(必需):指定 keepAliveTime 参数的时间单位。常用的有:TimeUnit.MILLISECONDS(毫秒)、TimeUnit.SECONDS(秒)、TimeUnit.MINUTES(分)。
workQueue:线程等待队列
threadFactory:创建线程的工厂
rejectHandler:当线程池和队列都满了之后的饱和策略。

更多推荐

设计的思考,设计是什么? 优漫动游

设计是什么?这是个大问题,但也是个小众问题。可能有很多人会说,“设计就是“你所需要的”东西。”这个回答或许说的很直白:因为有很多人都是从自己的角度去思考问题。”——我想做好一件事情。”——这是我喜欢做好一件事情的动力之一。”——但是这些解释是片面的。为什么?因为大家都会发现:自己所做的任何事情都不可能解决所有的问题。而

图论第四天|127. 单词接龙、841. 钥匙和房间、463. 岛屿的周长

127.单词接龙★文档讲解:代码随想录-127.单词接龙状态:开始学习。(★:需要多次回顾并重点回顾)思路:本题需要解决两个问题:图中的线是如何连在一起的题目中并没有给出点与点之间的连线,而是要我们自己去连,条件是字符只能差一个,所以判断点与点之间的关系,要自己判断是不是差一个字符,如果差一个字符,那就是有链接。起点和

大数据快速入门开发环境篇:CentOS 7安装配置Hadoop大数据框架开发环境

注意:在开始安装之前,请确保您的CentOS7系统已经正确安装和配置了Java。Hadoop需要Java来运行。目录一、下载与配置Hadoop框架:1.1、下载与环境变量设置1.2、XML配置文件Hadoop设置1.3、格式化HDFS二、Hadoop3.x版本中hdfs命令的问题解决与配置方法2.1、问题描述与解决方法

时序预测 | MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元时间序列预测

时序预测|MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元时间序列预测目录时序预测|MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元时间序列预测效果一览基本介绍模型搭建程序设计参考资料效果一览基本介绍MATLAB实现BO-BiGRU贝叶斯优化双向门控循环单元时间序列预测。基于贝叶斯(bayes)优化

【Unity2D】提升tilemap地图绘制速度的技巧

先安装好对应的包正文教程下面的都是我找到的不错教程,学会了也就能少花冤枉钱,不被Unity中国坑。【Unity小技巧】Unity2DTileMap的探究(最简单,最全面的TileMap使用介绍)这个博客会详细讲解了规则瓦片的各种功能,帮助我们可以快速自动地铺好地图,偏向俯视角地图制作,但是太全了,也没个参照,所以对于新

opencv 轮廓顶点重新排序----四边形

defreorder(myPoints):#print(myPoints.shape)#创建一个与myPoints具有相同形状和类型的数组myPointsNew=np.zeros_like(myPoints)#数组重塑为一个4行2列的数组myPoints=myPoints.reshape((4,2))#计算myPoin

三维模型3DTile格式轻量化压缩处理的数据质量提升方法分析

三维模型3DTile格式轻量化压缩处理的数据质量提升方法分析在处理三维模型3DTile格式的轻量化压缩时,如何在减少数据量的同时,保证或提升数据质量是一大挑战。以下为一些提升数据质量的方法分析:改进几何简化算法:在进行几何简化时,除了考虑顶点数量的减少,更要注重误差度量和形状特征。选择具有视觉优化功能的算法,例如基于四

Api接口加密策略

接口安全要求:1.防伪装攻击(案例:在公共网络环境中,第三方有意或恶意的调用我们的接口)2.防篡改攻击(案例:在公共网络环境中,请求头/查询字符串/内容在传输过程被修改)3.防重放攻击(案例:在公共网络环境中,请求被截获,稍后被重放或多次重放)4.防数据信息泄漏(案例:截获用户登录请求,截获到账号、密码等)设计原则:1

java - 散列算法 SHA-256 hash值计算

文章目录前言java-散列算法SHA-256hash值计算1.散列算法是什么?2.散列算法的主要特征是什么?3.计算SHA-256值有没有可能重复4.SHA-256算法实现示例前言如果您觉得有用的话,记得给博主点个赞,评论,收藏一键三连啊,写作不易啊^_^。而且听说点赞的人每天的运气都不会太差,实在白嫖的话,那欢迎常来

MQTT Paho Android 支持SSL/TLS(亲测有效)

MQTTPahoAndroid支持SSL/TLS(亲测有效)登录时支持ssl的交互这是调测登录界面设计代码中对ssl/tls的支持使用MqttAndroidClient配置mqtt客户端请求时,不加密及加密方式连接存在以下几点差异:url及端口差异valuri:String=if(tlsConnection){"ssl

CKA真题分析-2023年度

补充信息#补全#aptinstallbash-completionsource<(kubectlcompletionbash)#kubectlconfigget-contexts#cat~/.kube/config|grepcurrent#kubectlconfigcurrent-contextkubectlconfi

热文推荐