java线程间的通信 - join 和 ThreadLocal
你好,我是 shengjk1,多年大厂经验,努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注!你会有如下收益:
- 了解大厂经验
- 拥有和大厂相匹配的技术等
希望看什么,评论或者私信告诉我!
文章目录
- 一、前言
- 二、join 和 ThreadLocal
- 2.1 join 介绍
- 2.1.1 join 作用和例子
- 2.1.2 join 其他方法
- 2.1.3 join 原理
- 2.1.4 join 的使用场景
- 2.2 ThreadLocal 介绍
- 2.2.1 ThreadLocal 作用和例子
- 2.2.2 ThreadLocal 原理
- 2.2.3 ThreadLocal 的使用场景
- 2.2.4 ThreadLocal 注意
- 三、总结
一、前言
前面的几篇文章我们分别讲解了java多线程的基础知识、java 线程之间通信-volatile 和 synchronized 以及 java线程间的通信- notify和 wait本篇是java多线程通信的最后一篇:join 和 ThreadLocal
二、join 和 ThreadLocal
2.1 join 介绍
2.1.1 join 作用和例子
如果一个线程A执行了thread.join()语句,其含义是:当前线程A等待thread线程终止之后才从thread.join() 返回。
如:
public class ThreadJoin1 {public static void main(String[] args) throws InterruptedException {Thread thread = new Thread("threadB") {@Overridepublic void run() {try {TimeUnit.SECONDS.sleep(10);} catch (InterruptedException e) {e.printStackTrace();}}};thread.start();thread.join();System.out.println("threadB执行完成,主线程继续往下执行");}
}
这里主线程会一直等待threadB执行完成,才能继续往下执行
2.1.2 join 其他方法
线程Thread除了提供join()方法之外,还提供了join(long millis)和join(long millis,int nanos)两个具备超时特性的方法。这两个超时方法表示,如果线程thread在给定的超时时间里没有终止,那么将会从该超时方法中返回
2.1.3 join 原理
//当 join 的时间为 0 时
if (millis == 0) {while (isAlive()) {wait(0);}
} else {while (isAlive()) {long delay = millis - now;if (delay <= 0) {break;}wait(delay);now = System.currentTimeMillis() - base;}
}
- 等待线程终止:
join()
方法是用于让当前线程等待调用该方法的线程执行完毕。主调用线程会等待被调用线程的终止。具体来说,调用join(millis)
方法会使当前线程最多等待millis
毫秒,直到被调用线程结束,设定超时为0表示永久等待,而不是等待当前线程自己终止。 - 实现机制:
join()
方法的实现通常会使用this.wait()
方法,顺序地调用this.wait()
,并检查this.isAlive()
条件,以等待被调用线程的终止。当被调用线程终止时,会调用notifyAll()
方法来唤醒正在等待的线程,让其继续执行。 - 虽然源代码中无法找到
join()
方法内部的notifyAll()
调用,但可以肯定的是,Java的多线程机制会确保在目标线程执行结束时,等待的线程能够被正确唤醒。这种机制是由Java运行时环境在底层实现的
2.1.4 join 的使用场景
join()
方法是用于让一个线程等待另一个线程完成的方法。在Java中,join()
方法通常用于以下应用场景:
- 等待线程完成后再执行后续操作:当一个线程需要等待另一个线程执行完成后才能继续执行,可以使用
join()
方法。这在需要线程间协作的情况下很有用。 - 多个线程按顺序执行:如果有多个线程按照一定的顺序来执行,可以使用
join()
方法使得后续的线程等待前一个线程完成之后再执行。 - 线程任务协调:当一个线程需要等待其他一组线程都完成后才能继续执行时,在这组线程中每个线程可以在执行完自己的任务后调用
join()
方法,主线程会等待所有这些线程执行完毕。 - 实现线程间的数据交换:通过
join()
方法,一个线程可以等待另一个线程计算出结果或者产生数据,从而实现多个线程间的数据交换。 - 任务分解:在复杂的任务分解中,
join()
可以用来等待各个子任务完成,然后汇总结果。 举例来说,假设我们有一个主线程,需要等待两个子线程完成后再继续执行,可以这样实现:
public class JoinExample {public static void main(String[] args) {Thread thread1 = new Thread(() -> {// 执行一些任务System.out.println("Thread 1 finished");});Thread thread2 = new Thread(() -> {// 执行一些任务System.out.println("Thread 2 finished");});thread1.start();thread2.start();try {thread1.join(); // 主线程等待thread1完成thread2.join(); // 主线程等待thread2完成} catch (InterruptedException e) {e.printStackTrace();}// 所有线程都执行完毕后继续执行主线程System.out.println("All threads have finished");}
}
在这个例子中,主线程会等待thread1
和 thread2
完成后才会继续执行。这种方式可以用于确保线程间的操作顺序性以及线程完成后的后续处理。
2.2 ThreadLocal 介绍
2.2.1 ThreadLocal 作用和例子
ThreadLocal,即线程变量( 可以理解为是线程的私有变量,每个线程一个所以不存在线程安全的问题 ),是一个以ThreadLocal对象为键、任意对象为值的存储结构。这个结构被附带在线程上,也就是说一个线程可以根据一个ThreadLocal对象查询到绑定在这个线程上的一个值。
public class MyThreadLocalExample {private static ThreadLocal<Integer> threadLocal = new ThreadLocal<>();public static void main(String[] args) {threadLocal.set(100); // 在当前线程设置值System.out.println("Main Thread Value: " + threadLocal.get());Thread thread = new Thread(() -> {threadLocal.set(200); // 在新线程设置值System.out.println("Child Thread Value: " + threadLocal.get());});thread.start();}
}
可以通过set(T)方法来设置一个值,在当前线程下再通过get()方法获取到原先设置的值
2.2.2 ThreadLocal 原理
ThreadLocal原理主要涉及Java内存模型中的“线程封闭”概念和ThreadLocal类的设计。
-
每个线程都有自己的ThreadLocalMap: 在Java中,每个线程都维护着一个ThreadLocalMap对象,其中存储了线程本地变量的键值对。这个ThreadLocalMap在Thread类中以ThreadLocal.ThreadLocalMap类型的成员变量存在。
-
ThreadLocal作为 ThreadLocalMap 键: 当一个ThreadLocal对象被设置为线程的局部变量时,它实际上是作为ThreadLocalMap的键,而对应的值则是线程特定的变量。
-
支持多个ThreadLocal变量: 每个线程可以同时持有多个ThreadLocal对象,每个ThreadLocal对象对应一个特定的线程局部变量。
-
ThreadLocalMap的查找和存储机制: 当线程需要获取ThreadLocal变量时,会先访问自己的ThreadLocalMap,根据ThreadLocal对象找到对应的值。如果没有找到,会创建一个新的Entry并存储到ThreadLocalMap中。
通过这种设计,ThreadLocal实现了线程封闭性和线程间变量隔离,为多线程环境下共享变量带来了一种简洁、安全的解决方案。
2.2.3 ThreadLocal 的使用场景
ThreadLocal 是一个线程本地变量工具类,它提供了线程级别的数据隔离,每个线程都可以拥有自己独立的变量副本。ThreadLocal 的使用场景包括但不限于:
- 保存线程相关的上下文信息:在多线程环境中,有些信息是针对每个线程独立存在的,比如用户身份信息、数据库连接、请求参数等。ThreadLocal 可以用于保存这些线程相关的上下文信息,避免在线程之间相互干扰。
- 提升性能:在某些情况下,对于频繁访问的对象,可以将其放入 ThreadLocal 中以减少方法参数传递和数据共享的开销,从而提升性能。
- 跟踪日志:可以利用 ThreadLocal 在日志中添加线程标识符,用于追踪不同线程产生的日志信息,方便日志分析和调试。
- 缓存数据:在某些情况下,需要对一些数据进行缓存,而这些数据是与线程相关的,可以使用 ThreadLocal 存储这些线程私有的缓存数据。
- Web开发中的用户会话管理:在 Web 开发中,可以使用 ThreadLocal 存储用户的会话信息,确保每个用户的会话在不同请求之间得到正确管理。
如,在一个多线程的 Web 应用中,需要持续跟踪用户的登录状态:
public class UserContext {private static ThreadLocal<User> userThreadLocal = new ThreadLocal<>();public static void setUser(User user) {userThreadLocal.set(user);}public static User getUser() {return userThreadLocal.get();}public static void clear() {userThreadLocal.remove();}
}// 在某个地方设置用户信息
User currentUser = userService.getCurrentUser();
UserContext.setUser(currentUser);// 在其他地方获取用户信息
User loggedInUser = UserContext.getUser();
2.2.4 ThreadLocal 注意
ThreadLocalMap 中的 entry 继承了 WeakReference,在内存不足的时候,ThreadLocalMap 中的数据会被自动回收,所以在使用的时候要注意处理空值情况
static class Entry extends WeakReference<ThreadLocal<?>> {/** The value associated with this ThreadLocal. */Object value;Entry(ThreadLocal<?> k, Object v) {super(k);value = v;}
}
三、总结
本文详细介绍了join方法的使用方法、原理和适用场景,强调了其在多线程编程中的重要性。同时,ThreadLocal的工作原理和实际应用场景也得到了阐述,特别是在数据隔离和性能优化方面的作用。
相关文章:
java线程间的通信 - join 和 ThreadLocal
你好,我是 shengjk1,多年大厂经验,努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注!你会有如下收益: 了解大厂经验拥有和大厂相匹配的技术等 希望看什么,评论或者私信告诉我! 文章目录 一…...
差分GPS原理
双差RTK(Real-Time Kinematic)算法是基于差分全球卫星导航系统(GNSS)技术的一种高精度定位方法。它利用至少两个接收机(一个为基站,其他为移动站)接收自同一组卫星的信号来实现精确测量。双差处…...
【栈与队列】前k个高频元素
题目:给你一个整数数组 nums 和一个整数 k ,请你返回其中出现频率前 k 高的元素。你可以按 任意顺序 返回答案。 分析:首先我们需要计算数组中元素出现的频率,前几篇文章讲解了哈希表的应用,所以这里我们很容易想到用…...

B端产品竞品分析-总结版
B端竞品分析的难点 分析维度-业务逻辑复杂 B端产品与C端产品业务模型不同,B端产品主要以业务为导向,因此其业务流程与业务逻辑梳理起来也会较C端产品复杂的多,对于个人能力也有一定的要求,需要我们具备相关领域或行业专业知识。…...

刷代码随想录有感(116):动态规划——单词拆分
题干: 代码: class Solution { public:bool wordBreak(string s, vector<string>& wordDict) {unordered_set<string>set(wordDict.begin(), wordDict.end());vector<bool>dp(s.size() 1, false);dp[0] true;for(int j 0; j &…...

CSS-0_1 CSS和层叠(样式优先级、内联样式、选择器 用户代理样式)
CSS 的本质就是声明规则 ——《深入解析CSS》 文章目录 CSS层叠和优先级用户代理样式请和用户代理样式和谐相处 选择器单选择器的优先级选择器组的优先级关于选择器的其他源码顺序尽可能的选择优先级低的选择器 内联样式内联样式和JavaScript !important多个 !important 碎碎念…...

科技赋能冷链园区:可视化带来全新体验
应用图扑可视化技术,冷链园区能够更加直观地监控和管理资源,优化运作流程,提高运营效率与服务质量。...

高通安卓12-安卓系统定制2
将开机动画打包到system.img里面 在目录device->qcom下面 有lito和qssi两个文件夹 现在通过QSSI的方式创建开机动画,LITO方式是一样的 首先加入自己的开机动画,制作过程看前面的部分 打开qssi.mk文件,在文件的最后加入内容 PRODUCT_CO…...

高中数学:数列-解数列不等式问题的常用放缩技巧(重难点)
一、放缩技巧 技巧1 例题 证明:Sn<1 解: 变形 解: 由于第一种情况,我们证明了Sn<1,n≥1,是从第一项就开始放缩的。 发现,无法精确到 3 4 \frac{3}{4} 43 这时&am…...

[图解]企业应用架构模式2024新译本讲解17-活动记录1
1 00:00:01,070 --> 00:00:04,180 下一个我们要说的就是 2 00:00:04,190 --> 00:00:06,740 活动记录模式了 3 00:00:07,640 --> 00:00:11,210 同样是数据源架构模式 4 00:00:12,300 --> 00:00:18,480 里面的一个,活动记录 5 00:00:18,490 --> 00…...

[C++深入] --- malloc/free和new/delete
1 new运算符的拓展 1.1 自由存储区与堆的概念 在C++中,内存区分为5个区,分别是堆、栈、自由存储区、全局/静态存储区、常量存储区。 自由存储区是C++基于new操作符的一个抽象概念,凡是通过new操作符进行内存申请,该内存即为自由存储区。 new操作符从自由存储区(free st…...
Spcok测试代码抛异常场景
测试代码抛异常场景 class ExceptionSpec extends Specification {def validateService new ValidateService()Unrolldef "验证UserInfo"() {when: "调用校验方法"validateService.validateUser(user)then: "捕获异常并设置需要验证的异常值&qu…...

【漏洞复现】脸爱云一脸通智慧管理平台 SystemMng 管理用户信息泄露漏洞(XVE-2024-9382)
0x01 产品简介 脸爱云一脸通智慧管理平台是一套功能强大,运行稳定,操作简单方便,用户界面美观,轻松统计数据的一脸通系统。无需安装,只需在后台配置即可在浏览器登录。 功能包括:系统管理中心、人员信息管理中心、设备…...

新手如何入门Web3?
一、什么是Web3? Web3是指下一代互联网,它基于区块链技术,致力于将各种在线活动变得更加安全、透明和去中心化。Web3是一个广义的概念,涵盖了包括数字货币、去中心化应用、智能合约等在内的多个方面。它的主要特点包括去中心化、…...
React.FC`<ChildComponentProps>`解释
代码场景 ParentComponent.tsx import React, { useState } from react; import ChildComponent from ./ChildComponent;function ParentComponent() {const [childData, setChildData] useState<string>();const handleChildData (data: string) > { // 可以直接…...
2024-06-24力扣每日一题
链接: 503. 下一个更大元素 II 题意 循环数组,找出每个元素的往后最近且大于它的元素 解: 今天没试暴力啊,大概率是过不了的 思路就是先找到最大的数,最大数的结果肯定是-1,然后倒着遍历数组…...

pyhon模块以及常用的第三方模块
import my_info as info print(info.name) info.show()from my_info import * print(name) show() pyhon中包的导入 import admin.my_admin as ad # 包名.模块名 admin是包名,my_admin是模块名print(ad.name) print(ad.info())from admin import my_admin as ad # …...
shell脚本—快速修改centos网络配置
shell-文本中自行修改想要的配置 #!/bin/bash# 网卡名称 eth"eth0"# IP 地址 ipaddr"192.168.1.100"# 子网掩码 netmask"255.255.255.0"# 网关 gateway"192.168.1.1"# 写入配置文件 echo "BOOTPROTOstatic" > /etc/sysc…...

线程池概念、线程池的不同创建方式、线程池的拒绝策略
文章目录 💐线程池概念以及什么是工厂模式💐标准库中的线程池💐什么是工厂模式?💐ThreadPoolExecutor💐模拟实现线程池 💐线程池概念以及什么是工厂模式 线程的诞生是因为,频繁的创…...

示例:WPF中如何绑定ContextMenu和Menu
一、目的:开发过程中,有些模块的右键ContextMenu菜单是需要动态显示的,既是根据不同条件显示不同的菜单,很多是通过代码去生成ContextMenu的MenuItem,本文介绍通过绑定的方式去加载ContextMenu,Menu菜单栏的…...

观成科技:隐蔽隧道工具Ligolo-ng加密流量分析
1.工具介绍 Ligolo-ng是一款由go编写的高效隧道工具,该工具基于TUN接口实现其功能,利用反向TCP/TLS连接建立一条隐蔽的通信信道,支持使用Let’s Encrypt自动生成证书。Ligolo-ng的通信隐蔽性体现在其支持多种连接方式,适应复杂网…...
Linux链表操作全解析
Linux C语言链表深度解析与实战技巧 一、链表基础概念与内核链表优势1.1 为什么使用链表?1.2 Linux 内核链表与用户态链表的区别 二、内核链表结构与宏解析常用宏/函数 三、内核链表的优点四、用户态链表示例五、双向循环链表在内核中的实现优势5.1 插入效率5.2 安全…...

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

汽车生产虚拟实训中的技能提升与生产优化
在制造业蓬勃发展的大背景下,虚拟教学实训宛如一颗璀璨的新星,正发挥着不可或缺且日益凸显的关键作用,源源不断地为企业的稳健前行与创新发展注入磅礴强大的动力。就以汽车制造企业这一极具代表性的行业主体为例,汽车生产线上各类…...

React19源码系列之 事件插件系统
事件类别 事件类型 定义 文档 Event Event 接口表示在 EventTarget 上出现的事件。 Event - Web API | MDN UIEvent UIEvent 接口表示简单的用户界面事件。 UIEvent - Web API | MDN KeyboardEvent KeyboardEvent 对象描述了用户与键盘的交互。 KeyboardEvent - Web…...
解决本地部署 SmolVLM2 大语言模型运行 flash-attn 报错
出现的问题 安装 flash-attn 会一直卡在 build 那一步或者运行报错 解决办法 是因为你安装的 flash-attn 版本没有对应上,所以报错,到 https://github.com/Dao-AILab/flash-attention/releases 下载对应版本,cu、torch、cp 的版本一定要对…...
Spring Boot+Neo4j知识图谱实战:3步搭建智能关系网络!
一、引言 在数据驱动的背景下,知识图谱凭借其高效的信息组织能力,正逐步成为各行业应用的关键技术。本文聚焦 Spring Boot与Neo4j图数据库的技术结合,探讨知识图谱开发的实现细节,帮助读者掌握该技术栈在实际项目中的落地方法。 …...
Matlab | matlab常用命令总结
常用命令 一、 基础操作与环境二、 矩阵与数组操作(核心)三、 绘图与可视化四、 编程与控制流五、 符号计算 (Symbolic Math Toolbox)六、 文件与数据 I/O七、 常用函数类别重要提示这是一份 MATLAB 常用命令和功能的总结,涵盖了基础操作、矩阵运算、绘图、编程和文件处理等…...

NLP学习路线图(二十三):长短期记忆网络(LSTM)
在自然语言处理(NLP)领域,我们时刻面临着处理序列数据的核心挑战。无论是理解句子的结构、分析文本的情感,还是实现语言的翻译,都需要模型能够捕捉词语之间依时序产生的复杂依赖关系。传统的神经网络结构在处理这种序列依赖时显得力不从心,而循环神经网络(RNN) 曾被视为…...

IoT/HCIP实验-3/LiteOS操作系统内核实验(任务、内存、信号量、CMSIS..)
文章目录 概述HelloWorld 工程C/C配置编译器主配置Makefile脚本烧录器主配置运行结果程序调用栈 任务管理实验实验结果osal 系统适配层osal_task_create 其他实验实验源码内存管理实验互斥锁实验信号量实验 CMISIS接口实验还是得JlINKCMSIS 简介LiteOS->CMSIS任务间消息交互…...