当前位置: 首页 > news >正文

java线程池详解

在Java中,线程池是一种重要的多线程处理方式,通过管理和复用线程,提高应用程序的性能和响应速度,减少线程创建和销毁的开销,避免线程数量过多导致系统负载过高的问题。本文将详细介绍Java线程池的概念、核心参数、工作流程、常见类型、拒绝策略以及使用方法和优化建议。

一、线程池的概念

线程池就是线程的池子,用来管理和复用线程。它可以在应用程序中有效地管理线程的生命周期、调度和执行。线程池包含一组预先创建的线程,这些线程可以被动态分配给执行任务,从而避免了不断创建和销毁线程的开销。线程池通常用于执行大量的异步任务,提高多线程程序的性能和稳定性。

二、线程池的核心参数

线程池的核心参数包括:

  1. corePoolSize(核心线程数):线程池中保持的最小线程数,即使线程是空闲的。这些线程在处理任务时不会被回收,除非设置了allowCoreThreadTimeOut(true)来允许核心线程在空闲时被回收。
  2. maximumPoolSize(最大线程数):线程池允许的最大线程数,包括核心线程和非核心线程。当任务队列已满且活动线程数小于最大线程数时,会创建新的线程。
  3. keepAliveTime(线程空闲时间):非核心线程的空闲时间超过这个值就会被回收。指定非核心线程空闲线程的最长存活时间。
  4. unit(时间单位):用于指定keepAliveTime的时间单位,可以是TimeUnit.MILLISECONDS等。
  5. workQueue(任务队列):用于保存等待执行的任务。选择合适的任务队列,例如LinkedBlockingQueue、ArrayBlockingQueue等,以满足需求。
  6. threadFactory(线程工厂):用于创建新线程。通过线程工厂可以给每个创建出来的线程设置更有意义的名字。
  7. handler(拒绝策略):当队列和线程池都满了,说明线程池处于饱和状态,必须采取一种策略处理提交的新任务。这个策略默认情况下是AbortPolicy,表示无法处理新任务时抛出异常。还可以选择CallerRunsPolicy(用调用者所在线程来运行任务)、DiscardPolicy(丢弃队列里最近的一个任务,并执行当前任务)、DiscardOldestPolicy(丢弃最老的任务,尝试重新提交新的任务)等策略,或者根据应用场景实现RejectedExecutionHandler接口自定义策略。
三、线程池的工作流程

线程池的工作流程如下:

  1. 当有新任务来时,将先使用核心线程执行。
  2. 当任务数达到核心线程数时,后续的任务会被放入任务队列中等待执行。
  3. 如果任务队列已满,且活动线程数小于最大线程数,会创建新的非核心线程来执行任务。
  4. 当任务数达到最大线程数时,线程池满了,如果有新的任务,将执行拒绝策略。
四、常见线程池类型

Java中常见的线程池类型包括:

  1. FixedThreadPool(固定大小线程池):包含固定数量的线程,适用于需要限制并发线程数量的场景。
  2. CachedThreadPool(缓存线程池):不固定线程数量,可以根据需要自动创建新线程,适用于短期异步任务。
  3. SingleThreadPool(单线程池):只包含一个工作线程,保证所有任务按顺序执行,适用于需要保持任务顺序执行的场景。
  4. ScheduledThreadPool(定时线程池):可以执行定时任务和周期性任务。
  5. WorkStealingPool(工作窃取线程池):Java 8中引入的一种新类型的线程池,主要用于处理耗时任务,适用于需要大量并行任务、任务之间没有依赖关系的情况。
五、线程池的使用

Java提供了ThreadPoolExecutor类来实现线程池的管理。以下是使用ThreadPoolExecutor创建线程池并提交任务的示例代码:

import java.util.concurrent.*;  public class ThreadPoolExample {  public static void main(String[] args) {  // 创建线程池  ThreadPoolExecutor executor = new ThreadPoolExecutor(  2,  // 核心线程数  4,  // 最大线程数  60, // 线程空闲时间  TimeUnit.SECONDS,  new LinkedBlockingQueue<Runnable>()  );  // 向线程池提交任务  for (int i = 0; i < 10; i++) {  final int task = i;  executor.execute(new Runnable() {  @Override  public void run() {  System.out.println(Thread.currentThread().getName() + " 正在执行第 " + (task + 1) + " 个任务");  }  });  }  // 关闭线程池  executor.shutdown();  }  
}

此外,Java还提供了Executors工厂类来方便地创建常见的线程池类型。以下是使用Executors创建固定大小线程池、缓存线程池、单线程池和定时线程池的示例代码:

import java.util.concurrent.*;  public class ExecutorsExample {  public static void main(String[] args) {  // 创建固定大小线程池  ExecutorService fixedThreadPool = Executors.newFixedThreadPool(3);  // 创建缓存线程池  ExecutorService cachedThreadPool = Executors.newCachedThreadPool();  // 创建单线程池  ExecutorService singleThreadPool = Executors.newSingleThreadExecutor();  // 创建定时线程池  ScheduledExecutorService scheduledThreadPool = Executors.newScheduledThreadPool(3);  // 向线程池提交任务(示例)  for (int i = 0; i < 3; i++) {  final int task = i;  fixedThreadPool.execute(new Runnable() {  @Override  public void run() {  System.out.println(Thread.currentThread().getName() + " 正在执行固定大小线程池中的第 " + (task + 1) + " 个任务");  }  });  cachedThreadPool.execute(new Runnable() {  @Override  public void run() {  System.out.println(Thread.currentThread().getName() + " 正在执行缓存线程池中的第 " + (task + 1) + " 个任务");  }  });  singleThreadPool.execute(new Runnable() {  @Override  public void run() {  System.out.println(Thread.currentThread().getName() + " 正在执行单线程池中的第 " + (task + 1) + " 个任务");  }  });  }  // 定时任务示例  scheduledThreadPool.schedule(new Runnable() {  @Override  public void run() {  System.out.println("定时任务执行");  }  }, 2, TimeUnit.SECONDS);  // 关闭线程池(示例)  fixedThreadPool.shutdown();  cachedThreadPool.shutdown();  singleThreadPool.shutdown();  scheduledThreadPool.shutdown();  }  
}
六、线程池的拒绝策略

当线程池和队列都满了时,需要采取拒绝策略来处理新的任务。Java线程池支持多种拒绝策略,包括:

  1. AbortPolicy:直接抛出异常,防止系统崩溃。
  2. CallerRunsPolicy:在提交者线程中执行任务。
  3. DiscardPolicy:直接丢弃新任务。
  4. DiscardOldestPolicy:丢弃最老的任务,尝试重新提交新的任务。

选择合适的拒绝策略,可以避免任务丢失或者对系统造成过度负荷的影响。

七、线程池的优化建议
  1. 合理设置线程池大小:根据任务类型、执行时间和系统负载等因素来确定线程池大小。如果任务是I/O密集型,可以适当增加线程池大小;如果任务是计算密集型,可以适当减少线程池大小。
  2. 使用有界队列:无界队列可能会导致内存溢出,因此建议使用有界队列,并根据实际情况选择合适的拒绝策略。
  3. 动态调整线程池大小:通过调整keepAliveTime的值来动态调整线程池大小。例如,当任务量较少时,可以把keepAliveTime设置较长,让多余的线程等待更长时间以便对突发任务做出快速响应。
  4. 及时移除空闲线程:保持线程池中的空闲线程数量最小,可以减少系统资源开销。
  5. 避免线程池饥饿:线程池饥饿会导致任务一直处于排队状态,无法得到处理。可通过调整线程池大小、队列类型和拒绝策略等来避免线程池饥饿。

相关文章:

java线程池详解

在Java中&#xff0c;线程池是一种重要的多线程处理方式&#xff0c;通过管理和复用线程&#xff0c;提高应用程序的性能和响应速度&#xff0c;减少线程创建和销毁的开销&#xff0c;避免线程数量过多导致系统负载过高的问题。本文将详细介绍Java线程池的概念、核心参数、工作…...

五、创建型(建造者模式)

建造者模式 概念 建造者模式是一种创建型设计模式&#xff0c;通过使用多个简单的对象一步步构建一个复杂的对象。它将一个复杂对象的构建过程与其表示分离&#xff0c;从而使同样的构建过程可以创建不同的表示。 应用场景 复杂对象构建&#xff1a;当一个对象有多个属性&…...

CPU超线程技术是什么,怎么启用超线程技术

超线程技术是一种允许单个物理CPU核心模拟成两个逻辑核心的技术&#xff0c;从而提升处理器的并行性能和效率。以下是对超线程技术的详细介绍&#xff1a; 基本概念&#xff1a;超线程&#xff08;Hyper-Threading&#xff0c;HT&#xff09;是Intel公司研发的一种技术&#x…...

vba学习系列(7)--考勤表制作

系列文章目录 文章目录 系列文章目录前言一、汇总所有工作表指定区域内容到指定工作表二、汇总所有工作表指定区域内容到指定工作表(带公式)总结 前言 一、汇总所有工作表指定区域内容到指定工作表 Sub CopyRangesToSummary()Dim sourceSheet As WorksheetDim targetSheet As…...

Java学习第九天

相同包下的类可以直接访问&#xff0c;不同包下的类需要导包才可以使用&#xff0c;导包格式&#xff1a;import 包名.类名 final关键字&#xff1a; 常量&#xff1a; 枚举&#xff1a;一种特殊的类型(反编译之后本质就是实例常量&#xff0c;自己定义的类&#xff0c;创建了几…...

【算法系列-链表】链表相交 环形链表II

【算法系列-链表】链表相交&环形链表 文章目录 【算法系列-链表】链表相交&环形链表1. 链表相交1.1 思路分析&#x1f3af;1.2 解题过程&#x1f3ac;1.3 代码示例&#x1f330; 2. 环形链表II2.1 思路分析&#x1f3af;2.2 代码示例&#x1f330; 1. 链表相交 【题目…...

使用 Go 和 Gin 框架构建简单的用户和物品管理 Web 服务

使用 Go 和 Gin 框架构建简单的用户和物品管理 Web 服务 在本项目中&#xff0c;我们使用 Go 语言和 Gin 框架构建了一个简单的 Web 服务&#xff0c;能够管理用户和物品的信息。该服务实现了两个主要接口&#xff1a;根据用户 ID 获取用户名称&#xff0c;以及根据物品 ID 获…...

【VUE】双端比较算法

假设我们有两个虚拟节点 oldVnode 和 newVnode&#xff0c;它们分别对应的DOM结构为&#xff1a; 我们需要将 oldVnode 更新为 newVnode&#xff0c;这时就可以使用双端比较算法了。算法本质上是将新旧节点进行一次交叉比较&#xff0c;尽可能地重复使用已有的节点来达到最小…...

跨界的胜利:机器学习与神经网络的物理之光

近日&#xff0c;2024年诺贝尔物理学奖颁发给了机器学习与神经网络领域的研究者&#xff0c;这是历史上首次出现这样的情况。这项奖项原本只授予对自然现象和物质的物理学研究作出重大贡献的科学家&#xff0c;如今却将全球范围内对机器学习和神经网络的研究和开发作为了一种能…...

容器化技术:Docker的基本概念和使用

在现代软件开发和运维中&#xff0c;容器化技术已经成为一种不可或缺的工具。Docker作为容器化技术的代表&#xff0c;以其轻量级、可移植性和隔离性等特点&#xff0c;赢得了广泛的关注和应用。本文将详细介绍Docker的基本概念和使用方法&#xff0c;帮助读者快速上手Docker容…...

EcoVadis认证内容有哪些?EcoVadis认证申请流程?

EcoVadis认证是一个国际性的可持续发展评估平台&#xff0c;旨在帮助全球企业和供应链评鉴其在环境、社会和治理&#xff08;ESG&#xff09;方面的表现。该认证框架由法国的检验、认证和检测机构必维集团&#xff08;Bureau Veritas&#xff09;创建&#xff0c;得到了众多跨国…...

Windows 搭建 Gitea

一、准备工作 1. 安装 Git&#xff1a;Gitea 依赖 Git 进行代码管理&#xff0c;所以首先需要确保系统中安装了 Git。 下载地址&#xff1a;https://git-scm.com/downloads/win 2. 安装数据库&#xff08;可选&#xff09; 默认情况下&#xff0c;Gitea 使用 SQLite 作为内…...

嵌入式面试——FreeRTOS篇(五) 事件标志组

本篇为&#xff1a;FreeRTOS事件标志组篇 1、事件标志组介绍 答&#xff1a; 事件标志位&#xff1a;用一个位&#xff0c;来表示事件是否发生。 事件标志组是一组事件标志位的合集&#xff0c;可以简单的理解事件标志组&#xff0c;就是一个整数。 2、事件标志组的特点 答&am…...

智能听诊器:宠物健康管理的革命

智能听诊器不仅仅是一个简单的监测工具&#xff0c;它代表了宠物健康管理的一次革命。通过收集和分析宠物的生理数据&#xff0c;智能听诊器能够帮助宠物主人和医生更好地理解宠物的健康需求&#xff0c;从而提供更加个性化的护理方案。 智能听诊器通过高精度的传感器&#xf…...

dfs +剪枝sudoku———poj2676

目录 前言 lowbit函数 数独 suduku 问题描述 输入 输出 问题分析 子网格位置 优化搜索顺序剪枝1 优化搜索顺序剪枝2 可行性剪枝 代码 前言 lowbit函数 这是一个利用二进制位运算取出二进制数最后一位’1‘的函数 数独 数独大家肯定都玩过&#xff0c;…...

机器学习:关联规则:Apriori算法、FP - Growth算法的原理、应用场景及优缺点介绍

一、关联规则算法概述 关联规则挖掘是数据挖掘中的一个重要任务&#xff0c;用于发现数据集中不同项之间的关联关系。 二、Apriori算法 原理 频繁项集生成&#xff1a;Apriori算法基于一个先验原理&#xff0c;即如果一个项集是频繁的&#xff0c;那么它的所有子集也是频繁的…...

从0开始深度学习(7)——线性回归的简洁实现

在从0开始深度学习&#xff08;5&#xff09;——线性回归的逐步实现中&#xff0c;我们手动编写了数据构造模块、损失函数模块、优化器等&#xff0c;但是在现代深度学习框架下&#xff0c;这些已经包装好了 本章展示如果利用深度学习框架简洁的实现线性回归 0 导入头文件 im…...

【网络安全 | Java代码审计】华夏ERP(jshERP)v2.3

未经许可,不得转载。 文章目录 技术框架开发环境代码审计权限校验绕过SQL注入Fastjson反序列化命令执行存储型XSS越权/未授权重置密码越权/未授权删除用户信息越权/未授权修改用户信息会话固定安全建议项目地址:https://github.com/jishenghua/jshERP 技术框架 核心框架:Sp…...

Setting the value of ‘*‘ exceeded the quota

H5之localStorage限额报错quota_exceeded the quota-CSDN博客 Uncaught DOMException: Failed to set a named property on Storage: Setting the value of background exceeded the quota. 超出了 localStorage 的最大长度。...

前端页面模块修改成可动态生成数据模块——大部分数据为GPT生成(仅供学习参考)

前端页面模块修改成可动态生成数据模块&#xff1a; 这些案例展示了如何通过Blade模板将前端页面模块变成可动态生成的模板。通过巧妙使用Blade语法、控制结构、CSS/JS分离、组件复用等技巧&#xff0c;可以大大提高代码的灵活性和复用性。在Laravel的Controller中准备好数据并…...

在鸿蒙HarmonyOS 5中实现抖音风格的点赞功能

下面我将详细介绍如何使用HarmonyOS SDK在HarmonyOS 5中实现类似抖音的点赞功能&#xff0c;包括动画效果、数据同步和交互优化。 1. 基础点赞功能实现 1.1 创建数据模型 // VideoModel.ets export class VideoModel {id: string "";title: string ""…...

渗透实战PortSwigger靶场-XSS Lab 14:大多数标签和属性被阻止

<script>标签被拦截 我们需要把全部可用的 tag 和 event 进行暴力破解 XSS cheat sheet&#xff1a; https://portswigger.net/web-security/cross-site-scripting/cheat-sheet 通过爆破发现body可以用 再把全部 events 放进去爆破 这些 event 全部可用 <body onres…...

Mac软件卸载指南,简单易懂!

刚和Adobe分手&#xff0c;它却总在Library里给你写"回忆录"&#xff1f;卸载的Final Cut Pro像电子幽灵般阴魂不散&#xff1f;总是会有残留文件&#xff0c;别慌&#xff01;这份Mac软件卸载指南&#xff0c;将用最硬核的方式教你"数字分手术"&#xff0…...

10-Oracle 23 ai Vector Search 概述和参数

一、Oracle AI Vector Search 概述 企业和个人都在尝试各种AI&#xff0c;使用客户端或是内部自己搭建集成大模型的终端&#xff0c;加速与大型语言模型&#xff08;LLM&#xff09;的结合&#xff0c;同时使用检索增强生成&#xff08;Retrieval Augmented Generation &#…...

Go 语言并发编程基础:无缓冲与有缓冲通道

在上一章节中&#xff0c;我们了解了 Channel 的基本用法。本章将重点分析 Go 中通道的两种类型 —— 无缓冲通道与有缓冲通道&#xff0c;它们在并发编程中各具特点和应用场景。 一、通道的基本分类 类型定义形式特点无缓冲通道make(chan T)发送和接收都必须准备好&#xff0…...

脑机新手指南(七):OpenBCI_GUI:从环境搭建到数据可视化(上)

一、OpenBCI_GUI 项目概述 &#xff08;一&#xff09;项目背景与目标 OpenBCI 是一个开源的脑电信号采集硬件平台&#xff0c;其配套的 OpenBCI_GUI 则是专为该硬件设计的图形化界面工具。对于研究人员、开发者和学生而言&#xff0c;首次接触 OpenBCI 设备时&#xff0c;往…...

LOOI机器人的技术实现解析:从手势识别到边缘检测

LOOI机器人作为一款创新的AI硬件产品&#xff0c;通过将智能手机转变为具有情感交互能力的桌面机器人&#xff0c;展示了前沿AI技术与传统硬件设计的完美结合。作为AI与玩具领域的专家&#xff0c;我将全面解析LOOI的技术实现架构&#xff0c;特别是其手势识别、物体识别和环境…...

沙箱虚拟化技术虚拟机容器之间的关系详解

问题 沙箱、虚拟化、容器三者分开一一介绍的话我知道他们各自都是什么东西&#xff0c;但是如果把三者放在一起&#xff0c;它们之间到底什么关系&#xff1f;又有什么联系呢&#xff1f;我不是很明白&#xff01;&#xff01;&#xff01; 就比如说&#xff1a; 沙箱&#…...

解析两阶段提交与三阶段提交的核心差异及MySQL实现方案

引言 在分布式系统的事务处理中&#xff0c;如何保障跨节点数据操作的一致性始终是核心挑战。经典的两阶段提交协议&#xff08;2PC&#xff09;通过准备阶段与提交阶段的协调机制&#xff0c;以同步决策模式确保事务原子性。其改进版本三阶段提交协议&#xff08;3PC&#xf…...

Spring AOP代理对象生成原理

代理对象生成的关键类是【AnnotationAwareAspectJAutoProxyCreator】&#xff0c;这个类继承了【BeanPostProcessor】是一个后置处理器 在bean对象生命周期中初始化时执行【org.springframework.beans.factory.config.BeanPostProcessor#postProcessAfterInitialization】方法时…...