【JavaEE】【多线程】线程池

目录

  • 一、线程池
  • 二、ThreadPoolExecutor类讲解
    • 2.1 构造方法
      • 2.1.1 corePoolSize和maximumPoolSize
      • 2.1.2 KeepAliveTime和unit
      • 2.1.3 workeQueue
      • 2.1.4 threadFactory
      • 2.1.5 handler
  • 三、简易构造线程池
  • 四、自己实现一个简单线程池

一、线程池

线程池:线程池可以简单理解为存放多个线程的一段空间。

线程池的作用:就是把线程提前创建好,放入线程池中,需要线程时从线程池中取,线程用完归还到线程池中。这样就可以减少线程创建的开销。

一个操作系统包含内核和以及其它计算机系统所必须的组件,
而内核中包含了操作系统的各种核心功能:管理硬件设备,给软件提供稳定的运行环境。
而在计算机中认为有一段代码在应用程序中完成,执行过程是可控的,而在内核中完成的过程是不可控的。而可控的操作比不可控更加高效。

直接创建线程比从线程池拿线程开销小的原因:

  • 直接创建线程,需要内核配合完成,是不可控的;
  • 先创建好在从线程池中去取,取线程就是可控的操作。

Java标准库中提供的类ThreadPoolExecutor就是创建线程池的类。

二、ThreadPoolExecutor类讲解

2.1 构造方法

在ThreadPoolExecutor类中主要提供了下面四种不同参数的构造方法。
我们讲解第四种7种参数版本中每个参数代表什么。

2.1.1 corePoolSize和maximumPoolSize

int corePoolSize代表核心线程数的个数。核心线程随着线程池的创建而创建,销毁而销毁。
int maximumPoolSize代表最大线程数。就是核心线程数与非核心线程数之和。非核心线程是自适应创建的,不繁忙的时候就销毁,繁忙的时候在创建。

2.1.2 KeepAliveTime和unit

long KeepAliveTime代表非核心线程允许空闲的最大时间。
TimeUnit unit代表时间单位。
TimeUnit是一个枚举类。

2.1.3 workeQueue

blockingQueue<Runnable> workQueue代表工作队列,也是一个阻塞队列。线程池本身就是一个生产者消费者模型,调用submit方法就是在生产,线程池中的线程就是消费者。

2.1.4 threadFactory

ThreadFactory threadFactory给线程Thread类提供的工厂类。
ThreadFactory是一个接口。

并不能直接出来一个对象,需要我们自己创建类实现该接口。
也可以使用Java中自带的默认的方式Executors类下的defaultThreadFactory方法:Executors.defaultThreadFactory();

工厂模式:工厂模式就是主要用来弥补构造方法的缺陷的一种设计模式。当构造方法因为重载限制时,可以当前类中使用static静态方法(这个静态方法也称为工厂方法)或者单独使用一个类提供静态方法(这个类称为工厂类),在静态方法中调用构造方法。

例子:我们表示一个点的坐标有使用(x,y)坐标系的方法和(ρ,θ)来表示。
像下面这样提供构造方法就会报错。

但是我们像下面这样提供一个工厂类就可以避免了。

class Point {double x;double y;double ρ;double θ;
}
class PointFactory {public static void PointXY(double x, double y) {Point point = new Point();point.x = x;point.y = y;}public static void Pointρθ(double ρ, double θ) {Point point = new Point();point.ρ = ρ;point.θ = θ;}}

2.1.5 handler

RejectedExectionHandler handler表示 拒绝策略。

在调用submit,将任务给到任务队列,而在线程池中不会像阻塞队列一样,队列满了就阻塞,而是提供了4中拒绝策略。

  • AbortPolicy:线程池中直接抛出异常,撂挑子不干了。
  • CallerRunsPolicy:让调用submit方法的线程自己执行这个任务。
  • DiscardOldestPolicy:丢弃线程池中最老的任务,给新任务腾出空间。
  • DiscardPolicy:丢弃线程池中最新的任务,即submit的任务。

三、简易构造线程池

在Java中提供了Exectors类对ThreadPoolExecutor类进行了进一步封装,可以使用这个类来创建一个默认的线程池。

四、自己实现一个简单线程池

我们创建一个固定容量的线程池,只实现其中的submit方法和构造方法。

  • 构造一个阻塞队列;
  • 在构造方法中传要创建的线程数,循环创建线程,在线程中循环拿出队列中的任务,并执行run方法,不要忘记start线程。
  • 在submit方法中只要将任务put到队列中即可。
public class MyThreadPoolExecutor {//BlockingDeque<Runnable> queue = new LinkedBlockingDeque<>(1000);public MyThreadPoolExecutor(int n ) {//创建n个线程for (int i = 0; i < n; i++) {Thread thread = new Thread(() -> {try{while(true) {Runnable task = queue.take();task.run();}} catch (InterruptedException e) {e.printStackTrace();}});thread.start();}}public void submit(Runnable task) throws InterruptedException {queue.put(task);}
}

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

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

相关文章

Vue.js 学习总结(11)—— Vue3 Hook 函数实战总结

前言 在 Vue 3 中&#xff0c;Hook 函数是一种特殊的函数&#xff0c;用于封装可重用的逻辑和状态管理。Hook 函数允许你在 Vue 组件中提取和复用逻辑&#xff0c;而不是将所有逻辑都放在组件的选项对象中。它们可以帮助你更好地组织代码&#xff0c;提高代码的可维护性和可测…

Elasticsearch 解析:倒排索引机制/字段类型/语法/常见问题

Elasticsearch 是一个分布式的开源搜索引擎&#xff0c;广泛用于全文搜索、分析和数据存储。它基于 Apache Lucene 构建&#xff0c;支持 RESTful 风格的 API&#xff0c;使得开发者能够高效地存储和检索数据。本文将详细讲解 Elasticsearch 的基本原理&#xff0c;特别是其倒排…

网页上的视频怎么下载下来?三种方法

分享三个简单好用的网页视频下载工具&#xff0c;值得使用&#xff01; 1.IDM IDM 是一款可以提高下载速度达5倍的工具&#xff0c;同时具有恢复、调度和组织下载的功能。如果由于网络问题或意外的电源中断&#xff0c;程序将恢复未完成的下载。 IDM 还具有一个完全功能的站点…

【Flask】一、安装与第一个测试程序

目录 Flask简介 安装Flask 安装pip&#xff08;Python包管理器&#xff09; 使用pip安装Flask 验证安装 创建Flask程序 创建应用 运行 访问测试 Flask简介 Flask是一个用Python编写的轻量级Web应用框架。它被设计为易于使用和扩展&#xff0c;使其成为构建简单网站或复…

【经典论文阅读11】ESMM模型——基于贝叶斯公式的CVR预估

传统的CVR模型&#xff08;也就是直接对conversion rate建模的模型&#xff09;在实际应用中面临两个问题&#xff08;样本选择偏差与数据稀疏性问题&#xff09;。为了解决这两个问题&#xff0c;本文提出ESMM模型。该模型巧妙地利用用户行为序列去建模这个问题&#xff0c;从…

解决SpringBoot项目启动错误:找不到或无法加载主类

如何解决SpringBoot项目的“找不到或无法加载主类”启动错误 在开发SpringBoot应用时&#xff0c;经常可能会遇到一个启动错误&#xff1a;“错误&#xff1a;找不到或无法加载主类 com.example.controller.demo.DemoApplication”。本文将介绍三种解决这一问题的方法。 方法…

微信小程序中点击搜素按钮没有反应,可能是样式问题(按钮被其他元素覆盖或遮挡)

文章目录 1. 确认 bindtap 绑定在正确的元素上2. 检查是否有遮挡或重叠元素3. 检查 this 上下文绑定问题4. 清除微信小程序开发者工具的缓存5. 用微信开发者工具查看事件绑定6. 确保 handleSearch 没有拼写错误进一步调试 1、searchResults.wxml2、searchResults.wxss3、search…

偷懒总结篇|贪心算法|动态规划|单调栈|图论

由于这周来不及了&#xff0c;先过一遍后面的思路&#xff0c;具体实现等下周再开始详细写。 贪心算法 这个图非常好 122.买卖股票的最佳时机 II(妙&#xff0c;拆分利润) 把利润分解为每天为单位的维度&#xff0c;需要收集每天的正利润就可以&#xff0c;收集正利润的区间…

[C高手编程] 进程编程与IPC

&#x1f496;&#x1f496;⚡️⚡️专栏&#xff1a;C高手编程-面试宝典/技术手册/高手进阶⚡️⚡️&#x1f496;&#x1f496; 「C高手编程」专栏融合了作者十多年的C语言开发经验&#xff0c;汇集了从基础到进阶的关键知识点&#xff0c;是不可多得的知识宝典。如果你是即将…

基于SSM+小程序的旅游社交登录管理系统(旅游4)

&#x1f449;文末查看项目功能视频演示获取源码sql脚本视频导入教程视频 1、项目介绍 ​ 本旅游社交小程序功能有管理员和用户。管理员有个人中心&#xff0c;用户管理&#xff0c;每日签到管理&#xff0c;景点推荐管理&#xff0c;景点分类管理&#xff0c;防疫查询管理&a…

k8s 二进制部署安装(一)

目录 环境准备 初始化操作系统 部署docker 引擎 部署 etcd 集群 准备签发证书环境 部署 Master01 服务器相关组件 apiserver scheduler controller-manager.sh admin etcd 存储了 Kubernetes 集群的所有配置数据和状态信息&#xff0c;包括资源对象、集群配置、元数据…

阿里云镜像源无法访问?使用 DaoCloud 镜像源加速 Docker 下载(Linux 和 Windows 配置指南)

&#x1f680; 作者主页&#xff1a; 有来技术 &#x1f525; 开源项目&#xff1a; youlai-mall &#x1f343; vue3-element-admin &#x1f343; youlai-boot &#x1f343; vue-uniapp-template &#x1f33a; 仓库主页&#xff1a; GitCode&#x1f4ab; Gitee &#x1f…

银河麒麟V10系统下libopenblas.so.0和libllmlmf库的安装

1、当前linux服务器系统是银河麒麟V10&#xff0c;具体的内核和cpu型号如下&#xff1a; 2、使用:uname -a来进行查询 Linux localhost.localdomain 4.19.90-89.16.v2401.ky10.x86_64 #1 SMP Sat Sep 14 13:09:47 CST 2024 x86_64 x86_64 x86_64 GNU/Linux 3、在部署QT开发的应…

高清 MV 无字幕视频素材

在当下的短视频和自媒体时代&#xff0c;高清无字幕的视频素材无疑是创作者们的“得力助手”。不管是用于剪辑情感励志视频、制作搞笑段子&#xff0c;还是创作风景航拍视频&#xff0c;优质的素材库都能让你的创作如虎添翼。今天&#xff0c;我就为大家介绍几个海外的高质量素…

如何使用Qlik Sense Util

Qlik Sense Util 是 Qlik Sense 的一个实用工具&#xff0c;它可以帮助管理员执行各种配置和维护任务。 以下是使用 Qlik Sense Util 工具的一些基本步骤&#xff1a; 1. **运行 QlikSenseUtil.exe**&#xff1a; - 在中心节点上&#xff0c;打开文件资源管理器并导航到 C:…

服务器作业2

架设一台NFS服务器&#xff0c;并按照以下要求配置 关闭防火墙 [rootlocalhost ~]# systemctl stop firewalld [rootlocalhost ~]# setenforce 0 配置文件设置&#xff1a; [rootlocalhost ~]# vim /etc/exports 1、开放/nfs/shared目录&#xff0c;供所有用户查询资料 共享…

Scott Brinker:Martech App 的未来在中小企业和中端市场

中端市场营销支出增加 Product Hunt网站上每周发布的与营销技术相关的产品数量和TechCrunch网站上发布的新融资公告数量持续增加。最近&#xff0c;很多公司都在借助OpenAI、Azure和AWS的新API&#xff0c;赶上生成式人工智能的浪潮。可以肯定的是&#xff0c;有很多重复的想法…

IDEA集成AI的DevAssist插件使用指南

DevAssit使用背景&#xff0c;这类工具通常旨在帮助开发者提高效率&#xff0c;简化开发流程。这类工具包括但不限于&#xff1a; 代码编辑器插件&#xff1a;提供自动补全、代码提示等功能。 构建工具&#xff1a;帮助自动化构建过程。 调试工具&#xff1a;提供更强大的调试功…

anaconda 创建环境失败 解决指南

anaconda 创建环境失败 解决指南 一、问题描述 我在宿舍有一台电脑。由于我经常泡在实验室&#xff0c;所以那台电脑不是经常用&#xff0c;基本吃灰。昨天晚上突然有在那台电脑上使用Camel-AI部署多智能体协同需求&#xff0c;便戳开了电脑&#xff0c;问题也随之而来。 当…

河北统计年鉴(2000-2021年)

《河北统计年鉴》不仅记录了河北省经济社会发展的历史轨迹&#xff0c;还系统地展示了其现状。它涵盖了经济发展、人口就业、社会事业、居民生活、环境保护等多个领域的数据资料 2000-2021年河北统计年鉴数据整理资源-CSDN文库https://download.csdn.net/download/2401_845856…