Java并发编程-线程池（四）
文章目录
- 线程池实现原理
- Worker
- Worker 核心设计总结
- runWorker(Worker w)
- 总结
线程池实现原理
上一篇我们看了 addWork 方法，那接下来就让我们详细看看内部类Worker。
Worker
private final class Workerextends AbstractQueuedSynchronizerimplements Runnable
{final Thread thread; //worker自己的线程Runnable firstTask;Worker(Runnable firstTask) {setState(-1); // 默认禁止中断this.firstTask = firstTask;this.thread = getThreadFactory().newThread(this);}public void run() {runWorker(this); // 调用ThreadPoolExecutor的runWorker方法（后面会讲）}protected boolean isHeldExclusively() {return getState() != 0;}protected boolean tryAcquire(int unused) {if (compareAndSetState(0, 1)) { //仅当状态为0时获取锁，不可重入setExclusiveOwnerThread(Thread.currentThread());//课后习题return true;}return false;}protected boolean tryRelease(int unused) {setExclusiveOwnerThread(null);setState(0);return true;}public void lock() { acquire(1); }public boolean tryLock() { return tryAcquire(1); }public void unlock() { release(1); }public boolean isLocked() { return isHeldExclusively(); }void interruptIfStarted() {//调用链：shutdownNow()->interruptWorkers()->interruptIfStarted()Thread t;if (getState() >= 0 && (t = thread) != null && !t.isInterrupted()) {// 中断条件：运行中/运行结束 && 线程初始化过 && 没有被中断过try {t.interrupt();} catch (SecurityException ignore) {}}}
}
Worker类也继承了AQS，主要目的是利用state实现线程执行任务时的中断控制，确保线程池的优雅关闭机制。利用AQS的state字段来区分线程的初始状态、运行状态及中断权限。
-
初始化锁状态：在
Worker的构造函数中调用setState(-1)，将状态设置为非0值（-1），表示**默认禁止中断** 。这样可以避免新创建的Worker线程在未执行任务前（即未调用runWorker方法时）被中断干扰。- 实际任务执行时：在
runWorker方法中，通过调用unlock()方法将状态从-1重置为0，表示允许中断。
- 实际任务执行时：在
-
shutdownNow()的中断条件：运行中/运行结束 && 线程初始化过 && 没有被中断过
-
shutdown()的中断条件：
final void runWorker(Worker w) {...w.unlock(); // 允许中断...w.lock();...w.unlock();...
}
//调用链：shutdown()->interruptIdleWorkers()
private void interruptIdleWorkers() {final ReentrantLock mainLock = this.mainLock;mainLock.lock();try {for (Worker w : workers) {Thread t = w.thread;if (!t.isInterrupted() && w.tryLock()) {// 中断条件：没有被中断 && 没有任务在执行try {t.interrupt();} catch (SecurityException ignore) {} finally {w.unlock();}}}} finally {mainLock.unlock();}
}
Worker 核心设计总结
-
同步机制：通过AQS的自定义锁管理，实现任务的原子执行和中断控制。
-
状态标记：利用AQS的
state字段区分线程的初始状态、运行状态及中断权限。 -
线程池管理：支持线程池在关闭时区分处理空闲线程和运行线程，确保任务完整性。
Worker会循环获取工作队列里的任务来执行。我们可以从Worker类的run()方法里看到这点：
runWorker(Worker w)
final void runWorker(Worker w) {Thread wt = Thread.currentThread();Runnable task = w.firstTask;w.firstTask = null;w.unlock(); // 允许中断//标识线程是否因异常（如任务抛出未捕获错误）而非正常退出boolean completedAbruptly = true; try {// 循环获取工作队列里的任务来执行while (task != null || (task = getTask()) != null) {// 当前有任务 或者 能从队列中拿到任务w.lock();if ((runStateAtLeast(ctl.get(), STOP) ||//若线程池正在关闭（STOP 状态）(Thread.interrupted() &&runStateAtLeast(ctl.get(), STOP))) &&// Thread.interrupted() 会清除当前线程的中断状态（返回历史值），// 若为 true 且线程池已停止，需重新标记中断防止代码忽略此请求。!wt.isInterrupted())//在强制关闭（如 shutdownNow()）时，快速中断正在处理的任务wt.interrupt();try {//空方法（钩子），可被子类覆写以添加日志、监控或自定义逻辑（如任务执行时间统计）beforeExecute(wt, task);Throwable thrown = null;try {task.run(); // 执行任务} catch (RuntimeException x) {thrown = x; throw x;} catch (Error x) {thrown = x; throw x;} catch (Throwable x) {thrown = x; throw new Error(x);} finally {afterExecute(task, thrown);}} finally {task = null;//避免任务对象被错误复用或内存泄漏w.completedTasks++;//统计Worker完成的任务数（用于线程池监控或扩容策略）w.unlock();}}completedAbruptly = false;} finally {processWorkerExit(w, completedAbruptly);}
}
protected void beforeExecute(Thread t, Runnable r) { }
protected void afterExecute(Runnable r, Throwable t) { }private void processWorkerExit(Worker w, boolean completedAbruptly) {if (completedAbruptly)//补偿操作：若线程异常终止（未正常调整计数），//需主动减少工作线程计数（workerCount）以保持准确性decrementWorkerCount();final ReentrantLock mainLock = this.mainLock;mainLock.lock();try {completedTaskCount += w.completedTasks;//累计完成数workers.remove(w);//移除失效线程} finally {mainLock.unlock();}//当前线程退出后可能满足线程池终止条件（如所有线程退出且任务队列为空）//尝试将线程池状态过渡到TERMINATED（需符合SHUTDOWN/STOP状态且无活动线程和待处理任务）tryTerminate();int c = ctl.get();if (runStateLessThan(c, STOP)) {//线程池仍允许处理任务（如RUNNING/SHUTDOWN）if (!completedAbruptly) {//若允许核心线程超时（allowCoreThreadTimeOut），最小值为 0；//否则为 corePoolSizeint min = allowCoreThreadTimeOut ? 0 : corePoolSize;if (min == 0 && ! workQueue.isEmpty())min = 1;// 队列非空时至少保留一个线程处理任务if (workerCountOf(c) >= min)return; //当前线程数足够，无需补充}addWorker(null, false);//补充新Worker}
}
总结
ThreadPoolExecutor中线程执行任务的示意图
线程池中的线程执行任务分两种情况。
-
在execute()方法中创建一个线程时，会让这个线程执行当前任务。
-
这个线程执行完上图中1的任务后，会反复从BlockingQueue获取任务来执行。
相关文章：
Java并发编程-线程池（四）
文章目录 线程池实现原理WorkerWorker 核心设计总结 runWorker(Worker w)总结 线程池实现原理 上一篇我们看了 addWork 方法，那接下来就让我们详细看看内部类Worker。 Worker private final class Workerextends AbstractQueuedSynchronizerimplements Runnable …...
力扣热题——最长相邻不相等子序列 |
题目要求从字符串数组 words 中选出一个最长的子序列，使得该子序列中相邻字符串对应的 groups 数组中的值不同。通过贪心算法，可以高效地解决该问题。具体步骤为：初始化一个结果列表，遍历 words 数组，检查当前字符串的…...
筑牢信息安全防线：涉密计算机与互联网隔离的理论实践与风险防控
在数字化时代，信息安全已成为国家安全体系的重要组成部分。涉密计算机作为承载敏感信息的核心载体，其安全防护工作直接关系到国家利益与社会稳定。违规连接互联网这一行为，如同在严密的防护体系中打开一扇危险的"暗门"，…...
sqli-labs靶场29-31关（http参数污染）
目录 前言 less29（单引号http参数污染） less30（双引号http参数污染） less31(双引号括号http参数污染) 前言 在JSP中，使用request.getParameter("id")获取请求参数时，如果存在多个同名参数&a…...
基于Linux环境实现Oracle goldengate远程抽取MySQL同步数据到MySQL
基于Linux环境实现Oracle goldengate远程抽取MySQL同步数据到MySQL 场景说明： 先有项目需要读取生产库数据，但是不能直接读取生产库数据，需要把生产数据同步到一个中间库，下游系统从中间库读取数据。 生产库mysql - OGG - 中间库…...
linux,我启动一个springboot项目， 用java -jar xxx.jar ,但是没多久这个java进程就会自动关掉
当使用 java -jar xxx.jar & 启动 Spring Boot 项目后进程自动关闭时，可能由多种原因导致。以下是常见排查步骤和解决方案： 一、查看日志定位原因 进程异常关闭通常会在控制台或日志中留下线索，建议先获取完整日志： 1. 查看…...
pytorch 14.3 Batch Normalization综合调参实践
文章目录 一、Batch Normalization与Batch_size综合调参二、复杂模型上的Batch_normalization表现1、BN对复杂模型（sigmoid）的影响2、模型复杂度对模型效果的影响3、BN对复杂模型（tanh）的影响 三、包含BN层的神经网络的学习率优化…...
供应链安全检测系列技术规范介绍之一|软件成分分析
软件成分分析的概念及意义 软件成分分析Software Compostition Analysis（SCA）是一种用于管理开源组件应用安全的方法。软件成分分析系统可以快速跟踪和分析应用软件的开源组件，发现相关组件、支持库以及它们之间直接和间接依赖关系࿰…...
pytorch 15.1 学习率调度基本概念与手动实现方法
文章目录 一、学习率对模型训练影响 二、学习率调度基本概念与手动实现方法1.模型调度基本概念2.手动实现学习率调度3.常用学习率调度思路 从本节开始，我们将介绍深度学习中学习率优化方法。学习率作为模型优化的重要超参数，在此前的学习中，我…...
c++ 类的语法4
测试析构函数、虚函数、纯虚函数： void testClass5() {class Parent {public:Parent(int x) { cout << "Parent构造: " << x << endl; }~Parent() {cout << "调用Parent析构函数" << endl;}virtual string toSt…...
品铂科技在UWB行业地位综述（2025年更新）
一、行业领先地位 国内UWB领域头部企业 在2025年中国UWB企业综合实力排行榜中位列第一，技术研发、市场份额及行业影响力均处于领先地位。连续多年获评中国物联网产业联盟“中国最有影响力物联网定位企业”。 2.全球技术竞争力 .2016年IPSN微软国际室内…...
muduo库EventLoop模块详解
muduo库EventLoop模块深度解析 EventLoop是muduo网络库实现Reactor模型的核心调度中枢，负责驱动整个事件循环机制，协调Poller、Channel、TimerQueue等组件的工作。其设计遵循"One Loop Per Thread"原则。 一、核心职责与设计思想 1. 核心职责…...
循环导入（Circular Import） 错误
ImportError: cannot import name event_type_data_tree from partially initialized module routers.ticket (most likely due to a circular import) (E:\ai12345\backend\app\routers\ticket.py) 这是什么错，中文回答 这个错误是 循环导入（Circular …...
基于大数据的租房信息可视化系统的设计与实现【源码+文档+部署】
课题名称 基于大数据的租房信息可视化系统的设计与实现 学 院 专 业 计算机科学与技术 学生姓名 指导教师 一、课题来源及意义 租房市场一直是社会关注的热点问题。随着城市化进程的加速，大量人口涌入城市，导致租房需求激增。传统的租…...
奥运数据可视化：探索数据讲述奥运故事
在数据可视化的世界里，体育数据因其丰富的历史和文化意义，常常成为最有吸引力的主题之一。今天我要分享一个令人着迷的奥运数据可视化项目，它巧妙地利用交互式图表和动态动画，展现了自1896年至今奥运会的发展历程和各国奥运成就的…...
linux环境下 安装svn并且创建svn版本库详细教程
一、安装SVN 通过yum安装Subversion 在Linux系统中执行以下命令安装： yum install subversion -y 安装完成后，验证版本： svnserve --version 二、创建版本库 选择存储路径并创建目录 通常将版本库放在/var/svn或/usr/local/…...
STM32控制电机
初始化时钟：在 STM32 的程序中，初始化系统时钟，一般会使用 RCC（Reset and Clock Control）相关函数来配置时钟。例如，对于 STM32F103 系列，可能会使用 RCC_APB2PeriphClockCmd 函数来使能 GPIO 和…...
Ubuntu 更改 Nginx 版本
将 1.25 降为 1.18 先卸载干净 # 1. 完全卸载当前Nginx sudo apt purge nginx nginx-common nginx-core# 2. 清理残留配置 sudo apt autoremove sudo rm -rf /etc/apt/sources.list.d/nginx*.list修改仓库地址 # 添加仓库（通用稳定版仓库） codename$(…...
微服务初步学习
系统架构演变过程 一、单体架构 前后端都在一个项目中，包括我们现在的前后端分离开发，都可以看作是一个单体项目。 二、集群架构 把一个服务部署多次，可以解决服务不够的问题，但是有些不必要的功能也跟着部署多次。 三、垂直架…...
旧 docker 版本通过 nvkind 搭建虚拟多节点 gpu 集群的坑
踩坑 参考nvkind教程安装到Setup这一步，由于docker版本较旧，–cdi.enabled 和 config 参数执行不了 手动修改 /etc/docker/daemon.json 配置文件 "features": {"cdi": true}手动修改 /etc/nvidia-container-runtime/config.toml 配…...
Fabric 服务端插件开发简述与聊天事件监听转发
原文链接：Fabric 服务端插件开发简述与聊天事件监听转发 < Ping通途说 0. 引言 以前写过Spigot的插件，非常简单，仅需调用官方封装好的Event类即可。但Fabric这边在开发时由于官方文档和现有互联网资料来看，可能会具有一定的误…...
Wise Disk Cleaner：免费系统清理工具，释放空间，提升性能
Wise Disk Cleaner是一款功能强大且完全免费的系统清理工具，专为帮助用户清理系统中的无用文件和垃圾文件而设计。它能够有效释放磁盘空间，提高系统运行速度，确保电脑始终保持最佳性能。无论是日常维护还是深度清理，Wise Disk Cle…...
排序算法之高效排序:快速排序,归并排序,堆排序详解
排序算法之高效排序：快速排序、归并排序、堆排序详解 前言一、快速排序（Quick Sort）1.1 算法原理1.2 代码实现（Python）1.3 性能分析 二、归并排序（Merge Sort）2.1 算法原理2.2 代码实现…...
主打「反激进」的一汽丰田，靠稳扎稳打的技术实现突围
文/王俣祺 导语：今年的上海车展，当新势力都在用“1000TOPS算力”“激光雷达矩阵”等参数堆砌着一个个技术神话的时候，一汽丰田却选择了一条不同的路——用“反激进”的技术哲学，在电动化和智能化的大风向中，构建独特的…...
变量赋值和数据类型
对象 Python是面相对象的编程语言，在Python一些都是对象，对象由标识、类型、值三部分组成，本质上来讲，系统分配一块内存，这块内存中存储了特定了的值，还支持特定类型的相关操作。 标识：即对象…...
【笔记】cri-docker.service和containerd
cri-docker.service 和 containerd 都是 Kubernetes 支持的容器运行时组件，但它们的架构、功能定位及与 Docker 的关系有显著差异。以下是它们的核心区别和关联： 1. 功能定位 组件核心角色是否直接支持 CRIcontainerd轻量级容器运行时，直接管…...
技术文章：解决汇川MD500系列变频器干扰问题——GRJ9000S EMC滤波器的应用
1. 引言 汇川MD500系列变频器（Variable Frequency Drive, VFD）以其高性能、宽功率范围（0.4kW-500kW）和灵活的控制方式，广泛应用于工业自动化领域，如风机、水泵、传送带和压缩机等。然而，MD500系…...
频域中的反射-信号完整性分析
频域中的反射: 频域与时域的桥梁是傅里叶变换，一个周期信号可以拆分为许多个正弦波。所谓从频域中看信号，看到的可以是很多个频域中的点，也可以是许多个正弦波。 所以在大家眼中看到的信号如图4-13所示。我们可以将该信号分解为图4-14所示信号。 让我们来思考下面这个问题：…...
window nvidia-smi命令 Failed to initialize NVML: Unknown Error
如果驱动目录下的可以执行，那可能版本原因 "C:\Program Files\NVIDIA Corporation\NVSMI\nvidia-smi"复制"C:\Program Files\NVIDIA Corporation\NVSMI\nvidia-smi.exe"替换 C:\Windows\System32\nvidia-smi.exe 或者 把C:\Windows\System3…...
ubuntu 20.04 更改国内镜像源-阿里源 确保可用
镜像源是跟linux版本一一对应的,查询自己系统的版本号： 命令：lsb_release -a macw:~$ lsb_release -a No LSB modules are available. Distributor ID: Ubuntu Description: Ubuntu 20.04.6 LTS Release: 20.04 Codename: focal macw:~$…...
Elasticsearch 学习（一）如何在Linux 系统中下载、安装
目录 一、Elasticsearch 下载二、使用 yum、dnf、zypper 命令下载安装三、使用 Docker 本地快速启动安装（ESKibana）【测试推荐】3.1 介绍3.2 下载、安装、启动3.3 访问3.4 修改配置，支持ip访问 官网地址： https://www.elastic.co/…...
PYTHON训练营DAY27
装饰器 编写一个装饰器 logger，在函数执行前后打印日志信息（如函数名、参数、返回值） logger def multiply(a, b):return a * bmultiply(2, 3) # 输出: # 开始执行函数 multiply，参数: (2, 3), {} # 函数 multiply 执行完毕&a…...
Shell脚本日志输出完整指南（AI）
一、基础日志输出方法 1. 标准输出与错误重定向 在Shell脚本中，可以使用重定向操作符将命令输出记录到日志文件： >：覆盖写入文件>>：追加写入文件2>：重定向错误输出&>：同时重定向标准…...
 - 创建文件、打开文件、写入数据、追加数据、读取数据、创建目录、删除目录)
node.js文件系统(fs) - 创建文件、打开文件、写入数据、追加数据、读取数据、创建目录、删除目录
注意：以下所有示例均是异步语法！ 注意：以下所有示例均是异步语法！ 创建文件 node.js 允许我们在计算机本地创建文件，例如创建一个 word 文件： // 引入核心模块(fs) var fs require(fs)// API fs.writeF…...
关于如何本地启动xxl-job，并且整合SpringBoot
1. 本地安装xxl-job并启动 拉取xxl-job的代码 git clone gitgithub.com:xuxueli/xxl-job.git配置xxl-job数据库 拉取代码后，代码的doc/db目录下有官方配置好的sql脚本，执行里面的sql脚本至本地数据库 3. 修改xxl-job默认的数据库配置 spring.dataso…...
基于Unity的简单2D游戏开发
基于Unity的简单2D游戏开发 摘要 本文围绕基于Unity的简单2D游戏开发进行深入探讨，旨在分析其开发过程中的技术架构与实现策略。通过文献综述与市场分析，研究发现，近年来Unity引擎因其优秀的跨平台特性及可视化编程理念，成为2D游戏开发的主要工具。文章首先梳理了游戏开发的…...
_cat: /usr/include/cudnn_version.h: 没有那个文件或目录)
在服务器上安装AlphaFold2遇到的问题(3)_cat: /usr/include/cudnn_version.h: 没有那个文件或目录
[rootlocalhost ~]# cat /usr/include/cudnn_version.h cat: /usr/include/cudnn_version.h: 没有那个文件或目录这个错误表明系统找不到 cudnn_version.h 头文件，说明 cuDNN 的开发文件（头文件）没有正确安装。以下是完整的解决方案ÿ…...
Java生产环境设限参数教学
哈哈，这个问题问得好！咱们用开餐厅的比喻来理解生产环境的四大必须设限参数，保证你听完再也不会忘！（搓手手） 1. 堆内存上限：-Xmx（厨房的最大容量） 问题：想象…...
武汉火影数字全息剧秀制作：科技与艺术的梦幻联动
全息剧秀是通过全息投影技术、多媒体互动技术、舞台表演艺术等元素深度融合的新型演出形式。 随着科技的不断进步，投影技术的更加成熟，全息剧秀作为演艺行业的创新力量，正以其独特的魅力和无限的潜力，为观众带来全新的视听盛宴。 …...
MySQL锁机制详解与加锁流程全解析
一、MySQL锁机制全景图 1.1 锁类型体系 #mermaid-svg-czUB6iJgmHuOPdN1 {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-czUB6iJgmHuOPdN1 .error-icon{fill:#552222;}#mermaid-svg-czUB6iJgmHuOPdN1 .error-text{f…...
云轴科技ZStack官网上线Support AI，智能助手助力高效技术支持
5月16日，云轴科技ZStack在官网（www.zstack.io）正式上线ZStack Support AI智能助手。该系统是ZStack应用人工智能于技术支持服务领域的重要创新，基于自研ZStack AIOS平台智塔及LLMOPS技术打造。 ZStack Support AI定位为智能客服&…...
)
深度学习笔记23-LSTM实现火灾预测(Tensorflow)
🍨 本文为🔗365天深度学习训练营中的学习记录博客🍖 原作者： 一、前期准备 1.导入数据 import pandas as pd import numpy as npdf_1 pd.read_csv("D:\TensorFlow1\woodpine2.csv") df_1import matplotlib.pyplot as…...
单例模式（Singleton Pattern）详解
单例模式（Singleton Pattern）详解 1. 定义与核心目标 单例模式是一种创建型设计模式，确保一个类只有一个实例，并提供全局访问点。核心目标： 控制实例数量：防止重复创建对象，节省资源。统一管理共享资源：如配置管理、数据库连接池、日志处理器等。2. 实现方式及对比 (…...
IntelliJ IDEA打开项目后，目录和文件都不显示，只显示pom.xml，怎样可以再显示出来？
检查.idea文件夹 如果项目目录中缺少.idea文件夹，可能导致项目结构无法正确加载。可以尝试删除项目根目录下的.idea文件夹，然后重新打开项目，IDEA会自动生成新的.idea文件夹和相关配置文件，从而恢复项目结构。 问题解决࿰…...
LongRefiner：解决长文档检索增强生成的新思路
大语言模型与RAG的应用越来越广泛，但在处理长文档时仍面临不少挑战。今天我们来聊聊一个解决这类问题的新方法——LongRefiner。 背景问题：长文档处理的两大难题 使用检索增强型生成（RAG）系统处理长文档时，主要有两个…...
Tcping详细使用教程
Tcping详细使用教程 下载地址 https://download.elifulkerson.com/files/tcping/0.39/在windows环境下安装tcping 在以上的下载地中找到exe可执行文件，其中tcping.exe适用于32位Windows系统，tcping64.exe适用于64位Windows操作系统。 其实tcping是个…...
Java + 鸿蒙双引擎：ZKmall开源商城如何定义下一代B2C商城技术标准？
在 B2C 电商领域持续革新的当下，技术架构的优劣成为决定商城竞争力的核心要素。ZKmall开源商城以其创新融合的 Java 与鸿蒙双引擎，为下一代 B2C 商城技术标准勾勒出全新蓝图，在性能、兼容性、拓展性等关键维度实现了重大突破。 一、Java 技术…...
华为云Flexus+DeepSeek征文｜基于Dify平台tiktok音乐领域热门短视频分析Ai agent
前言 在当今数字化快速发展的时代，人工智能技术尤其是大模型的应用，正逐渐成为推动各行业创新与变革的关键力量。大模型凭借其强大的语言理解、生成和逻辑推理能力，为企业和开发者提供了全新的解决方案和应用可能性。然而，将这些…...
排序算法之线性时间排序:计数排序,基数排序,桶排序详解
排序算法之线性时间排序：计数排序、基数排序、桶排序详解 前言一、计数排序（Counting Sort）1.1 算法原理1.2 代码实现（Python）1.3 性能分析1.4 适用场景 二、基数排序（Radix Sort）2.1 算法原理2…...
HarmonyOS 开发之 —— 合理使用动画与转场
HarmonyOS 开发之 —— 合理使用动画与转场 谢谢关注！！ 前言：上一篇文章主要介绍HarmonyOs开发之———UIAbility进阶:https://blog.csdn.net/this_is_bug/article/details/147976323?spm=1011.2415.3001.10575&sharefrom=mp_manage_link 在移动应用开发中，动画与转…...