Java中的四种线程池详解及使用场景

前言

在Java并发编程中,JDK提供了一套强大的线程池工具类java.util.concurrent.ThreadPoolExecutor以及它的四个便捷工厂方法,这四种线程池分别对应不同的使用场景和特性。下面将详细介绍每种线程池的创建方式、工作原理以及适用场景。

1. CachedThreadPool(可缓存线程池)

ExecutorService cachedPool = Executors.newCachedThreadPool();

特点与原理:

  • newCachedThreadPool创建的线程池会根据需要创建新的线程,并且可以灵活地回收空闲线程。
  • 线程池的核心线程数为0,最大线程数为Integer.MAX_VALUE,即理论上没有限制。
  • 使用SynchronousQueue作为任务队列,这是一个无界但不存储元素的队列,每个插入操作必须等待另一个线程的移除操作,因此当提交新任务时,若没有空闲线程可用,则会创建新的线程执行任务。
  • 当线程空闲超过60秒后会被终止并从线程池中移除,从而达到动态调整线程数量的目的。

适用场景:

  • 执行大量短生命周期的任务,且任务的执行时间远小于线程创建销毁的时间开销。
  • 对于并发执行的数量需求不确定,适合处理突发性的高并发请求。

2. FixedThreadPool(定长线程池)

ExecutorService fixedPool = Executors.newFixedThreadPool(nThreads);

特点与原理:

  • newFixedThreadPool创建的是一个固定大小的线程池,核心线程数和最大线程数相等。
  • 设置了明确的线程数量,一旦创建就不会再增加或减少。
  • 配合有界任务队列(通常默认是LinkedBlockingQueue),当线程数量达到上限时,新提交的任务将会被放入队列中等待执行。
  • 如果线程池中的所有线程都处于活动状态,新提交的任务将在队列中等待,直到有线程空闲出来。

适用场景:

  • 资源有限或者系统对资源消耗有严格要求的情况下,例如数据库连接池大小固定。
  • 需要控制并发数,防止过多的线程导致系统负载过重。

3. ScheduledThreadPool(定时/周期性线程池)

ScheduledExecutorService scheduledPool = Executors.newScheduledThreadPool(corePoolSize);

特点与原理:

  • newScheduledThreadPool创建的线程池主要用于执行定时任务和具有固定延迟的任务。
  • 核心线程数可自定义,非核心线程闲置时会被回收,但不会低于核心线程数。
  • 支持延迟或定期执行Runnable或Callable任务,提供了schedule()scheduleAtFixedRate()等方法来安排任务执行。

适用场景:

  • 定时任务调度,如每隔一定时间执行一次清理、统计或者其他后台服务的操作。
  • 周期性任务执行,如心跳检测、数据同步等。

4. SingleThreadExecutor(单线程线程池)

ExecutorService singleThreadExecutor = Executors.newSingleThreadExecutor();

特点与原理:

  • newSingleThreadExecutor创建的线程池只有一个工作线程。
  • 提交到此线程池的任务将按照FIFO(先进先出)顺序执行,确保所有任务在一个线程上按序完成。
  • 即使有多个任务提交,也不会同时执行,而是排队等待当前任务完成后才开始下一个任务。

适用场景:

  • 应用场景是对任务执行顺序有严格要求的环境,保证任务间串行执行。
  • 用于维护应用中某个组件的单一访问点,比如日志文件写入、GUI事件队列处理等。

总结来说,Java提供的这四种线程池各自服务于特定的并发场景,合理选择和使用线程池能有效提升系统的性能和稳定性,避免因频繁创建和销毁线程带来的额外开销,同时也方便进行统一管理和监控。在实际开发过程中,应遵循“线程池复用”的原则,避免重复创建线程池,尤其是对于Web项目而言,建立全局的线程池是非常重要的实践。

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

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

相关文章

Linux文本三剑客---grep

grep(从文本或字符串种过滤特定内容。) 格式:Usage: grep [OPTION]... PATTERNS [FILE]... 常用选项: -E 等价于 egrep 扩展正则 -i 忽略大小写 -w 匹配单词 -o 仅显示匹配内容 -r 递归匹配 -c 统计匹配的行数 -v 取反 -n 行号 -A…

react 什么是h函数

React 中的 H 函数,通常是指 Hooks(钩子)函数。Hooks 是 React 16.8 版本引入的新特性,允许你在不写 class 的情况下使用 state 以及其他的 React 特性。Hooks 提供了一种更简洁、更直观的方式来使用 React 的功能,使得…

11.2 Web开发_CSS入门(❤❤)

11.2 Web开发_CSS入门❤❤ 1. CSS简介1.1 基础案例2. CSS书写的位置2.1 行内式2.2 内嵌式2.3 外链式3. CSS基础选择器3.1 标签选择器3.2 id选择器3.3 类选择器3.4 选择器优先级3.5 通配符选择器4. 多类名5. 样式的两种特性5.1 层叠性

仰暮计划|“老师说我其实很聪明,就是家里太穷了没条件,不然我现在也是……”

吴桂荣老人回忆录 在我外婆家的时候,我跟几位老奶奶坐在门口一起聊天,我询问她们是否能帮助我完成一份作业,她们笑着答应了,最后我选择了其中的一位老奶奶作为了解对象,她邀请我去家中交谈。通过了解,我得知…

HCIA学习第四天:静态路由与动态路由

静态路由: 选路原则:尽量选择路径最短的路由条目 扩展配置: 1、负载均衡:当路由器访问同一个目标且目标且目标具有多条开销相似的路径时,可以让设备将流量拆分后延多条路径同时进行传输,以达到叠加带宽的…

(七)springboot实战——springboot3集成R2DBC实现webflux响应式编程服务案例

前言 本节主要内容是关于使用新版springboot3集成响应式数据库R2DBC,完成响应式web服务案例。需要注意的是,此次项目使用的JDK版本是JDK17,springboot版本使用3.2.2版本,数据库使用关系型数据库mysql。WebFlux 是一个基于响应式编程模型的框…

K8s-持久化(持久卷,卷申明,StorageClass,StatefulSet持久化)

POD 卷挂载 apiVersion: v1 kind: Pod metadata:name: random-number spec:containers:- image: alpinename: alpinecommand: ["/bin/sh","-c"]args: ["shuf -i 0-100 -n 1 >> /opt/number.out;"]volumeMounts:- mountPath: /optname: da…

04-Nacos-服务注册基于spring boot实现

官方参考 在不依赖spring cloud 组件基础上&#xff0c;单独的微服务项目&#xff0c;实现nacos接入 1、依赖文件pom.xml <dependency><groupId>com.alibaba.boot</groupId><artifactId>nacos-discovery-spring-boot-starter</artifactId><…

RUST笔记: 动态链接库的创建和使用

生成动态链接库 // https://github.com/vvvm23/funny-shapes # 项目元信息 [package] name "funnyshapes" # 项目名称 version "0.1.0" # 版本号 edition "2021" # Rust语言版本# 更多配置信息可查阅&#xff1…

华为机考入门python3--(3)牛客3-明明的随机数

分类&#xff1a;集合、排序 知识点&#xff1a; 集合添加元素 set.add(element) 集合转列表 list(set) 列表排序 list.sort() 题目来自【牛客】 N int(input().strip()) nums set()for i in range(N):nums.add(int(input().strip()))# 集合转列表 nums_list l…

眼底增强型疾病感知蒸馏模型 FDDM:无需配对,fundus 指导 OCT 分类

眼底增强型疾病感知蒸馏模型 FDDM&#xff1a;fundus 指导 OCT 分类 核心思想设计思路训练和推理 效果总结子问题: 疾病特定特征的提取与蒸馏子问题: 类间关系的理解与建模 核心思想 论文&#xff1a;https://arxiv.org/pdf/2308.00291.pdf 代码&#xff1a;https://github.c…

【模板】拓扑排序

Problem: 【模板】拓扑排序 文章目录 思路解题方法复杂度Code 思路 拓扑排序模板 解题方法 初始化一个队列&#xff0c;将所有入度为0的顶点入队。从队列中取出一个顶点&#xff0c;并将其输出。对于该顶点的所有出边&#xff0c;将出边的终点的入度减1。如果某个顶点的入度变为…

269. 火星词典

Problem: 269. 火星词典 文章目录 思路解题方法复杂度Code 思路 首先&#xff0c;我们先将所有单词中出现的字符标记为 0&#xff0c;没有出现的标记为 1。然后&#xff0c;我们开始建图&#xff0c;对于每一个单词对&#xff0c;我们比较它们的前缀&#xff0c;直到找到第一个…

【笔试常见编程题02】字符串中找出连续最长的数字串、数组中出现次数超过一半的数字、计算糖果、进制转换

1. 字符串中找出连续最长的数字串 读入一个字符串str&#xff0c;输出字符串str中的连续最长的数字串 输入描述 个测试输入包含1个测试用例&#xff0c;一个字符串str&#xff0c;长度不超过255。 输出描述 在一行内输出str中里连续最长的数字串。 示例 1 输入 abcd12345ed125s…

java数据结构与算法刷题-----LeetCode328. 奇偶链表

java数据结构与算法刷题目录&#xff08;剑指Offer、LeetCode、ACM&#xff09;-----主目录-----持续更新(进不去说明我没写完)&#xff1a;https://blog.csdn.net/grd_java/article/details/123063846 解题思路 将链表按奇偶顺序&#xff0c;分成两个链表。最后将偶数链表放在…

(每日持续更新)jdk api之InterruptedIOException基础、应用、实战

博主18年的互联网软件开发经验,从一名程序员小白逐步成为了一名架构师,我想通过平台将经验分享给大家,因此博主每天会在各个大牛网站点赞量超高的博客等寻找该技术栈的资料结合自己的经验,晚上进行用心精简、整理、总结、定稿,每天都会整理到12点,为了就是能让大家能够真…

Python无人诊断治疗全套系统

Python无人诊断治疗全套系统的研发开发对于医疗行业具有重要性。以下是其重要性的几个方面&#xff1a; 提高诊断精确性&#xff1a;无人诊断系统利用大数据分析和人工智能技术&#xff0c;能够通过对病例的分析和比对&#xff0c;提供更准确的诊断结果。相比于传统的人工诊断&…

LeetCode第500题 - 键盘行

题目 给定一个单词列表&#xff0c;只返回可以使用在键盘同一行的字母打印出来的单词。 示例&#xff1a; 输入: [“Hello”, “Alaska”, “Dad”, “Peace”] 输出: [“Alaska”, “Dad”] 解答 class Solution {public String[] findWords(String[] words) {char[][] keybo…

计算机网络-编制与调制(基带信号 基带传输 宽度信号 宽度传输 编码 调制 )

文章目录 基带信号与宽带信号编码与调制数字数据编码为数字信号数字数据调制为模拟信号模拟数据编码为数字信号模拟数据调制为模拟信号小结 基带信号与宽带信号 信道上传输的信号除了可以分为数字信号和模拟信号&#xff0c;也可以分为基带信号和宽带信号&#xff0c;只是分类…

【每日一题】最大合金数

文章目录 Tag题目来源解题思路方法一&#xff1a;二分枚举答案 写在最后 Tag 【二分枚举答案】【数组】【2024-01-27】 题目来源 2861. 最大合金数 解题思路 方法一&#xff1a;二分枚举答案 思路 如果我们可以制造 x 块合金&#xff0c;那么一定也可以制造 x-1 块合金。于…