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 什么是列表 列表是一种有序的可变序列,用于存储一组数据。它支持多种类型的数据…...

19c补丁后oracle属主变化,导致不能识别磁盘组
补丁后服务器重启,数据库再次无法启动 ORA01017: invalid username/password; logon denied Oracle 19c 在打上 19.23 或以上补丁版本后,存在与用户组权限相关的问题。具体表现为,Oracle 实例的运行用户(oracle)和集…...
java调用dll出现unsatisfiedLinkError以及JNA和JNI的区别
UnsatisfiedLinkError 在对接硬件设备中,我们会遇到使用 java 调用 dll文件 的情况,此时大概率出现UnsatisfiedLinkError链接错误,原因可能有如下几种 类名错误包名错误方法名参数错误使用 JNI 协议调用,结果 dll 未实现 JNI 协…...

大数据零基础学习day1之环境准备和大数据初步理解
学习大数据会使用到多台Linux服务器。 一、环境准备 1、VMware 基于VMware构建Linux虚拟机 是大数据从业者或者IT从业者的必备技能之一也是成本低廉的方案 所以VMware虚拟机方案是必须要学习的。 (1)设置网关 打开VMware虚拟机,点击编辑…...

定时器任务——若依源码分析
分析util包下面的工具类schedule utils: ScheduleUtils 是若依中用于与 Quartz 框架交互的工具类,封装了定时任务的 创建、更新、暂停、删除等核心逻辑。 createScheduleJob createScheduleJob 用于将任务注册到 Quartz,先构建任务的 JobD…...

Python实现prophet 理论及参数优化
文章目录 Prophet理论及模型参数介绍Python代码完整实现prophet 添加外部数据进行模型优化 之前初步学习prophet的时候,写过一篇简单实现,后期随着对该模型的深入研究,本次记录涉及到prophet 的公式以及参数调优,从公式可以更直观…...

ESP32 I2S音频总线学习笔记(四): INMP441采集音频并实时播放
简介 前面两期文章我们介绍了I2S的读取和写入,一个是通过INMP441麦克风模块采集音频,一个是通过PCM5102A模块播放音频,那如果我们将两者结合起来,将麦克风采集到的音频通过PCM5102A播放,是不是就可以做一个扩音器了呢…...
C++.OpenGL (10/64)基础光照(Basic Lighting)
基础光照(Basic Lighting) 冯氏光照模型(Phong Lighting Model) #mermaid-svg-GLdskXwWINxNGHso {font-family:"trebuchet ms",verdana,arial,sans-serif;font-size:16px;fill:#333;}#mermaid-svg-GLdskXwWINxNGHso .error-icon{fill:#552222;}#mermaid-svg-GLd…...
Axios请求超时重发机制
Axios 超时重新请求实现方案 在 Axios 中实现超时重新请求可以通过以下几种方式: 1. 使用拦截器实现自动重试 import axios from axios;// 创建axios实例 const instance axios.create();// 设置超时时间 instance.defaults.timeout 5000;// 最大重试次数 cons…...
css3笔记 (1) 自用
outline: none 用于移除元素获得焦点时默认的轮廓线 broder:0 用于移除边框 font-size:0 用于设置字体不显示 list-style: none 消除<li> 标签默认样式 margin: xx auto 版心居中 width:100% 通栏 vertical-align 作用于行内元素 / 表格单元格ÿ…...

基于Java+MySQL实现(GUI)客户管理系统
客户资料管理系统的设计与实现 第一章 需求分析 1.1 需求总体介绍 本项目为了方便维护客户信息为了方便维护客户信息,对客户进行统一管理,可以把所有客户信息录入系统,进行维护和统计功能。可通过文件的方式保存相关录入数据,对…...