java线程间的通信 - join 和 ThreadLocal

你好,我是 shengjk1,多年大厂经验,努力构建 通俗易懂的、好玩的编程语言教程。 欢迎关注!你会有如下收益:

  1. 了解大厂经验
  2. 拥有和大厂相匹配的技术等

希望看什么,评论或者私信告诉我!

文章目录

  • 一、前言
  • 二、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;}
}
  1. 等待线程终止join()方法是用于让当前线程等待调用该方法的线程执行完毕。主调用线程会等待被调用线程的终止。具体来说,调用join(millis)方法会使当前线程最多等待millis毫秒,直到被调用线程结束,设定超时为0表示永久等待,而不是等待当前线程自己终止。
  2. 实现机制join()方法的实现通常会使用this.wait()方法,顺序地调用this.wait(),并检查this.isAlive()条件,以等待被调用线程的终止。当被调用线程终止时,会调用notifyAll()方法来唤醒正在等待的线程,让其继续执行。
  3. 虽然源代码中无法找到join()方法内部的notifyAll()调用,但可以肯定的是,Java的多线程机制会确保在目标线程执行结束时,等待的线程能够被正确唤醒。这种机制是由Java运行时环境在底层实现的

2.1.4 join 的使用场景

join() 方法是用于让一个线程等待另一个线程完成的方法。在Java中,join() 方法通常用于以下应用场景:

  1. 等待线程完成后再执行后续操作:当一个线程需要等待另一个线程执行完成后才能继续执行,可以使用 join() 方法。这在需要线程间协作的情况下很有用。
  2. 多个线程按顺序执行:如果有多个线程按照一定的顺序来执行,可以使用 join() 方法使得后续的线程等待前一个线程完成之后再执行。
  3. 线程任务协调:当一个线程需要等待其他一组线程都完成后才能继续执行时,在这组线程中每个线程可以在执行完自己的任务后调用join()方法,主线程会等待所有这些线程执行完毕。
  4. 实现线程间的数据交换:通过join()方法,一个线程可以等待另一个线程计算出结果或者产生数据,从而实现多个线程间的数据交换。
  5. 任务分解:在复杂的任务分解中,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");}
}

在这个例子中,主线程会等待thread1thread2 完成后才会继续执行。这种方式可以用于确保线程间的操作顺序性以及线程完成后的后续处理。

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类的设计。

  1. 每个线程都有自己的ThreadLocalMap: 在Java中,每个线程都维护着一个ThreadLocalMap对象,其中存储了线程本地变量的键值对。这个ThreadLocalMap在Thread类中以ThreadLocal.ThreadLocalMap类型的成员变量存在。

  2. ThreadLocal作为 ThreadLocalMap 键: 当一个ThreadLocal对象被设置为线程的局部变量时,它实际上是作为ThreadLocalMap的键,而对应的值则是线程特定的变量。

  3. 支持多个ThreadLocal变量: 每个线程可以同时持有多个ThreadLocal对象,每个ThreadLocal对象对应一个特定的线程局部变量。

  4. ThreadLocalMap的查找和存储机制: 当线程需要获取ThreadLocal变量时,会先访问自己的ThreadLocalMap,根据ThreadLocal对象找到对应的值。如果没有找到,会创建一个新的Entry并存储到ThreadLocalMap中。

通过这种设计,ThreadLocal实现了线程封闭性和线程间变量隔离,为多线程环境下共享变量带来了一种简洁、安全的解决方案。

2.2.3 ThreadLocal 的使用场景

ThreadLocal 是一个线程本地变量工具类,它提供了线程级别的数据隔离,每个线程都可以拥有自己独立的变量副本。ThreadLocal 的使用场景包括但不限于:

  1. 保存线程相关的上下文信息:在多线程环境中,有些信息是针对每个线程独立存在的,比如用户身份信息、数据库连接、请求参数等。ThreadLocal 可以用于保存这些线程相关的上下文信息,避免在线程之间相互干扰。
  2. 提升性能:在某些情况下,对于频繁访问的对象,可以将其放入 ThreadLocal 中以减少方法参数传递和数据共享的开销,从而提升性能。
  3. 跟踪日志:可以利用 ThreadLocal 在日志中添加线程标识符,用于追踪不同线程产生的日志信息,方便日志分析和调试。
  4. 缓存数据:在某些情况下,需要对一些数据进行缓存,而这些数据是与线程相关的,可以使用 ThreadLocal 存储这些线程私有的缓存数据。
  5. 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的工作原理和实际应用场景也得到了阐述,特别是在数据隔离和性能优化方面的作用。

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

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

相关文章

力扣1.两数之和

力扣1.两数之和 遍历每个元素 同时查找哈希表中数值存入哈希表 class Solution {public:vector<int> twoSum(vector<int>& nums, int target) {unordered_map<int,int> cnt;for(int j0;;j){auto it cnt.find(target - nums[j]);if(it ! cnt.end()) r…

27、架构-技术方法论-向微服务迈进

微服务需要的条件 在决定采用微服务架构之前&#xff0c;需要明确其前提条件。微服务架构不仅仅是技术上的变革&#xff0c;更涉及组织结构和团队文化的调整。以下是微服务需要的几个关键条件&#xff1a; 1. 组织结构 微服务的成功实施依赖于组织结构的支持。根据康威定律&…

deepl翻译的PDF文档保护密码解除

1、首先将后缀名(.docx)修改为压缩包格式(.zip)。 2、修改解密word加密.py里zip的位置&#xff0c;和新生成的zip的位置和名称 import zipfile import xml.etree.ElementTree as ET import os import shutil# 定义文件路径 zip_file_path rC:\Users\Administrator\Desktop\新…

React的生命周期函数详解

import React,{Component} from "react";import SonApp from ./sonAppclass App extends Component{state{hobby:爱吃很多好吃的}// 是否要更新数据&#xff0c;这里返回true才会更新数据shouldComponentUpdate(nextProps,nextState){console.log("app.js第一步…

【计算机视觉】人脸算法之图像处理基础知识(六)

图像直方图 图像直方图是描述图像中像素强度分布的一种统计图表&#xff0c;它是图像处理和计算机视觉领域中一个非常基础且重要的概念。图像直方图通常用于分析图像的亮度、对比度特性&#xff0c;以及在图像增强、阈值分割、特征提取等多种图像处理任务。 import cv2 impor…

【C++】二叉搜索树|Key模型|key_value模型|基本操作

目录 ​编辑 二叉搜索树的定义&#xff0c;创建&#xff08;Key模型&#xff09; 定义 创建 基本操作 插入 查找 删除 Key模型和Key_Value模型 二叉搜索树&#xff08;Key_Value模型&#xff09; 定义 创建 基本操作 插入 应用 二叉搜索树的定义&#xff0c;创建&…

第二十九篇——交叉验证:电信诈骗为什么能成功?

目录 一、背景介绍二、思路&方案三、过程1.思维导图2.文章中经典的句子理解3.学习之后对于投资市场的理解4.通过这篇文章结合我知道的东西我能想到什么&#xff1f; 四、总结五、升华 一、背景介绍 具体的应用中&#xff0c;让我理解了交叉验证的重要意义&#xff0c;他也…

【Altium】查找PCB上未连接的网络

【更多软件使用问题请点击亿道电子官方网站】 1、文档目标&#xff1a; PCB设计后期检查中找出没有连接的网络 应用场景&#xff1a;PCB设计后期&#xff0c;需要检查是否所有网络都已连接布线。虽然未连接的网络会有飞线显示&#xff0c;但是由于布线后期整板布线密度较高&…

【加密与解密】【05】数据加密知识体系

常用加密算法 包括加密算法的分类&#xff0c;加密算法的作用&#xff0c;加密算法的优缺点&#xff0c;加密算法应用场景 加密算法实践 包括Java加密套件使用方式&#xff0c;BouncyCastle的CommonsCodec的使用 常见概念 公钥&#xff0c;私钥&#xff0c;对称秘钥&#xff…

如何优雅的删库跑路?

本文已收录于&#xff1a;https://github.com/danmuking/all-in-one&#xff08;持续更新&#xff09; 前言 哈喽&#xff0c;大家好&#xff0c;我是 DanMu。鲁迅说过&#xff1a;一个程序员成熟的标志是一次优雅是删库。&#xff08;鲁迅&#xff1a;这bi话我可没说过&#x…

LeetCode刷题之HOT100之排序链表

2024/6/24 周末两天没去实验室&#xff0c;可能跟天气有关&#xff0c;也可能跟我不想去有关。最近实在太热&#xff0c;不想出门。早上来&#xff0c;去二楼看了一下我的栀子花&#xff0c;长得很好&#xff0c;但是花苞都没了&#xff0c;只剩下唯一一颗&#xff0c;给它浇了…

vue3滚动日历选择器

倒叙日历&#xff1a; <template><div class"date-picker"><div class"column" wheel"onYearScroll"><div v-for"(year, index) in displayedYears" :key"index" :class"{current: year current…

Ubuntu下载QT5.8安装包-bestswinger课程

最近在看UP的QT开发课&#xff0c;真的找了巨久这个安装包&#xff0c;谁都不想在安装上花太多时间。。出一版小小教程吧&#xff5e; 首先打开qt download官网&#xff0c;5.8好像在镜像网站上没有看到&#xff0c;所以我最后还是老老实实官网了&#xff0c;而且5.8会小一点 …

Linux 运维 | 4.从零开始,文件目录特殊权限管理实践

[ 知识是人生的灯塔&#xff0c;只有不断学习&#xff0c;才能照亮前行的道路 ] 0x00 前言简述 描述&#xff1a;前一章&#xff0c;学习了Linux系统中的用户与用户组的管理&#xff0c;此章节我们将继续学习Linux系统中比较基础且重要的文件权限设置与属性管理&#xff0c;在L…

Kubernetes面试攻略:揭秘企业最爱问的几个问题-必看!下

1. 什么是存储类&#xff08;Storage Class&#xff09;&#xff1f; 答&#xff1a;存储类&#xff08;Storage Class&#xff09;是用于动态配置存储卷的资源对象&#xff0c;它定义了存储卷的类型、存储提供商&#xff08;如 AWS EBS、GCE PD&#xff09;、以及卷配置参数。…

解锁流量密码:这些软文新闻稿发布平台值得一试

随着互联网技术的飞速发展&#xff0c;软文新闻作为一种有效的品牌传播和营销推广手段&#xff0c;越来越受到企业和个人的重视。而新闻稿发布平台也已成为企业、机构和个人传递信息、展示形象的重要渠道。所以选择一个合适的软文新闻稿发布平台&#xff0c;则成为实现信息快速…

日牵物流装备受邀盛装亮相2024长三角快递物流供应链与技术装备展览会(杭州)

日牵物流装备受邀盛装亮相2024长三角快递物流供应链与技术装备展览会&#xff0c;为物流节省每一个铜板&#xff0c;3C馆A21与您相约&#xff01; 日牵物流装备始建于1995年&#xff0c;总部坐落于辽宁省大连市&#xff0c;是一家集科研开发、生产制造、销售服务于一体的现代化…

【数据结构与算法 经典例题】使用栈实现队列(图文详解)

&#x1f493; 博客主页&#xff1a;倔强的石头的CSDN主页 &#x1f4dd;Gitee主页&#xff1a;倔强的石头的gitee主页 ⏩ 文章专栏&#xff1a;《数据结构与算法 经典例题》C语言 期待您的关注 目录 ​​一、问题描述 二、前置知识 三、解题思路 原理&#xff1a; 图解&…

警惕!马斯克深度伪造视频引发的加密货币骗局泛滥

近期&#xff0c;一场以埃隆马斯克形象为幌子的深度伪造视频骗局在网络世界掀起了轩然大波&#xff0c;给广大网民带来了巨大的困扰和潜在的经济损失。 据可靠消息&#xff0c;埃隆・马斯克的深度伪造视频在 YouTube 直播平台上频繁出现&#xff0c;成为了不法分子实施加密货币…