Java多线程技术二:线程间通信——ThreadLocal的使用

1 概述

        变量值的共享可以使用public static 的声明方式,所有的线程都是用同一个public static变量,那如果想实现每一个线程都有自己的变量该如何解决呢?JDK提供的ThreadLocal就派上用场了。

        ThreadLocal类主要的作用就是将数据放入当前线程对象中的Map里,这个Map类是Thread类的实例变量。ThreadLocal类自己不管理也不存储任何数据,它只是数据和Map之间的中介和桥梁,通过ThreadLocal将数据放入Map中,执行流程如下:

数据——>ThreadLocal——>currentThread()——>Map

        执行后每个线程中的Map就存储自己的数据,Map中的key存储的是ThreadLocal对象,value就是存储的值,说明ThreadLocal和值之间是一对一的关系,一个ThreadLocal对象只能关联一个值。每个线程中Map的值只对向前线程可见,其他线程不可以访问当前线程对象中Map的值。内存结构如下:

2 get()方法与null

        如果从未在Thread中的Map存储 ThreadLocal对象对应的值,则get()方法返回null。

public class Run1 {public static ThreadLocal t1 = new ThreadLocal();public static void main(String[] args) {if(t1.get() == null){System.out.println("从未放过值");t1.set("第一次放的值");}System.out.println(t1.get());System.out.println(t1.get());}
}

        ThreadLocal类解决的是变量在不同线程中的隔离性,也就是不同线程拥有自己的值,不同线程中的值是可以通过ThreadLocal类进行保存的。

3 ThreadLocal类存取数据流程分析

        运行测试程序:

public class Test {public static void main(String[] args) {ThreadLocal local = new ThreadLocal();local.set("value");System.out.println(local.get());}
}

        从JDK源码角度来分析一下ThreadLocal类执行存取操作的流程。

        首先看一下数据如何存入到ThreadLocal中的。

        (1)执行ThreadLocal.set("value")代码时,ThreadLocal代码如下:

public void set(T value) {//对象t就是main线程Thread t = Thread.currentThread();//从main线程中获取ThreadLocalMap ThreadLocalMap map = getMap(t);if (map != null) {//如果map不等于null,则set操作map.set(this, value);} else {//如果map等于null,则先执行创建,在执行setcreateMap(t, value);}}

        (2)ThreadLocalMap map = getMap(t); 源码如下:

ThreadLocalMap getMap(Thread t) {//参数t就是前面传入的main线程return t.threadLocals;//返回main线程中threadLocals变量对应的ThreadLocalMap对象}

        对象threadLocals数据类型就是ThreadLocal.ThreadLocalMap,变量threadLocals是Thread类中的实例变量。

        (3)取得Thread中的ThreadLocal.ThreadLocalMap后,根据map对象值是不是null来决定是否对其执行set或create and set操作。

        (4)createMap()方法的功能是创建一个新的ThreadLocalMap,并在这个新的ThreadLocalMap里存储数据,ThreadLocalMap中的key就是当前ThreadLocal对象,值就是传入的value,createMap()方法的源码如下:

void createMap(Thread t, T firstValue) {t.threadLocals = new ThreadLocalMap(this, firstValue);}

        在实例化ThreadLocalMap的时候,向构造方法传入thi和firstValue,其中,this就是当前ThreadLocal对象,firstValue就是调用ThreadLocal对象时set()方法传入的参数值。

new ThreadLocalMap(this, firstValue)的源码是:

ThreadLocalMap(ThreadLocal<?> firstKey, Object firstValue) {table = new Entry[INITIAL_CAPACITY];int i = firstKey.threadLocalHashCode & (INITIAL_CAPACITY - 1);table[i] = new Entry(firstKey, firstValue);size = 1;setThreshold(INITIAL_CAPACITY);}

        在源码中可以发现,将ThreadLocal对象与firstValue封装进Entry对象中,并放入table[]数组。

        再看一下get()的执行流程。

        (1)当执行 local.get() 代码时,ThreadLocal.get()源码如下:

    public T get() {Thread t = Thread.currentThread();//t 就是main线程ThreadLocalMap map = getMap(t);//从main线程中获取ThreadLocalMap if (map != null) {ThreadLocalMap.Entry e = map.getEntry(this);//如果map不等于null,获取Entry对象if (e != null) {@SuppressWarnings("unchecked")T result = (T)e.value;return result;}}return setInitialValue();}

        总结:上面的几个步骤就是set和get的执行流程,比较麻烦。为什么不能直接向Thread类中的ThreadLocalMap对象存取数据呢?这是无法实现的,原因参考下面代码:

ThreadLocal.ThreadLocalMap threadLocals = null;

        变量 threadLocals 默认是包级访问,所以不能从外部直接访问该变量,也没有对应的get和set方法,只有用同一个包中的类可以访问threadLocals变量,而ThreadLocal和Thread恰好在同一个包中(都在java.lang包下)。

4 验证线程变量的隔离性

        本节将实现通过使用ThreadLocal在每个线程中存储自己的私有数据。

public class Tools {public static ThreadLocal t1 = new ThreadLocal();
}
public class MyThreadA extends Thread{@Overridepublic void run(){try {for (int i = 0; i < 10; i++) {Tools.t1.set("A: " +(i+1) );System.out.println("A get:" + Tools.t1.get());int sleepValue = (int)(Math.random() * 10000);Thread.sleep(sleepValue);}}catch (InterruptedException e){e.printStackTrace();}}
}
public class MyThreadB extends Thread{@Overridepublic void run(){try {for (int i = 0; i < 10; i++) {Tools.t1.set("B: " +(i+1) );System.out.println("B get:" + Tools.t1.get());int sleepValue = (int)(Math.random() * 10000);Thread.sleep(sleepValue);}}catch (InterruptedException e){e.printStackTrace();}}
}
public class Run1 {public static void main(String[] args) throws InterruptedException {MyThreadA a = new MyThreadA();MyThreadB b = new MyThreadB();a.start();b.start();for (int i = 0; i < 10; i++) {Tools.t1.set("main: " +(i+1) );System.out.println("main get:" + Tools.t1.get());int sleepValue = (int)(Math.random() * 10000);Thread.sleep(sleepValue);}}
}

        控制台输出的结果表示通过ThreadLocal向每个线程存储自己的私有数据,虽然3个线程都向t1存放数据,但是每个线程仅能取出自己的数据,不能取出其他线程存放的数据 。

5 解决get()返回null的问题

        新建ThreadLocalExt.java,继承ThreadLocal类,并覆盖 initialValue() 方法

public class ThreadLocalExt extends ThreadLocal{@Overrideprotected Object initialValue(){return "我是默认值,第一次get不再为null";}
}

         覆盖initialValue()方法具有初始值,因为ThreadLocal.java中的initialValue方法默认返回值就是null,所以要在子类中重写。源码如下:

protected T initialValue() {return null;}
public class Run1 {public static ThreadLocalExt t1 = new ThreadLocalExt();public static void main(String[] args) {if(t1.get() == null){System.out.println("没有存放过值");t1.set("第一次存放值");}System.out.println(t1.get());System.out.println(t1.get());}

6 验证重写initialValue()方法的隔离性

public class Tools {public  static ThreadLocalExt t1 = new ThreadLocalExt();
}

public class ThreadLocalExt extends ThreadLocal{@Overrideprotected Object initialValue() {return new Date().getTime();}
}
public class ThreadA extends Thread{@Overridepublic void run(){try {for (int i = 0; i < 10; i++) {System.out.println("在线程ThreadA中取值 = " + Tools.t1.get());Thread.sleep(100);}}catch (InterruptedException e){e.printStackTrace();}}
}
public class Run1 {public static void main(String[] args) {try {for (int i = 0; i < 10; i++) {System.out.println("在Main线程中取值 = " + Tools.t1.get());}Thread.sleep(2000);ThreadA threadA = new ThreadA();threadA.start();}catch (InterruptedException e){e.printStackTrace();}}
}

7 使用remove()方法的必要性

        ThreadLocalMap中的静态内置类Entry是弱引用类型,源码如下:

static class Entry extends WeakReference<ThreadLocal<?>> {/** The value associated with this ThreadLocal. */Object value;Entry(ThreadLocal<?> k, Object v) {super(k);value = v;}}

         弱引用的特点是,只要垃圾回收器扫描时发现弱引用的对象,就不管内存是否足够,都会回收弱引用的对象。也就是只要执行gc操作,ThreadLocal对象就会立即销毁,代表key的值ThreadLocal对象会随着gc操作而销毁,释放内存空间,但value值却不会随着gc操作而销毁,这会出现内存溢出。如果对象数量过多,对于ThreadLocalMap类中不用的数据使用ThreadLocal类的remove方法进行清除,实现业务对象的垃圾回收,释放内存。

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

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

相关文章

web前端开发HTML/css用户登录界面

代码&#xff1a; <!DOCTYPE html PUBLIC "-//W3C//DTD XHTML 1.0 Transitional//EN" "http://www.w3.org/TR/xhtml1/DTD/xhtml1-transitional.dtd"> <html xmlns"http://www.w3.org/1999/xhtml"> <head> <meta http-equi…

神经网络常用归一化和正则化方法解析(一)

&#x1f380;个人主页&#xff1a; https://zhangxiaoshu.blog.csdn.net &#x1f4e2;欢迎大家&#xff1a;关注&#x1f50d;点赞&#x1f44d;评论&#x1f4dd;收藏⭐️&#xff0c;如有错误敬请指正! &#x1f495;未来很长&#xff0c;值得我们全力奔赴更美好的生活&…

Win环境中安装Jenkins指南

目录 安装Java环境 下载并安装Jenkins Jenkins版本 启动Jenkins 如何删除Jenkins 安装Java环境 访问 Oracle官方网站 下载并安装JDK 安装完成后&#xff0c;设置系统环境变量 JAVA_HOME 到你的 JDK 安装路径&#xff0c;并将 %JAVA_HOME%\bin 添加到系统 PATH 中。 下载…

Apollo新版本Beta技术沙龙参会感受:未来的自动驾驶之旅

Apollo新版本Beta技术沙龙参会感受&#xff1a;未来的自动驾驶之旅 &#x1f697;&#x1f4a1; 文章目录 Apollo新版本Beta技术沙龙参会感受&#xff1a;未来的自动驾驶之旅 &#x1f697;&#x1f4a1;摘要引言正文&#x1f4cd; 参会流程介绍&#x1f31f; 参会收获&#x1…

「Verilog学习笔记」任意小数分频

专栏前言 本专栏的内容主要是记录本人学习Verilog过程中的一些知识点&#xff0c;刷题网站用的是牛客网 timescale 1ns/1nsmodule div_M_N(input wire clk_in,input wire rst,output wire clk_out );parameter M_N 8d87; parameter c89 8d24; // 8/9时钟切换点parameter di…

封装时间轴组件 timeline

要求时间轴的点展示进度百分比&#xff0c;线也根据进度不同展示不同长度的颜色 实现效果&#xff1a; 使用的组件库是vant的circle 子组件&#xff1a; <template><div class"m-timeline-area" :style"width: ${width}px"><div class&qu…

聊聊 Jetpack Compose 的 “状态订阅自动刷新” -- 你真的了解重组吗?

Jekpack Compose “状态订阅&自动刷新” 系列&#xff1a; 【 聊聊 Jetpack Compose 的 “状态订阅&自动刷新” - - MutableState/mutableStateOf 】 【 聊聊 Jetpack Compose 的 “状态订阅&自动刷新” - - remember 和重组作用域 】 【 聊聊 Jetpack Compose 的 …

Spring Cloud 配置 Druid(二)

不废话&#xff0c;直接上代码&#xff0c; Nacos搭建的微服务&#xff0c;可以看Spring Cloud 配置 Nacos&#xff08;一&#xff09;-CSDN博客 一&#xff0c;pom文件 spring-cloud-starter-alibaba-nacos-discovery 和 spring-cloud-starter-openfeign 都是基于spring-cl…

Apollo新版本Beta技术沙龙的参会感受

Apollo新版本Beta技术沙龙的参会感受 Apollo新版本Beta技术沙龙的参会感受摘要 &#x1f697;&#x1f310;参会流程 &#x1f5d3;️展厅参观/展厅讲解 &#x1f3e2;进入百度Apollo未来驾驶汽车5G云代驾的神奇签到 &#x1f4dd;Apollo新版本Beta整体介绍 &#x1f680;技术分…

C语言:用递归的方法求斐波那契数列:1,1,2,3,5,8,……的前40个数

分析&#xff1a; 首先&#xff0c;在代码的起始部分&#xff0c;包含<stdio.h>头文件&#xff0c;这个头文件提供了输入和输出的函数。 然后&#xff0c;定义了四个变量&#xff1a;f、f1、f2和i。f1和f2是斐波那契数列的前两个数字&#xff0c;初始化为1。f是当前计…

qt使用wimlib-imagex,做windows系统备份还原

wimlib-imagex是个第三方工具&#xff0c;可对系统映像进行操作&#xff0c;下载地址&#xff1a; https://wimlib.net/downloads/index.html 程序主要用到以下这两个文件&#xff1a;libwim-15.dll和wimlib-imagex.exe wimlib-imagex.exe的调用命令参数&#xff0c;可以通过…

【Docker】资源配额及私有镜像仓库

资源配额及私有镜像仓库 一、Docker资源配额1.1、控制cpu1.1.1、cpu份额控制1.1.2、core核心控制1.1.3、配额控制参数的混合使用 1.2、控制内存1.3、控制IO1.4、资源释放 二、Docker私有镜像仓库Harbor2.1、Harbor简介2.2、为Harbor自签发证书【1】生成ca证书【2】生成域名的证…

输出完全二叉树中某个结点的双亲和所有子孙。假设完全二叉树的顺序存储在一维数组A[n]中。

思路&#xff1a; 首先定义两个函数&#xff0c;getParent函数用于获取指定结点的双亲结点的索引&#xff0c;printDescendants函数用于输出指定结点的所有子孙。然后在main函数中&#xff0c;创建表示完全二叉树的数组A&#xff0c;并针对指定结点索引进行相关操作&#xf…

HOST文件被挟持,无法上网,如何解决。

问题&#xff1a; 晚上开机&#xff0c;突然发现无法联网&#xff0c;提示网络异常 解决&#xff1a; 首先网络诊断&#xff0c;host文件被劫持&#xff0c;修复后&#xff0c;仍然不行。 然后测试手机热点&#xff0c;发现仍然无法联网 尝试用火绒修复&#xff0c;无果。 所有…

Python 解析JSON实现主机管理

JSON&#xff08;JavaScript Object Notation&#xff09;是一种轻量级的数据交换格式&#xff0c;它以易于阅读和编写的文本形式表示数据。JSON 是一种独立于编程语言的数据格式&#xff0c;因此在不同的编程语言中都有对应的解析器和生成器。JSON 格式的设计目标是易于理解、…

【解决方案】环保设备用电与电网数据集中展示平台的应用与研究

摘 要&#xff1a;近年来&#xff0c;信息化不断推进&#xff0c;政府工作方式以及职能不断改革&#xff0c;许多省级环保部门开展环保与信息技术的融合&#xff0c;用于推进环保的发展。本文基于环境监测研究省级环保与电网数据集中展示平台的应用。环境监测是环保工作的重要组…

读书笔记-《数据结构与算法》-摘要1[数据结构]

文章目录 [数据结构]1. String - 字符串2. Linked List - 链表2.1 链表的基本操作2.1.1 反转链表单向链表双向链表 2.1.2 删除链表中的某个节点2.1.3 链表指针的鲁棒性2.1.4 快慢指针 3. Binary Tree - 二叉树3.1 树的遍历3.2 Binary Search Tree - 二叉查找树 4. Queue - 队列…

JSP入门+EL表达式+JSTL标签

1.JSP&#xff1a; 1.指令 2.注释 3.内置对象 2.MVC开发模式 3.EL表达式 4.JSTL标签 5.三层架构 ## JSP&#xff1a; 1.指令 *用于配置JSP页面&#xff0c;导入资源文件 *格式&#xff1a;<% 指令名称 属性名1属性值1 属性名2属性值2 .......%> *分类&#xff1…

格雷希尔帮助仪器仪表测试时快速密封的G60C系列接头其优势有哪些

仪器仪表在工业领域中扮演着重要的角色&#xff0c;如&#xff1a;压力表&#xff0c;压力传感器、压力变送器、压力开关、压力歧管等这些&#xff0c;在工业领域中都是随处可见的&#xff0c;其数据的精度直接影响着产品在生产过程中的质量和安全性&#xff1b;因此&#xff0…

食品行业研究:金枪鱼产业发展及市场消费分析

金枪鱼是无污染、高档、美味、安全、健康的绿色海洋动物食品&#xff0c;是国际营养协会推荐的世界三大营养鱼种之一 ,它凭借较高的经济价值、较广的分布范围、丰富的资源储量等优势&#xff0c;成为当今世界远洋渔业发展的关注重点和国际水产品贸易的主要鱼种。 金枪鱼类是高度…