Java线程池提交任务流程底层源码与源码解析
前言
嘿,各位技术爱好者们,今天咱们来聊聊Java线程池提交任务的底层源码与源码解析。作为一个资深的Java开发者,我相信你一定对线程池并不陌生。线程池作为并发编程中的一大利器,其重要性不言而喻。今天,我将以对话的方式,带你一步步深入线程池的奥秘,从概述到功能点,再到背景和业务点,最后到底层原理和示例,让你对线程池有一个全新的认识。
一、概述
我:你好,今天咱们来聊聊Java线程池吧。
你:好呀,线程池确实是个好东西,能显著提高系统的性能和资源利用率。
我:没错,线程池通过预先创建一定数量的线程,并将这些线程放入一个容器中,来管理和复用线程。当任务提交时,线程池会从容器中选择一个空闲的线程来执行任务,避免了频繁创建和销毁线程的开销。
你:那线程池主要用在哪些场景呢?
我:线程池的应用场景非常广泛,比如Web服务器处理客户端请求、并发编程管理并发任务、异步任务处理、定时任务调度以及后台线程处理等。
二、功能点
我:线程池的功能点有哪些呢?
你:线程池的功能点主要包括以下几个方面:
- 降低资源消耗:通过复用线程,避免频繁创建和销毁线程的开销。
- 提高响应速度:当任务到达时,可以立即从线程池中获取线程执行任务,无需等待线程创建。
- 提高线程的可管理性:线程池可以统一管理线程的生命周期,方便进行调优和监控。
- 控制并发度:通过限制线程池中的线程数量,避免过多的线程竞争资源导致性能下降。
我:这些功能点确实非常实用,那线程池是如何实现这些功能的呢?
你:这就涉及到线程池的底层原理了,我们接下来详细聊聊。
三、背景
我:在深入底层原理之前,我们先来聊聊线程池的背景吧。
你:好的,在传统的多线程编程中,每次需要执行任务时都会创建一个新的线程,任务执行完毕后再销毁该线程。这种方式存在一些问题,比如频繁创建和销毁线程会带来较大的开销,线程数量的不可控会导致系统资源的浪费和性能下降。
我:确实,这些问题在多线程编程中非常常见。那线程池是如何解决这些问题的呢?
你:线程池通过预先创建一定数量的线程,并将这些线程放入一个容器中,来管理和复用线程。当任务提交时,线程池会从容器中选择一个空闲的线程来执行任务,避免了频繁创建和销毁线程的开销。同时,线程池还可以根据系统的负载情况动态调整线程的数量,以适应不同的负载需求。
四、业务点
我:在实际业务开发中,我们如何使用线程池呢?
你:在实际业务开发中,我们通常会根据任务的特性和线程池的负载情况选择适当的线程池类型。Java提供了多种线程池类型,比如FixedThreadPool、CachedThreadPool、SingleThreadPool、ScheduledThreadPool等。每种线程池类型都有其适用的场景和优缺点。
我:能详细介绍一下这些线程池类型吗?
你:当然可以。
- FixedThreadPool:固定大小线程池,包含固定数量的线程。适用于需要限制并发线程数量的场景。
- CachedThreadPool:缓存线程池,不固定线程数量,可以根据需要自动创建新线程。适用于短期异步任务。
- SingleThreadPool:单线程池,只包含一个工作线程。适用于需要保持任务顺序执行的场景。
- ScheduledThreadPool:定时线程池,可以执行定时任务和周期性任务。
我:了解了这些线程池类型后,我们就可以根据实际需求选择合适的线程池了。
五、底层原理
我:接下来我们来聊聊线程池的底层原理吧。
你:好的,线程池的底层原理主要涉及到线程池的状态管理、工作线程的创建与销毁、任务队列的管理以及拒绝策略的处理等方面。
我:那我们先从线程池的状态管理开始吧。
你:线程池的状态管理是通过一个整数变量ctl
来实现的。ctl
变量使用了位分割技术,其中一部分位用于表示线程池的状态,另一部分位用于表示线程的数量。线程池的状态主要有以下几种:
- RUNNING:线程池接受新任务,并处理阻塞队列中的任务。
- SHUTDOWN:不再接受新任务,但是会继续处理阻塞队列中的任务直到完成。
- STOP:不再接受新任务,并取消正在执行的任务,同时清空阻塞队列。
- TIDYING:所有任务完成后,线程池进入这个状态。
- TERMINATED:线程池完成所有任务,并且所有工作线程都已经终止。
我:了解了线程池的状态后,我们再来看看工作线程的创建与销毁吧。
你:工作线程的创建与销毁主要是通过addWorker
方法和tryTerminate
方法来实现的。当有新任务提交时,线程池会判断是否需要创建新的工作线程。如果需要,就调用addWorker
方法来创建一个新的工作线程。当工作线程空闲时间超过设定的存活时间时,线程池会调用tryTerminate
方法来销毁该工作线程。
我:那任务队列的管理呢?
你:任务队列的管理主要是通过workQueue
来实现的。workQueue
是一个阻塞队列,用于存放待执行的任务。当线程池中的工作线程执行完任务后,会从任务队列中获取下一个任务执行。如果任务队列为空,工作线程会进入等待状态,直到有新的任务提交到任务队列中。
我:最后我们来看看拒绝策略的处理吧。
你:拒绝策略的处理主要是通过RejectedExecutionHandler
接口来实现的。当任务队列已满且无法继续添加任务时,线程池会根据拒绝策略来处理新提交的任务。Java提供了几种内置的拒绝策略,比如AbortPolicy
(抛出异常)、CallerRunsPolicy
(在调用者线程中执行任务)、DiscardPolicy
(丢弃任务)和DiscardOldestPolicy
(丢弃队列中最旧的任务)等。当然,我们也可以根据实际需求来实现自定义的拒绝策略。
六、示例
我:了解了线程池的底层原理后,我们来看看具体的示例吧。
你:好的,我们先来看一个简单的示例,演示如何使用线程池来执行任务。
示例一:使用线程池执行任务
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
public class ThreadPoolExample {
public static void main(String[] args) {
// 创建一个固定大小的线程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交任务
for (int i = 0; i < 10; i++) {
final int index = i;executorService.execute(() -> {System.out.println("Task " + index + " is running by " + Thread.currentThread().getName());});}
// 关闭线程池executorService.shutdown();}
}
我:这个示例很简单,创建了一个固定大小的线程池,并提交了10个任务。每个任务都会打印出执行该任务的线程名称。
你:没错,这个示例展示了如何使用线程池来执行任务。接下来我们来看一个稍微复杂一点的示例,演示如何使用线程池来提交带返回值的任务,并获取任务的执行结果。
示例二:提交带返回值的任务并获取执行结果
import java.util.concurrent.Callable;
import java.util.concurrent.ExecutionException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.Future;
public class CallableThreadPoolExample {
public static void main(String[] args) {
// 创建一个固定大小的线程池
ExecutorService executorService = Executors.newFixedThreadPool(5);
// 提交带返回值的任务Future<Integer> future1 = executorService.submit(new Callable<Integer>() {
@Override
public Integer call() throws Exception {Thread.sleep(1000); // 模拟耗时任务
return 1 + 1;}});Future<String> future2 = executorService.submit(new Callable<String>() {
@Override
public String call() throws Exception {Thread.sleep(2000); // 模拟耗时任务
return "Hello, World!";}});
try {
// 获取任务的执行结果
Integer result1 = future1.get();
String result2 = future2.get();System.out.println("Task 1 result: " + result1);System.out.println("Task 2 result: " + result2);} catch (InterruptedException | ExecutionException e) {e.printStackTrace();}
// 关闭线程池executorService.shutdown();}
}
我:这个示例展示了如何使用线程池来提交带返回值的任务,并通过Future
对象来获取任务的执行结果。
你:没错,这个示例更加实用。在实际开发中,我们经常会需要提交带返回值的任务,并获取任务的执行结果。线程池提供了很好的支持。
我:那接下来我们再看一个示例,演示如何使用自定义的线程工厂和拒绝策略。
示例三:使用自定义线程工厂和拒绝策略
import java.util.concurrent.*;
public class CustomThreadPoolExample {
public static void main(String[] args) {
// 创建自定义的线程工厂
ThreadFactory threadFactory = new ThreadFactory() {
private int count = 1;
@Override
public Thread newThread(Runnable r) {
Thread thread = new Thread(r, "my-thread-" + count);count++;
return thread;}};
// 创建自定义的拒绝策略
RejectedExecutionHandler rejectedExecutionHandler = new RejectedExecutionHandler() {
@Override
public void rejectedExecution(Runnable r, ThreadPoolExecutor executor) {System.out.println("Task " + r.toString() + " rejected from " + executor.toString());}};
// 创建线程池,并传入自定义的线程工厂和拒绝策略
ThreadPoolExecutor threadPoolExecutor = new ThreadPoolExecutor(
2, // 核心线程数
5, // 最大线程数
60, // 空闲线程存活时间TimeUnit.SECONDS, // 时间单位
new LinkedBlockingQueue<>(10), // 任务队列threadFactory, // 线程工厂rejectedExecutionHandler // 拒绝策略);
// 提交任务
for (int i = 0; i < 20; i++) {
final int index = i;threadPoolExecutor.execute(() -> {System.out.println("Task " + index + " is running by " + Thread.currentThread().getName());});}
// 关闭线程池threadPoolExecutor.shutdown();}
}
我:这个示例展示了如何使用自定义的线程工厂和拒绝策略来创建线程池。通过自定义线程工厂,我们可以给每个线程设置更有意义的名字;通过自定义拒绝策略,我们可以定义当任务无法被线程池执行时的处理方式。
你:没错,这个示例非常实用。在实际开发中,我们经常会需要根据业务需求来自定义线程工厂和拒绝策略。
七、优缺点
我:那使用线程池有哪些优缺点呢?
你:使用线程池的优缺点主要有以下几个方面:
优点:
- 降低资源消耗:通过复用线程,避免频繁创建和销毁线程的开销。
- 提高响应速度:当任务到达时,可以立即从线程池中获取线程执行任务,无需等待线程创建。
- 提高线程的可管理性:线程池可以统一管理线程的生命周期,方便进行调优和监控。
- 控制并发度:通过限制线程池中的线程数量,避免过多的线程竞争资源导致性能下降。
缺点:
- 增加系统复杂性:使用线程池会增加系统的复杂性,需要合理配置线程池的参数,并进行调优和监控。
- 可能引发死锁:如果任务之间存在依赖关系,并且没有正确处理,可能会引发死锁问题。
- 资源限制:线程池中的线程数量是有限的,如果任务数量过多,可能会导致任务堆积,影响系统的响应速度。
我:了解了这些优缺点后,我们就可以更加合理地使用线程池了。
八、总结
我:今天咱们聊了这么多关于线程池的内容,你有什么感想吗?
你:我觉得线程池确实是一个非常强大的工具,能够显著提高系统的性能和资源利用率。但是,在使用线程池时也需要注意合理配置参数,并进行调优和监控,以避免潜在的问题。
我:没错,线程池虽然强大,但也需要我们谨慎使用。好了,今天的聊天就到这里吧。如果你对线程池还有其他问题或者想深入了解某个方面,随时都可以来找我哦。
你:好的,谢谢你今天的分享!
后记
希望通过今天的对话,你对Java线程池提交任务的底层源码与源码解析有了更深入的了解。线程池作为并发编程中的一大利器,其重要性不言而喻。在实际开发中,我们需要根据业务需求合理选择线程池类型,并合理配置参数,以充分发挥线程池的优势。同时,我们也需要关注线程池的调优和监控,以确保系统的稳定性和性能。
相关文章:
Java线程池提交任务流程底层源码与源码解析
前言 嘿,各位技术爱好者们,今天咱们来聊聊Java线程池提交任务的底层源码与源码解析。作为一个资深的Java开发者,我相信你一定对线程池并不陌生。线程池作为并发编程中的一大利器,其重要性不言而喻。今天,我将以对话的…...

新型大语言模型的预训练与后训练范式,Meta的Llama 3.1语言模型
前言:大型语言模型(LLMs)的发展历程可以说是非常长,从早期的GPT模型一路走到了今天这些复杂的、公开权重的大型语言模型。最初,LLM的训练过程只关注预训练,但后来逐步扩展到了包括预训练和后训练在内的完整…...
硬菜3道+馒头
硬菜3道 1、可乐鸡翅 》鸡翅滑刀酱油耗油胡椒粉盐》 搅拌腌制3-5分钟 》油锅,直到2面煎黄 》倒入可乐,到大火收汁,出锅 2、洋葱牛肉 》冻牛肉切薄酱油耗油胡椒粉盐 》手指摇匀 》加入生粉水,继续摇匀》直到粘稠 》油锅牛肉炒半熟&…...

YOLO系列论文综述(从YOLOv1到YOLOv11)【第14篇:YOLOv11——在速度和准确性方面具有无与伦比的性能】
YOLOv11 1 摘要2 改进点3 模型性能4 模型架构 YOLO系列博文: 【第1篇:概述物体检测算法发展史、YOLO应用领域、评价指标和NMS】【第2篇:YOLO系列论文、代码和主要优缺点汇总】【第3篇:YOLOv1——YOLO的开山之作】【第4篇ÿ…...

【Spring】聊聊@EventListener注解原理
1.一个Demo出发 在平时的开发中,其实编写同步线程代码是比较容易的,但是如何将一些操作和另外一些操作进行解除耦合,而事件方式 是一种很好的解耦合方式,比如当一个用户注销一个APP之后,需要发送一些短信 让他引流回来…...
LangChain——HTML文本分割 多种文本分割
Text Splitters 文本分割器 加载文档后,您通常会想要对其进行转换以更好地适合您的应用程序。最简单的例子是,您可能希望将长文档分割成更小的块,以适合模型的上下文窗口。 LangChain 有许多内置的文档转换器,可以轻松地拆分、组…...
梯度爆炸与消失
梯度爆炸和梯度消失 一、概念解析 (一)梯度爆炸 定义 在深度神经网络训练的反向传播过程中,梯度爆炸是指梯度的值过大的现象。这会使模型的参数更新出现异常。 产生原因 深层网络与链式法则:深度神经网络按链式法则计算某层权重…...

关于扩散方程的解
1-D 扩散方程的形式 Cauchy齐次方程 这个解无积分无级数,很简单的形式 美其名曰:基本解。 把基本解和初值做卷积,就得到cauchy方程的解。...

如何监控Elasticsearch集群状态?
大家好,我是锋哥。今天分享关于【如何监控Elasticsearch集群状态?】面试题。希望对大家有帮助; 如何监控Elasticsearch集群状态? 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 监控 Elasticsearch 集群的状态对于确保…...

关于音频 DSP 的接口种类以及其应用场景介绍
在音频系统中,DSP(数字信号处理器)扮演着重要角色,通常会通过不同的接口与音频系统中的其他组件(如功放、扬声器、音频源等)进行连接。以汽车应用场景为例,以下是一些常见的接口类型分类及其介绍…...

arkTS:持久化储存UI状态的基本用法(PersistentStorage)
arkUI:持久化储存UI状态的基本用法(PersistentStorage) 1 主要内容说明2 例子2.1 持久化储存UI状态的基本用法(PersistentStorage)2.1.1 源码1的相关说明2.1.1.1 数据存储2.1.1.2 数据读取2.1.1.3 动态更新2.1.1.4 显示…...

css—动画
一、背景 本文章是用于解释上一篇文章中的问题,如果会动画的小伙伴就不用再次来看了,本文主要讲解一下动画的设定规则,以及如何在元素中添加动画,本文会大篇幅的讲解一下,动画属性。注意,这是css3的内容&am…...

YOLO系列论文综述(从YOLOv1到YOLOv11)【第12篇:YOLOv9——可编程梯度信息(PGI)+广义高效层聚合网络(GELAN)】
YOLOv9 1 摘要2 改进点3 网络架构 YOLO系列博文: 【第1篇:概述物体检测算法发展史、YOLO应用领域、评价指标和NMS】【第2篇:YOLO系列论文、代码和主要优缺点汇总】【第3篇:YOLOv1——YOLO的开山之作】【第4篇:YOLOv2—…...
【ETCD】etcd简单入门之基础操作基于etcdctl进行操作
这里将使用etcdctl命令行工具来进行演示, 1、使用put命令向etcd写入kv对 使用etcdctl put命令来设置键值对。put命令接受两个参数:键和值 使用方法: NAME:put - Puts the given key into the storeUSAGE:etcdctl put [options] <key&g…...

第六届国际科技创新(IAECST 2024)暨第四届物流系统与交通运输(LSTT 2024)
重要信息 会议官网:www.lstt.org 大会时间:2024年12月6-8日 大会地点:中国-广州 简介 第六届国际科技创新暨第四届物流系统与交通运输国际(LSTT 2024)将于2024年12月6-8日在广州举办,这是一个集中探讨…...

20241127 给typecho文章编辑附件 添加视频 图片预览
Typecho在写文章时,如果一次性上传太多张图片可能分不清哪张,因为附件没有略缩图,无法实时阅览图片,给文章插入图片时很不方便。 编辑admin/file-upload.php 大约十八行的位置 一个while 循环里面,这是在进行html元素更新操作,在合…...

vue3使用monaco编辑器(VSCode网页版)
vue3使用monaco编辑器(VSCode网页版) 文章说明参考文章核心代码效果展示实践说明源码下载 文章说明 一直在找网页版的编辑器,网页版的VSCode功能很强大,这个monaco就是VSCode样式的编辑器,功能很强大,可以直…...
Spark优化--开发调优、资源调优、数据倾斜调优和shuffle调优等
针对Spark优化,我们可以从多个角度进行,包括开发调优、资源调优、数据倾斜调优和shuffle调优等。以下是一些具体的优化方法: 1. 开发调优 避免创建重复的RDD:对于同一份数据,只应该创建一个RDD,避免创建多…...

Day1 生信新手笔记
生信新手笔记 生信学习第一天笔记打卡。 转录组学中: 上游分析-基于linux,包括质控、过滤、比对、定量; 下游分析-基于R语言,包括差异分析、富集分析、可视化。 1. 级别标题 一个井号加空格 就是一级标题,两个井号加…...
Python的秘密基地--[章节2]Python核心数据结构
第2章:Python核心数据结构 Python中的数据结构提供了强大的工具来存储和操作数据。理解这些数据结构是Python编程的基础。 2.1 列表(List) 2.1.1 什么是列表 列表是一种有序的可变序列,用于存储一组数据。它支持多种类型的数据…...

【Axure高保真原型】引导弹窗
今天和大家中分享引导弹窗的原型模板,载入页面后,会显示引导弹窗,适用于引导用户使用页面,点击完成后,会显示下一个引导弹窗,直至最后一个引导弹窗完成后进入首页。具体效果可以点击下方视频观看或打开下方…...
在软件开发中正确使用MySQL日期时间类型的深度解析
在日常软件开发场景中,时间信息的存储是底层且核心的需求。从金融交易的精确记账时间、用户操作的行为日志,到供应链系统的物流节点时间戳,时间数据的准确性直接决定业务逻辑的可靠性。MySQL作为主流关系型数据库,其日期时间类型的…...

基于距离变化能量开销动态调整的WSN低功耗拓扑控制开销算法matlab仿真
目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.算法仿真参数 5.算法理论概述 6.参考文献 7.完整程序 1.程序功能描述 通过动态调整节点通信的能量开销,平衡网络负载,延长WSN生命周期。具体通过建立基于距离的能量消耗模型&am…...

K8S认证|CKS题库+答案| 11. AppArmor
目录 11. AppArmor 免费获取并激活 CKA_v1.31_模拟系统 题目 开始操作: 1)、切换集群 2)、切换节点 3)、切换到 apparmor 的目录 4)、执行 apparmor 策略模块 5)、修改 pod 文件 6)、…...

2025年能源电力系统与流体力学国际会议 (EPSFD 2025)
2025年能源电力系统与流体力学国际会议(EPSFD 2025)将于本年度在美丽的杭州盛大召开。作为全球能源、电力系统以及流体力学领域的顶级盛会,EPSFD 2025旨在为来自世界各地的科学家、工程师和研究人员提供一个展示最新研究成果、分享实践经验及…...

家政维修平台实战20:权限设计
目录 1 获取工人信息2 搭建工人入口3 权限判断总结 目前我们已经搭建好了基础的用户体系,主要是分成几个表,用户表我们是记录用户的基础信息,包括手机、昵称、头像。而工人和员工各有各的表。那么就有一个问题,不同的角色…...
sqlserver 根据指定字符 解析拼接字符串
DECLARE LotNo NVARCHAR(50)A,B,C DECLARE xml XML ( SELECT <x> REPLACE(LotNo, ,, </x><x>) </x> ) DECLARE ErrorCode NVARCHAR(50) -- 提取 XML 中的值 SELECT value x.value(., VARCHAR(MAX))…...
【RockeMQ】第2节|RocketMQ快速实战以及核⼼概念详解(二)
升级Dledger高可用集群 一、主从架构的不足与Dledger的定位 主从架构缺陷 数据备份依赖Slave节点,但无自动故障转移能力,Master宕机后需人工切换,期间消息可能无法读取。Slave仅存储数据,无法主动升级为Master响应请求ÿ…...

selenium学习实战【Python爬虫】
selenium学习实战【Python爬虫】 文章目录 selenium学习实战【Python爬虫】一、声明二、学习目标三、安装依赖3.1 安装selenium库3.2 安装浏览器驱动3.2.1 查看Edge版本3.2.2 驱动安装 四、代码讲解4.1 配置浏览器4.2 加载更多4.3 寻找内容4.4 完整代码 五、报告文件爬取5.1 提…...

如何理解 IP 数据报中的 TTL?
目录 前言理解 前言 面试灵魂一问:说说对 IP 数据报中 TTL 的理解?我们都知道,IP 数据报由首部和数据两部分组成,首部又分为两部分:固定部分和可变部分,共占 20 字节,而即将讨论的 TTL 就位于首…...