java 线程池的使用

线程池的分类

在 Java 中,常用的线程池有以下几种:

  1. ThreadPoolExecutor:ThreadPoolExecutor 是 Java 提供的最基本的线程池实现。它提供了丰富的参数配置,可以自定义核心线程数、最大线程数、线程空闲时间、工作队列等。

  2. Executors.newFixedThreadPool:这是一个固定大小的线程池,核心线程数和最大线程数都是固定的,没有线程空闲时间限制。适用于需要控制并发线程数量的场景。

  3. Executors.newCachedThreadPool:这是一个可缓存的线程池,核心线程数为0,最大线程数为 Integer.MAX_VALUE,线程空闲时间为60秒。适用于执行大量短期异步任务的场景,可以根据任务的数量自动调整线程数量。

  4. Executors.newSingleThreadExecutor:这是一个单线程的线程池,核心线程数和最大线程数都为1,只有一个工作线程。适用于需要保证任务按照顺序执行的场景。

  5. Executors.newScheduleThreadPool:创建一个定长的线程池,而且支持定时的以及周期性的任务执行。例如延迟3秒执行。

这些线程池都是使用 Executors 类提供的静态方法创建的,它们都实现了 ExecutorService 接口,可以提交任务并管理线程池的生命周期。

除了上述常用线程池,Java 8 还引入了 ForkJoinPool,它是一种特殊的线程池,用于执行分治任务。ForkJoinPool 提供了一种基于工作窃取(work-stealing)算法的线程池实现,适用于高效执行递归并行任务。

在选择线程池时,需要根据具体的业务需求和性能要求来选择合适的线程池类型和参数配置。需要考虑任务的特性、并发量、响应时间要求以及系统资源限制等因素,进行适当的调整和优化。

线程池七大核心参数

ThreadPoolExecutor 是 Java 中用于管理线程池的类,它提供了一些核心参数用于配置线程池的行为。下面是 ThreadPoolExecutor 的七个核心参数及其通常的设置:

  1. corePoolSize(核心线程数):

    • 表示线程池中保持活动状态的线程数,即使它们处于空闲状态也不会被回收。
    • 通常根据系统资源和任务负载来设置,一般建议设置与 CPU 核心数相当或稍多一些。
  2. maximumPoolSize(最大线程数):

    • 表示线程池中允许存在的最大线程数,包括核心线程和非核心线程。
    • 通常根据系统资源和任务负载来设置,根据具体需求决定最大并发线程数。
  3. keepAliveTime(线程空闲时间):

    • 表示非核心线程的空闲时间,超过这个时间,非核心线程将被终止并从线程池中移除。
    • 通常根据任务的特性和响应时间要求来设置,以充分利用资源并避免不必要的线程创建和销毁。
  4. unit(时间单位):

    • 用于指定 keepAliveTime 的时间单位,可以是 TimeUnit.SECONDS、TimeUnit.MILLISECONDS 等。
  5. workQueue(工作队列):

    • 用于存储待执行的任务的阻塞队列。
    • 可以选择不同的队列实现,如 SynchronousQueue、LinkedBlockingQueue、ArrayBlockingQueue 等,根据任务的特性和需求选择合适的队列类型。
  6. threadFactory(线程工厂):

    • 用于创建新的线程对象。
    • 可以通过自定义 ThreadFactory 实现来为线程池中的线程指定特定的名称、优先级等属性。
  7. handler(拒绝策略):

    • 当线程池已达到最大线程数并且队列已满时,用于处理新提交的任务。
    • 可以选择不同的拒绝策略,如 ThreadPoolExecutor.AbortPolicy、ThreadPoolExecutor.CallerRunsPolicy、ThreadPoolExecutor.DiscardPolicy、ThreadPoolExecutor.DiscardOldestPolicy,或者自定义实现。

这些参数的具体设置需要根据实际需求和系统性能进行调优。通常,根据任务的类型、并发量、响应时间要求和系统资源限制等因素来选择合适的参数配置。对于每个参数,需要综合考虑系统的负载情况、可用资源、任务处理的特性和性能需求,进行适当的调整和优化。

线程池参数设置实例

具体的 ThreadPoolExecutor 参数设置需要根据具体的应用场景和需求进行调整,下面我给出一个例子来说明常见的参数设置。

假设我们有一个 Web 服务器应用,需要处理大量的并发请求。该应用的主要特点是,请求的处理时间较长,可能涉及到网络请求、IO 操作或复杂的计算逻辑。我们希望通过线程池来管理请求的处理,以提高并发性能和资源利用率。

在这种情况下,我们可以进行如下的 ThreadPoolExecutor 参数设置:

java

复制

int corePoolSize = Runtime.getRuntime().availableProcessors(); // 核心线程数设置为 CPU 核心数
int maximumPoolSize = corePoolSize * 2; // 最大线程数设置为核心线程数的两倍
long keepAliveTime = 60; // 线程空闲时间设置为 60 秒
TimeUnit unit = TimeUnit.SECONDS; // 时间单位为秒
BlockingQueue<Runnable> workQueue = new LinkedBlockingQueue<>(); // 使用无界队列,即 LinkedBlockingQueue
ThreadFactory threadFactory = Executors.defaultThreadFactory(); // 使用默认的线程工厂
RejectedExecutionHandler handler = new ThreadPoolExecutor.AbortPolicy(); // 使用默认的拒绝策略ThreadPoolExecutor executor = new ThreadPoolExecutor(corePoolSize,maximumPoolSize,keepAliveTime,unit,workQueue,threadFactory,handler
);

在这个例子中,我们将核心线程数设置为 CPU 核心数,最大线程数设置为核心线程数的两倍,以充分利用系统资源。线程空闲时间设置为 60 秒,即非核心线程在空闲 60 秒后会被终止并从线程池中移除,以避免不必要的线程创建和销毁。使用无界队列 LinkedBlockingQueue,可以无限制地存储待执行的任务。线程工厂使用默认的工厂,拒绝策略使用默认的 AbortPolicy,表示当线程池已满时,新提交的任务将会被拒绝并抛出异常。

这个例子中的参数设置只是一种常见的配置,实际的应用场景可能会有不同的需求。对于不同的应用,你可能需要根据具体情况来调整参数,例如调整核心线程数、最大线程数、队列类型和大小、线程空闲时间等,以满足你的性能和资源需求。

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

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

相关文章

ElementPlus中 使用ElLoading.service, spinner: ‘el-icon-loading‘不生效

let downloadLoadingInstance ElLoading.service({ text: "正在下载数据&#xff0c;请稍候",spinner: el-icon-loading, background: "rgba(0, 0, 0, 0.7)", })使用以上代码时&#xff0c;加载的圆圈出不来&#xff0c;使用f12查看&#xff0c;即使能出…

BEVFormer环境配置

官网的教程说是Step By Step&#xff0c;但是实际上我按照步骤安装下来运行不了&#xff08;BEVFormer GitHub地址&#xff09;。主要是安装后关于包依赖产生的某些错误&#xff0c;特别是安装nuscenes-devkit没有在步骤中列出来&#xff0c;后面就不好解决某些包的版本依赖了。…

Nginx的缓存配置与其他配置

一、Nginx的缓存配置 http {server {#设置缓存的通配符&#xff0c;只要满足后缀是jpg或png或swf或gif的就进行缓存&#xff08;意思就>是当用户浏览网页时&#xff0c;会将网页上所有jpg或png或swf或gif都缓存起来&#xff0c;下次用户再次访问的时候就直接从本地加载图片…

代币化对网约车区块链平台的影响

The effects of tokenization on ride-hailing blockchain platforms 再一次分析一下一篇关于区块链的文章&#xff0c;这篇文章比较新&#xff0c;2023年发表在POMS上。 由于这篇文章跟之前那几篇关注假货的文章的重点不一样&#xff0c;所以需要仔细读一下他的INTRODUCTION…

【嵌入式面试实战】大疆嵌入式一面

1.自我介绍(介绍你的背景和教育经历,特别强调与嵌入式系统相关的学习和项目经验) 2.linux中的线程一般是怎么调度的? 内核根据线程的优先级和调度策略来确定下一个要执行的线程。内核维护一个调度队列,其中包含所有可运行(runnable)状态的线程。当一个CPU核心空闲时,内…

多级缓存自用

1.什么是多级缓存 传统的缓存策略一般是请求到达Tomcat后,先查询Redis,如果未命中则查询数据库,如图: 存在下面的问题: •请求要经过Tomcat处理,Tomcat的性能成为整个系统的瓶颈 •Redis缓存失效时,会对数据库产生冲击 多级缓存就是充分利用请求处理的每个环节,添加缓…

Vue2生命周期、Vue3生命周期及其对比

一、Vue2中的生命周期 Vue2的生命周期分为8个阶段&#xff0c;它们分别是&#xff1a; beforeCreate&#xff08;创建前&#xff09;&#xff1a;在实例初始化之后&#xff0c;数据观测和事件配置之前被调用。此时实例还未完成初始化&#xff0c;无法访问到data、computed、wa…

C语言实现猜数字游戏

前面我们已经了解了分支循环、数据类型及变量的知识点&#xff0c;今天我将用之前学过的知识进行实操&#xff0c;将所学的知识进行巩固和提升。下面的讲解仅我个人认知水平&#xff0c;如有欠缺之处&#xff0c;欢迎大家指正&#xff0c;并且我希望初学者在看完讲解后可以独立…

强化学习------时序差分(Temporal-Difference Learning)

简介 时序差分方法&#xff08;Temporal-Difference Learning&#xff09;简称TD算法是强化学习中非常经典的一种方法&#xff0c;Sarsa算法和Q-learning算法都是基于时序差分这种方法的。 强化学习分为基于模型和不基于模型的方法 基于模型的方法&#xff1a;是一种通过建立…

Redis之五大基础数据类型(详细总结 面试必备)

Redis之五大基础数据类型 Redis 共有 5 种基本数据类型&#xff1a;String&#xff08;字符串&#xff09;、List&#xff08;列表&#xff09;、Set&#xff08;集合&#xff09;、Hash&#xff08;散列&#xff09;、Zset&#xff08;有序集合&#xff09;。 这 5 种数据类…

64. 最小路径和(Leetcode)

文章目录 前言一、题目分析二、算法原理1.状态表示2.状态转移方程3.初始化4.填表顺序5.返回值是什么 三、代码实现总结 前言 在本文章中&#xff0c;我们将要详细介绍一下Leetcode6最小路径相关的内容 一、题目分析 二、算法原理 1.状态表示 列出dp表&#xff0c;dp[i][j]代…

IDEA导入JavaWeb项目(Maven)

IDEA导入JavaWeb(Maven)项目教程 运行教程 亲爱的粉丝们&#xff0c;我深知你们对IDEA导入JAVAWeb工程的迫切需求。在这个充满竞争的时代&#xff0c;每一个项目都离不开高效的沟通。过程中需要对应的环境适配和软件安…

操作PDF相关的工具,EPUB转PDF,golang

unipdf 安装依赖 go get github.com/unidoc/unipdf/v3 示例代码 https://github.com/unidoc/unipdf-examples 获取KEY 登录 https://cloud.unidoc.io/ 注册账号&#xff0c;生成 KEY&#xff0c;但是需要收费。 chromedp 使用Golang编写&#xff0c;主要功能是调用浏览器内…

24秋招--双非本科上岸大疆研发岗面经分享

联想 小组面 小组面试 就人工智能的工业化领域张开讨论 单面 英文沟通 自我介绍 介绍一下货拉拉的实习经历 在货拉拉实习学到了什么 说说对DevOps的理解 有哪些爱好 对Agilean有了解吗 ... 中文沟通 对测试理论有哪些了解 对测试和测开的职责的理解 为什么要跳槽去…

代码随想录算法训练营第四十一天 _ 动态规划_343. 整数拆分、96.不同的二叉搜索树、01背包问题。

学习目标&#xff1a; 动态规划五部曲&#xff1a; ① 确定dp[i]的含义 ② 求递推公式 ③ dp数组如何初始化 ④ 确定遍历顺序 ⑤ 打印递归数组 ---- 调试 引用自代码随想录&#xff01; 60天训练营打卡计划&#xff01; 学习内容&#xff1a; 343. 整数拆分 动态规划五步曲&…

Mysql之数据处理增删改

Mysql之数据处理增删改查 插入数据INSERT INTO语句的使用INSERT 与子查询结合 更新数据(修改数据)UPDATE SET语句 删除数据DELETE FROM语句 Mysql8新特性&#xff1a;计算列 插入数据 INSERT INTO语句的使用 用 INSERT INTO 语句&#xff0c;向表中插入数据 方式一&#xff1a;…

Web漏洞分析-SQL注入XXE注入(上)

随着互联网的不断普及和Web应用的广泛应用&#xff0c;网络安全问题愈发引起广泛关注。在网络安全领域中&#xff0c;SQL注入和XXE注入是两个备受关注的话题&#xff0c;也是导致许多安全漏洞的主要原因之一。本博客将深入研究这两种常见的Web漏洞&#xff0c;带您探寻背后的原…

一个用c#瞎写的sftp工具

0.下载地址 https://wwus.lanzouj.com/iOZUv1gkgpze 密码:123456 1.能进行单个和批量下载, 没有弄上传 2.速度奇差,可能是某些地方没弄好.有一定的进度显示,但是不太准. 3.很多地方没弄好,有能力的自己弄一下 4.在app.config文件配置sftp

深度学习 第3章 Python程序设计语言(3.2 Python程序流程控制)

无论是在机器学习还是深度学习中&#xff0c;Python已经成为主导性的编程语言。而且&#xff0c;现在许多主流的深度学习框架&#xff0c;例如PyTorch、TensorFlow也都是基于Python。本课程主要是围绕“理论实战”同时进行&#xff0c;所以本章将重点介绍深度学习中Python的必备…

Echarts大屏可视化_03 定制柱状图

柱状图模块引入 1.找到合适的图表 在echarts中寻找与目标样式相近的图表 Examples - Apache ECharts 2. 引入柱状图 使用立即执行函数构建&#xff0c;防止变量全局污染 实例化对象 将官网中提供的option复制到代码中&#xff0c;并且构建图表 // 柱状图模块1 (function () {/…