Java编程基本功大揭秘 | 详解深入分析Java线程池源码和底层原理,掌握实战技巧【1】

详解深入分析Java线程池源码和底层原理

  • 文章大纲
  • 引言
    • Java线程池概念及重要性
  • `ThreadPoolExecutor`类的概述
    • `ThreadPoolExecutor`类的基本功能和作用
      • **基本功能**
      • **核心作用**
    • `ThreadPoolExecutor`主要构造函数及其参数
      • 继承关系链
      • 功能介绍
      • ThreadPoolExecutor 构造器
        • 构造器参数
          • 构造器中各个参数的含义
            • corePoolSize
            • maximumPoolSize
            • keepAliveTime
            • unit
            • workQueue
            • threadFactory
            • handler
      • 接口继承关系链
  • 总结与展望

文章大纲

在这里插入图片描述

引言

早期的编程实践中,直接使用新线程执行任务虽直观且易实现,但在高并发场景下却面临性能瓶颈。当系统需处理大量短暂并发任务时,频繁创建和销毁线程会导致巨大的开销,降低系统性能,甚至可能因资源过度消耗导致系统崩溃。为解决线程频繁创建和销毁的问题,我们需要高效复用线程的机制。

Java线程池概念及重要性

Java的线程池(Thread Pool)提供了这样的解决方案:预先创建并管理线程组,任务执行时从池中获取线程,任务完成后线程返回池中等待新任务。这种方式显著减少线程创建和销毁,大幅提升系统并发处理能力。


ThreadPoolExecutor类的概述

Java中的ThreadPoolExecutor是线程池的核心实现,提供灵活的配置和管理方法。要深入理解其工作原理和使用,可从关键方法入手,逐步探索其实现逻辑。

ThreadPoolExecutor类的基本功能和作用

在Java中,ThreadPoolExecutor是线程池框架的核心组件,它允许开发者以高度可配置和灵活的方式管理线程资源。其核心功能是为应用程序提供一个线程池,从而优化和控制线程的使用,特别是在处理大量并发任务时。

基本功能

  1. 线程管理与复用ThreadPoolExecutor管理一个线程池,当任务提交给线程池时,线程池会尝试复用已有的线程来执行任务,而不是为每个新任务都创建一个新线程。这大大减少了线程创建和销毁的开销。
  2. 任务队列:当线程池中的线程都在忙碌时,新提交的任务会被放置在一个任务队列中等待执行。ThreadPoolExecutor允许你配置这个队列的大小和类型,以适应不同的应用场景。
  3. 线程生命周期管理ThreadPoolExecutor允许你配置线程的生命周期,包括核心线程数、最大线程数、线程空闲时间等。当线程空闲超过指定时间后,多余的线程会被销毁以节省资源。
  4. 任务拒绝策略:当任务队列已满且所有线程都在忙碌时,新提交的任务将被拒绝。ThreadPoolExecutor提供了几种内置的任务拒绝策略,同时也允许你自定义拒绝策略。

核心作用

  1. 提高性能:通过复用线程,ThreadPoolExecutor显著减少了线程创建和销毁的开销,从而提高了应用程序的性能。
  2. 资源管理ThreadPoolExecutor允许你精细控制线程资源的使用,包括线程的数量、任务的排队策略等,从而更有效地管理系统的资源。
  3. 简化并发编程:使用ThreadPoolExecutor,开发者可以更加专注于业务逻辑的实现,而无需过多关注线程的管理和调度。
  4. 提供灵活的扩展性:通过调整线程池的配置参数,ThreadPoolExecutor可以适应不同规模和需求的应用程序,提供了很好的扩展性。

ThreadPoolExecutor主要构造函数及其参数

继承关系链

在这里插入图片描述

ThreadPoolExecutor 实现了 ExecutorService 接口, ExecutorService 扩展了 Executor 接口。

功能介绍

  • Executor:这是Java中执行已提交任务的对象的接口,提供了一种将任务与任务执行机制(通常是线程)解耦的方式。

  • ExecutorService:这是一个扩展了Executor接口的接口,它提供了更全面的生命周期管理(例如关闭、终止)和任务提交机制(例如execute, submit等)。ExecutorService通常用于控制和管理线程,它内部封装了一组线程,使得线程的使用更加简便和安全。

  • AbstractExecutorService:实际上,Java标准库中没有名为AbstractExecutorService的接口。可能您是想引用一个抽象类,但ExecutorService接口本身通常被具体类(如ThreadPoolExecutor)实现,而不是由抽象类来扩展。在标准库中,有一个AbstractExecutorService类的可能性很低,但如果有这样的类,它可能提供了一些ExecutorService接口的默认实现。

  • ThreadPoolExecutor:这是一个实现了ExecutorService接口的具体类,它提供了线程池的实现,允许用户配置核心线程数、最大线程数、线程空闲时间、任务队列等参数。ThreadPoolExecutor是线程池框架中最常用的实现之一,它高效地管理线程资源的复用,降低了系统的开销。

ThreadPoolExecutor 构造器

java.uitl.concurrent.ThreadPoolExecutor类是线程池中最核心的一个类,因此如果要透彻地了解Java中的线程池,必须先了解这个类。下面我们来看一下ThreadPoolExecutor类的具体实现源码。

public class ThreadPoolExecutor extends AbstractExecutorService {public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue);public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory);public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit unit,BlockingQueue<Runnable> workQueue,RejectedExecutionHandler handler);public ThreadPoolExecutor(int corePoolSize,int maximumPoolSize,long keepAliveTime,TimeUnit 	unit,BlockingQueue<Runnable> workQueue,ThreadFactory threadFactory,RejectedExecutionHandler handler);
...
}	

从上面的代码可以得知,ThreadPoolExecutor继承了AbstractExecutorService类,并提供了四个构造器,事实上,通过观察每个构造器的源码具体实现,发现前面三个构造器都是调用的第四个构造器进行的初始化工作。

构造器参数

了解如何配置线程池。这包括设置核心线程数、最大线程数、队列容量等参数。这些参数的选择将直接影响线程池的性能和稳定性。通过合理地配置这些参数,我们可以在保证系统性能的同时,也避免了资源的过度消耗。

构造器中各个参数的含义

在这里插入图片描述

corePoolSize

corePoolSize 是线程池中的一个关键参数,它决定了线程池中的核心线程数量。

在创建线程池后,初始状态下线程池内部并不包含任何线程。线程池会等待任务的到来,并根据需要创建线程来执行任务。除非显式地调用 prestartAllCoreThreads()prestartCoreThread() 方法,线程池才会预先创建核心线程。从这两个方法的名字就可以推断出,它们的目的是在未接收到任务之前就创建指定数量的线程。

在默认情况下,当第一个任务到达时,线程池会创建一个新线程来执行它。随着更多任务的到达,线程池中的线程数量会逐渐增加,直到达到 corePoolSize 所设定的数量。一旦线程池中的线程数量达到这个核心值,后续到达的任务将不再触发新线程的创建。

此时,如果还有新任务到来,线程池会将它们放入一个缓存队列中等待执行。这个队列通常是一个阻塞队列,用于存储待执行的任务。只有当队列满了,或者线程池中的线程数量低于 maximumPoolSize(最大线程池大小)时,线程池才会考虑创建额外的线程来执行任务。

注意:合理配置 corePoolSize,可以平衡线程创建和销毁的开销与任务执行的效率。如果 corePoolSize 设置得太小,可能会导致大量任务在队列中等待,从而增加任务的延迟;如果设置得太大,又可能浪费系统资源,因为不是所有线程都会同时处于忙碌状态。因此,在实际应用中,需要根据任务的特性和系统资源来合理设置这个参数。

maximumPoolSize

线程池中的maximumPoolSize参数指的是线程池能够容纳的最大线程数量。当线程池中的线程数量达到这个值时,新的任务提交到线程池时,线程池将不会再创建新的线程来处理这些任务,而是根据线程池的其他策略(如队列策略)来决定如何处理这些新任务。

keepAliveTime

线程没有任务执行时最多保持多久时间会终止。

默认情况下,只有当线程池中的线程数大于corePoolSize时,keepAliveTime才会起作用,直到线程池中的线程数不大于corePoolSize,即当线程池中的线程数大于corePoolSize时,如果一个线程空闲的时间达到keepAliveTime,则会终止,直到线程池中的线程数不超过corePoolSize。

注意:如果调用了allowCoreThreadTimeOut(boolean)方法,在线程池中的线程数不大于corePoolSize时,keepAliveTime参数也会起作用,直到线程池中的线程数为0;

unit

unit:参数keepAliveTime的时间单位,有7种取值,在TimeUnit类中有7种静态属性:
在这里插入图片描述

workQueue

一个阻塞队列,用来存储等待执行的任务,这个参数的选择也很重要,会对线程池的运行过程产生重大影响,一般来说,这里的阻塞队列有以下几种选择:
在这里插入图片描述
线程池中的阻塞队列(BlockingQueue)是线程池的一个重要组成部分,用于存储待执行的任务。当线程池中的线程数量达到corePoolSize时,新提交的任务会被放入这个队列中等待执行。阻塞队列的类型会影响线程池的行为和性能。以下是您提到的几种阻塞队列的作用和特性:

  • ArrayBlockingQueue(数组类型队列)

    • 特点:基于数组结构的有界阻塞队列。
    • 容量限制:在创建时需要指定队列的容量,一旦队列满了,新提交的任务会被拒绝。
    • 性能:由于是基于数组,它在入队和出队操作上的时间复杂度是O(1),具有较好的性能。
    • 使用场景:适用于有固定大小的任务缓存场景,当任务量比较大时,能够避免在内存中创建大量的对象。
  • LinkedBlockingQueue(链表类型队列)

    • 特点:基于链表结构的有界(但默认大小为Integer.MAX_VALUE,可视为无界)阻塞队列。
    • 容量限制:可以指定队列的容量,但如果不指定,则默认为Integer的最大值,几乎可以认为是无界的。
    • 性能:入队和出队操作的时间复杂度为O(1),但由于是链表结构,实际性能可能会略低于ArrayBlockingQueue。
    • 使用场景:适用于任务量较大,但不想或不需要限制队列大小的场景。
  • SynchronousQueue(同步单元素队列)

    • 特点:一个不存储元素的阻塞队列,也就是说它的容量为1。
    • 容量限制:只能存储一个元素,如果队列中有元素,则新提交的任务可以直接获取执行,否则需要等待其他线程执行完任务后,腾出空间才能继续。
    • 性能:入队和出队操作的时间复杂度接近O(1),但由于其特殊的特性,线程间的交互更为频繁,可能导致更高的线程调度开销。
    • 使用场景:适用于线程池中的线程数量与任务数量大致相等,且任务执行时间较短的场景。
  • PriorityBlockingQueue(具有优先级的队列)

    • 特点:一个支持优先级排序的无界阻塞队列。
    • 容量限制:默认是无界的,可以存储任意数量的任务。
    • 优先级:队列中的元素按照它们的自然排序或者通过提供的Comparator进行排序,优先级高的任务将优先被执行。
    • 性能:由于需要排序,入队和出队操作的时间复杂度可能会高于O(1)。
    • 使用场景:适用于需要按照优先级执行任务的场景,例如,某些重要或紧急的任务需要优先得到处理。

ArrayBlockingQueue和PriorityBlockingQueue使用较少,一般使用LinkedBlockingQueue和Synchronous。线程池的排队策略与BlockingQueue有关。

threadFactory

线程工厂,主要用来创建线程的工厂实现类

public interface ThreadFactory {/*** Constructs a new {@code Thread}.  Implementations may also initialize* priority, name, daemon status, {@code ThreadGroup}, etc.** @param r a runnable to be executed by new thread instance* @return constructed thread, or {@code null} if the request to*         create a thread is rejected*/Thread newThread(Runnable r);
}
handler

表示当拒绝处理任务时的策略,有以下四种取值:
在这里插入图片描述

接口继承关系链

总结与展望

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/diannao/37293.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

c语言自动售货机

C语言编写的自动售货机程序可以模拟真实自动售货机的基本功能&#xff0c;例如选择商品、显示价格、付款和找零。下面是一个简单的示例代码&#xff0c;展示了一个基本的自动售货机程序&#xff1a; #include <stdio.h>// 商品结构体 typedef struct {char name[30];int…

破解对LabVIEW的偏见

LabVIEW被广泛应用于科学研究、工程测试和自动化控制领域&#xff0c;具有专业性和高效的开发能力。尽管有人对其存在偏见&#xff0c;认为不如C语言&#xff0c;但LabVIEW的图形化编程、强大集成能力、丰富社区支持和专业功能&#xff0c;使其在许多实际应用中表现出色。通过多…

Go语言环境安装

Go下载地址 哪个能用用哪个。 https://go.dev/ https://golang.google.cn/&#xff08;Golang官网的官方镜像&#xff09; Windows 使用.msi安装包安装 下载msi文件 安装 双击运行go1.22.4.windows-amd64.msi Next 勾选I accept the terms in the License Agreement&…

收藏 | SSL证书无效的原因和解决办法

当浏览器访问一个使用SSL证书保护的网站时&#xff0c;会检查其证书的有效性。如果发现证书存在问题&#xff0c;浏览器会显示“SSL证书无效”的警告信息&#xff0c;提醒用户存在潜在的安全风险。 “SSL证书无效”的警告可能会导致用户离开站点&#xff08;并且永远不会返回&…

MySQL高级-SQL优化-小结

文章目录 1、insert 优化2、主键优化3、order by 优化4、group by 优化5、limit 优化6、count 优化7、update 优化 1、insert 优化 insert&#xff1a;批量插入、手动控制事务、主键顺序插入 大批量插入&#xff1a;load data local infile 2、主键优化 主键长度尽量短、顺序插…

系统漏洞复现与勒索病毒

知识点&#xff1a;SMB漏洞介绍、漏洞复现流程、勒索病毒攻击与防护 渗透测试相关&#xff1a; 基本概念&#xff1a; 渗透测试就是利用我们所掌握的渗透知识&#xff0c;对网站进行一步一步的渗透&#xff0c;发现其中存在的漏洞和隐藏的风险&#xff0c;然后撰写一篇测试报…

FastAPI教程I

本文参考FastAPI教程https://fastapi.tiangolo.com/zh/tutorial 第一步 import uvicorn from fastapi import FastAPIapp FastAPI()app.get("/") async def root():return {"message": "Hello World"}if __name__ __main__:uvicorn.run(&quo…

GPT-4o模型到底有多强

近年来&#xff0c;人工智能技术突飞猛进&#xff0c;在自然语言处理&#xff08;NLP&#xff09;和计算机视觉等领域取得了令人瞩目的成就。OpenAI推出的GPT-4o模型作为最新一代的语言模型&#xff0c;进一步提升了AI的能力&#xff0c;尤其在文档分析、识图生文、文生图等功能…

elementUI的搭建使用过程

Element - The worlds most popular Vue UI framework 上面是elementUI的网站,进入网站 点击右上角的组件按钮 复制这段代码到你的项目终端:npm i element-ui -S 加载完成后即可使用elementUI网站中的组件,使用它们只需要复制组件下面的代码即可

Unity UGUI 实现简单两点连线功能

实现 记录鼠标点击位置为线段起点。 posStart Input.mousePosition; 创建一个Image 作为线段。 line new GameObject("line"); rtLine line.AddComponent<RectTransform>(); rtLine.pivot new Vector2(0, 0.5f); rtLine.localScale Vector3.one; img…

Linux 进程通信

1.什么是进程通信&#xff1f; 答&#xff1a;两个或多个进程实现数据层面的交互&#xff1b;但是因为进程的独立性&#xff0c;导致进程通信的成本较高&#xff1b; 2.为什么要通信&#xff1f; 答&#xff1a;多进程之间由协同的需求&#xff0c;所以通信&#xff1b;以下…

Java常用对象的快速初始化

在Java中&#xff0c;有多种方式来快速初始化各种常用对象&#xff0c;如字符串数组&#xff08;String[]&#xff09;&#xff0c;集合列表&#xff08;List&#xff09;&#xff0c;映射表&#xff08;Map&#xff09;&#xff0c;以及集合&#xff08;Set&#xff09;。不同…

动态服务管理的艺术:Eureka在服务扩展与收缩中的策略

动态服务管理的艺术&#xff1a;Eureka在服务扩展与收缩中的策略 在微服务架构中&#xff0c;服务的动态扩展和收缩是实现高可用性和弹性的关键。Eureka&#xff0c;作为Netflix开源的服务发现框架&#xff0c;提供了一套机制来处理服务实例的动态变化。本文将深入探讨Eureka如…

在操作系统中,background通常指的是运行于后台的进程或任务

在计算机中&#xff0c;"background"一词具有多种含义&#xff0c;以下是一些主要的解释和相关信息&#xff1a; 计算机视觉中的背景&#xff08;Background&#xff09;&#xff1a; 在计算机视觉中&#xff0c;background指的是图像或视频中的背景部分&#xff0c;…

[code snippet] 生成随机大文件

[code snippet] 生成随机大文件 一个无聊的测试代码&#xff0c;因为要测试大文件的网络传输&#xff0c;就写了一个随机大文件生成脚本&#xff0c;做个备份。 基本上都是 GPT 生成的&#xff0c;哈哈。 C# 代码 namespace ConsolePlayground;internal class BigFileGenera…

IOS17闪退问题Assertion failure in void _UIGraphicsBeginImageContextWithOptions

最近项目更新到最新版本IOS17&#xff0c;发现一个以前的页面突然闪退了。原来是IOS17下&#xff0c;这个方法 UIGraphicsBeginImageContext(CGSize size) 已经被移除&#xff0c;原参数如果size为0的话&#xff0c;会出现闪退现象。 根据说明&#xff0c;上述方法已经被替换…

【shell脚本速成】python安装脚本

文章目录 案例需求应用场景解决问题脚本思路案例代码 &#x1f308;你好呀&#xff01;我是 山顶风景独好 &#x1f388;欢迎踏入我的博客世界&#xff0c;能与您在此邂逅&#xff0c;真是缘分使然&#xff01;&#x1f60a; &#x1f338;愿您在此停留的每一刻&#xff0c;都沐…

React 中 useEffect

React 中 useEffect 是副作用函数&#xff0c;副作用函数通常是处理外围系统交互的逻辑。那么 useEffect 是怎处理的呢&#xff1f;React 组件都是纯函数&#xff0c;需要将副作用的逻辑通过副作用函数抽离出去&#xff0c;也就是副作用函数是不影响函数组件的返回值的。例如&a…

vue中如何使用echarts和echarts-gl实现三维折线图

一、vue中使用三维折线图 效果图&#xff1a; 二、使用步骤 1.引入库 安装echarts 在package.json文件中添加 "dependencies": {"echarts": "^5.1.2""echarts-gl": "^1.1.1",// "echarts-gl": "^2.0.8…

5G超宽,远程诊疗带来优质就医体验

上篇&#xff08;5G与4G的区别-CSDN博客&#xff09;讲了4G与5G的区别&#xff0c;大家可以看到5G 具备高带宽、低时延的特性&#xff0c;可以广泛应用在各种物联网场景下。 今天和大家简单聊聊5G远程诊疗。 远程诊疗是一种利用信息通信技术为患者提供医疗服务的方式。它允许…