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

Java线程池提交任务流程底层源码与源码解析


前言

嘿,各位技术爱好者们,今天咱们来聊聊Java线程池提交任务的底层源码与源码解析。作为一个资深的Java开发者,我相信你一定对线程池并不陌生。线程池作为并发编程中的一大利器,其重要性不言而喻。今天,我将以对话的方式,带你一步步深入线程池的奥秘,从概述到功能点,再到背景和业务点,最后到底层原理和示例,让你对线程池有一个全新的认识。


一、概述

:你好,今天咱们来聊聊Java线程池吧。

:好呀,线程池确实是个好东西,能显著提高系统的性能和资源利用率。

:没错,线程池通过预先创建一定数量的线程,并将这些线程放入一个容器中,来管理和复用线程。当任务提交时,线程池会从容器中选择一个空闲的线程来执行任务,避免了频繁创建和销毁线程的开销。

:那线程池主要用在哪些场景呢?

:线程池的应用场景非常广泛,比如Web服务器处理客户端请求、并发编程管理并发任务、异步任务处理、定时任务调度以及后台线程处理等。


二、功能点

:线程池的功能点有哪些呢?

:线程池的功能点主要包括以下几个方面:

  1. 降低资源消耗:通过复用线程,避免频繁创建和销毁线程的开销。
  2. 提高响应速度:当任务到达时,可以立即从线程池中获取线程执行任务,无需等待线程创建。
  3. 提高线程的可管理性:线程池可以统一管理线程的生命周期,方便进行调优和监控。
  4. 控制并发度:通过限制线程池中的线程数量,避免过多的线程竞争资源导致性能下降。

:这些功能点确实非常实用,那线程池是如何实现这些功能的呢?

:这就涉及到线程池的底层原理了,我们接下来详细聊聊。


三、背景

:在深入底层原理之前,我们先来聊聊线程池的背景吧。

:好的,在传统的多线程编程中,每次需要执行任务时都会创建一个新的线程,任务执行完毕后再销毁该线程。这种方式存在一些问题,比如频繁创建和销毁线程会带来较大的开销,线程数量的不可控会导致系统资源的浪费和性能下降。

:确实,这些问题在多线程编程中非常常见。那线程池是如何解决这些问题的呢?

:线程池通过预先创建一定数量的线程,并将这些线程放入一个容器中,来管理和复用线程。当任务提交时,线程池会从容器中选择一个空闲的线程来执行任务,避免了频繁创建和销毁线程的开销。同时,线程池还可以根据系统的负载情况动态调整线程的数量,以适应不同的负载需求。


四、业务点

:在实际业务开发中,我们如何使用线程池呢?

:在实际业务开发中,我们通常会根据任务的特性和线程池的负载情况选择适当的线程池类型。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();}
}

:这个示例展示了如何使用自定义的线程工厂和拒绝策略来创建线程池。通过自定义线程工厂,我们可以给每个线程设置更有意义的名字;通过自定义拒绝策略,我们可以定义当任务无法被线程池执行时的处理方式。

:没错,这个示例非常实用。在实际开发中,我们经常会需要根据业务需求来自定义线程工厂和拒绝策略。


七、优缺点

:那使用线程池有哪些优缺点呢?

:使用线程池的优缺点主要有以下几个方面:

优点

  1. 降低资源消耗:通过复用线程,避免频繁创建和销毁线程的开销。
  2. 提高响应速度:当任务到达时,可以立即从线程池中获取线程执行任务,无需等待线程创建。
  3. 提高线程的可管理性:线程池可以统一管理线程的生命周期,方便进行调优和监控。
  4. 控制并发度:通过限制线程池中的线程数量,避免过多的线程竞争资源导致性能下降。

缺点

  1. 增加系统复杂性:使用线程池会增加系统的复杂性,需要合理配置线程池的参数,并进行调优和监控。
  2. 可能引发死锁:如果任务之间存在依赖关系,并且没有正确处理,可能会引发死锁问题。
  3. 资源限制:线程池中的线程数量是有限的,如果任务数量过多,可能会导致任务堆积,影响系统的响应速度。

:了解了这些优缺点后,我们就可以更加合理地使用线程池了。


八、总结

:今天咱们聊了这么多关于线程池的内容,你有什么感想吗?

:我觉得线程池确实是一个非常强大的工具,能够显著提高系统的性能和资源利用率。但是,在使用线程池时也需要注意合理配置参数,并进行调优和监控,以避免潜在的问题。

:没错,线程池虽然强大,但也需要我们谨慎使用。好了,今天的聊天就到这里吧。如果你对线程池还有其他问题或者想深入了解某个方面,随时都可以来找我哦。

:好的,谢谢你今天的分享!


后记

希望通过今天的对话,你对Java线程池提交任务的底层源码与源码解析有了更深入的了解。线程池作为并发编程中的一大利器,其重要性不言而喻。在实际开发中,我们需要根据业务需求合理选择线程池类型,并合理配置参数,以充分发挥线程池的优势。同时,我们也需要关注线程池的调优和监控,以确保系统的稳定性和性能。

相关文章:

Java线程池提交任务流程底层源码与源码解析

前言 嘿&#xff0c;各位技术爱好者们&#xff0c;今天咱们来聊聊Java线程池提交任务的底层源码与源码解析。作为一个资深的Java开发者&#xff0c;我相信你一定对线程池并不陌生。线程池作为并发编程中的一大利器&#xff0c;其重要性不言而喻。今天&#xff0c;我将以对话的…...

新型大语言模型的预训练与后训练范式,Meta的Llama 3.1语言模型

前言&#xff1a;大型语言模型&#xff08;LLMs&#xff09;的发展历程可以说是非常长&#xff0c;从早期的GPT模型一路走到了今天这些复杂的、公开权重的大型语言模型。最初&#xff0c;LLM的训练过程只关注预训练&#xff0c;但后来逐步扩展到了包括预训练和后训练在内的完整…...

硬菜3道+馒头

硬菜3道 1、可乐鸡翅 》鸡翅滑刀酱油耗油胡椒粉盐》 搅拌腌制3-5分钟 》油锅&#xff0c;直到2面煎黄 》倒入可乐&#xff0c;到大火收汁&#xff0c;出锅 2、洋葱牛肉 》冻牛肉切薄酱油耗油胡椒粉盐 》手指摇匀 》加入生粉水&#xff0c;继续摇匀》直到粘稠 》油锅牛肉炒半熟&…...

YOLO系列论文综述(从YOLOv1到YOLOv11)【第14篇:YOLOv11——在速度和准确性方面具有无与伦比的性能】

YOLOv11 1 摘要2 改进点3 模型性能4 模型架构 YOLO系列博文&#xff1a; 【第1篇&#xff1a;概述物体检测算法发展史、YOLO应用领域、评价指标和NMS】【第2篇&#xff1a;YOLO系列论文、代码和主要优缺点汇总】【第3篇&#xff1a;YOLOv1——YOLO的开山之作】【第4篇&#xff…...

【Spring】聊聊@EventListener注解原理

1.一个Demo出发 在平时的开发中&#xff0c;其实编写同步线程代码是比较容易的&#xff0c;但是如何将一些操作和另外一些操作进行解除耦合&#xff0c;而事件方式 是一种很好的解耦合方式&#xff0c;比如当一个用户注销一个APP之后&#xff0c;需要发送一些短信 让他引流回来…...

LangChain——HTML文本分割 多种文本分割

Text Splitters 文本分割器 加载文档后&#xff0c;您通常会想要对其进行转换以更好地适合您的应用程序。最简单的例子是&#xff0c;您可能希望将长文档分割成更小的块&#xff0c;以适合模型的上下文窗口。 LangChain 有许多内置的文档转换器&#xff0c;可以轻松地拆分、组…...

梯度爆炸与消失

梯度爆炸和梯度消失 一、概念解析 &#xff08;一&#xff09;梯度爆炸 定义 在深度神经网络训练的反向传播过程中&#xff0c;梯度爆炸是指梯度的值过大的现象。这会使模型的参数更新出现异常。 产生原因 深层网络与链式法则&#xff1a;深度神经网络按链式法则计算某层权重…...

关于扩散方程的解

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

如何监控Elasticsearch集群状态?

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

关于音频 DSP 的接口种类以及其应用场景介绍

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

arkTS:持久化储存UI状态的基本用法(PersistentStorage)

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

css—动画

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

YOLO系列论文综述(从YOLOv1到YOLOv11)【第12篇:YOLOv9——可编程梯度信息(PGI)+广义高效层聚合网络(GELAN)】

YOLOv9 1 摘要2 改进点3 网络架构 YOLO系列博文&#xff1a; 【第1篇&#xff1a;概述物体检测算法发展史、YOLO应用领域、评价指标和NMS】【第2篇&#xff1a;YOLO系列论文、代码和主要优缺点汇总】【第3篇&#xff1a;YOLOv1——YOLO的开山之作】【第4篇&#xff1a;YOLOv2—…...

【ETCD】etcd简单入门之基础操作基于etcdctl进行操作

这里将使用etcdctl命令行工具来进行演示&#xff0c; 1、使用put命令向etcd写入kv对 使用etcdctl put命令来设置键值对。put命令接受两个参数&#xff1a;键和值 使用方法&#xff1a; NAME:put - Puts the given key into the storeUSAGE:etcdctl put [options] <key&g…...

第六届国际科技创新(IAECST 2024)暨第四届物流系统与交通运输(LSTT 2024)

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

20241127 给typecho文章编辑附件 添加视频 图片预览

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

vue3使用monaco编辑器(VSCode网页版)

vue3使用monaco编辑器&#xff08;VSCode网页版&#xff09; 文章说明参考文章核心代码效果展示实践说明源码下载 文章说明 一直在找网页版的编辑器&#xff0c;网页版的VSCode功能很强大&#xff0c;这个monaco就是VSCode样式的编辑器&#xff0c;功能很强大&#xff0c;可以直…...

Spark优化--开发调优、资源调优、数据倾斜调优和shuffle调优等

针对Spark优化&#xff0c;我们可以从多个角度进行&#xff0c;包括开发调优、资源调优、数据倾斜调优和shuffle调优等。以下是一些具体的优化方法&#xff1a; 1. 开发调优 避免创建重复的RDD&#xff1a;对于同一份数据&#xff0c;只应该创建一个RDD&#xff0c;避免创建多…...

Day1 生信新手笔记

生信新手笔记 生信学习第一天笔记打卡。 转录组学中&#xff1a; 上游分析-基于linux&#xff0c;包括质控、过滤、比对、定量&#xff1b; 下游分析-基于R语言&#xff0c;包括差异分析、富集分析、可视化。 1. 级别标题 一个井号加空格 就是一级标题&#xff0c;两个井号加…...

Python的秘密基地--[章节2]Python核心数据结构

第2章&#xff1a;Python核心数据结构 Python中的数据结构提供了强大的工具来存储和操作数据。理解这些数据结构是Python编程的基础。 2.1 列表&#xff08;List&#xff09; 2.1.1 什么是列表 列表是一种有序的可变序列&#xff0c;用于存储一组数据。它支持多种类型的数据…...

【Electron学习笔记(三)】Electron的主进程和渲染进程

Electron的主进程和渲染进程 Electron的主进程和渲染进程前言正文1、主进程2、渲染进程3、Preload 脚本3.1 在项目目录下创建 preload.js 文件3.2 在 main.js 文件下创建路径变量并将 preload.js 定义为桥梁3.3 在 preload.js 文件下使用 electron 提供的contextBridge 模块3.4…...

[免费]SpringBoot+Vue景区订票(购票)系统【论文+源码+SQL脚本】

大家好&#xff0c;我是java1234_小锋老师&#xff0c;看到一个不错的SpringBootVue大景区订票(购票)系统&#xff0c;分享下哈。 项目视频演示 【免费】SpringBootVue景区订票(购票)系统 Java毕业设计_哔哩哔哩_bilibili 项目介绍 现代经济快节奏发展以及不断完善升级的信息…...

idea_工程与模块管理

module相关操作 项目结构新建module移除模块删除模块导入模块 项目结构 层级关系 project(工程) - module(模块) - package(包) - class(类) 在 IntelliJ IDEA 中Project是最顶级的结构单元 &#xff0c;然后就是Module。目前&#xff0c;主流的大型项目结构基本都是多Module…...

A02、Java 设计模式优化

1、单例模式 1.1、什么是单例模式 它的核心在于&#xff0c;单例模式可以保证一个类仅创建一个实例&#xff0c;并提供一个访问它的全局访问点。该模式有三个基本要点&#xff1a;一是这个类只能有一个实例&#xff1b;二是它必须自行创建这个实例&#xff1b;三是它必须自行向…...

jdk8没有Buffer.put()

在Java中&#xff0c;Buffer是一个抽象类&#xff0c;它定义了缓冲区的通用行为。不过&#xff0c;Buffer本身并没有直接提供put()方法。put()方法是在Buffer的子类中定义的&#xff0c;比如ByteBuffer、CharBuffer、ShortBuffer、IntBuffer、LongBuffer、FloatBuffer和DoubleB…...

Artec Leo:航海设备维护的便携式3D扫描利器【沪敖3D】

挑战&#xff1a;海军服务提供商USP Maritime需要CAD数据来执行维修和改装任务&#xff0c;特别是在偏远地区的任务&#xff0c;以及原始设计丢失的情况下。 解决方案&#xff1a;Artec Leo, Artec Studio, Autodesk Inventor 效果&#xff1a;高精度船舶组件和船坞机械模型&…...

HCIA笔记6--路由基础

0. 概念 自治系统&#xff1a;一个统一管理的大型网络&#xff0c;由路由器组成的集合。 路由器隔离广播域&#xff0c;交换机隔离冲突域。 1.路由器工作原理 路由器根据路由表进行转发数据包&#xff1b; 路由表中没有路由&#xff0c;直接丢弃该数据包路由表中只有一条路…...

说说Elasticsearch拼写纠错是如何实现的?

大家好&#xff0c;我是锋哥。今天分享关于【说说Elasticsearch拼写纠错是如何实现的&#xff1f;】面试题。希望对大家有帮助&#xff1b; 说说Elasticsearch拼写纠错是如何实现的&#xff1f; 1000道 互联网大厂Java工程师 精选面试题-Java资源分享网 在 Elasticsearch 中&…...

Ubuntu20.04运行R-VIO2

目录 1.环境配置2.构建项目3. 运行 VIO 模式4.结果图 1.环境配置 CMakeLists.txt中 C 使用 14、opencv使用4 2.构建项目 克隆代码库&#xff1a; 在终端中执行以下命令克隆项目&#xff1a;git clone https://github.com/rpng/R-VIO2.git编译项目&#xff1a; 使用 catkin_m…...

【软件项目测试文档大全】软件测试方案,验收测试计划,验收测试报告,测试用例,集成测试,测试规程和指南,等保测试(Word原件)

1. 引言 1.1. 编写目的 1.2. 项目背景 1.3. 读者对象 1.4. 参考资料 1.5. 术语与缩略语 2. 测试策略 2.1. 测试完成标准 2.2. 测试类型 2.2.1. 功能测试 2.2.2. 性能测试 2.2.3. 安全性与访问控制测试 2.3. 测试工具 3. 测试技术 4. 测试资源 4.1. 人员安排 4.…...