ThreadLocal 详讲

ThreadLocal

ThreadLocal是一个将在多线程中为每一个线程创建单独的变量副本的类; 当使用ThreadLocal来维护变量时, ThreadLocal会为每个线程创建单独的变量副本, 避免因多线程操作共享变量而导致的数据不一致的情况。

ThreadLocal 使用

public class ThreadLocalTest {private static ThreadLocal<String> threadLocal = new ThreadLocal<>();private static ThreadLocal<UserInfo> userInfoThreadLocal = new ThreadLocal<UserInfo>();public static void main(String[] args) {threadLocal.set(Thread.currentThread().getName());UserInfo userInfo = new UserInfo();userInfo.setLoginId(Thread.currentThread().getName());userInfoThreadLocal.set(userInfo);System.out.println(threadLocal.get());System.out.println(userInfoThreadLocal.get()); }
}

执行结果

main
UserInfo{loginId='main', userName='null'}

set 方法

public void set(T value) {Thread t = Thread.currentThread(); //获取当前线程ThreadLocalMap map = getMap(t); //获取ThreadLocalMap  if (map != null) // 如果ThreadLocalMap 不为空 则调用set 方法map.set(this, value); // this 代表当前ThreadLocal 对象elsecreateMap(t, value); //创建ThreadLocalMap 赋值给当前线程threadLocals 属性 并set 当前ThreadLocal 对象为key  传入的value 作为value}ThreadLocalMap getMap(Thread t) {return t.threadLocals; //返回当前线程对象threadLocals 属性}

ThreadLocalMap 结构

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

ThreadLocalMap是ThreadLocal的内部类,主要有一个Entry数组,Entry的key为ThreadLocal,value为ThreadLocal对应的值。每个线程都有一个ThreadLocalMap类型的threadLocals变量。

ThreadLocalMap # set 方法

private void set(ThreadLocal<?> key, Object value) {Entry[] tab = table;int len = tab.length;int i = key.threadLocalHashCode & (len-1); //ThreadLocal对象hash 值   与数组长度进行与运算 得到数组下标for (Entry e = tab[i];e != null;//当遍历到数组元素为空就退出循环e = tab[i = nextIndex(i, len)]) { // 循环Entry 数组ThreadLocal<?> k = e.get(); //拿到Entry 的key if (k == key) {//判断Entry 的key 是否与 需要存储的key 相等e.value = value; //如果相等就替换原来的值return;}if (k == null) {//Entry 中的key 为空replaceStaleEntry(key, value, i); // 该方法会继续寻找传入key的安放位置, 并清理掉key为空的Entry return;}}//走这里 说明Entry[] 数组不存在 该key tab[i] = new Entry(key, value); //创建key为key ,value为value Entry 存储在下标为i 的位置int sz = ++size;//数组大小+1if (!cleanSomeSlots(i, sz) && sz >= threshold) //sz 大小是否大于阈值rehash();//扩容}
  1. 遍历数组Entry[] 如果找到key 相等的entry ,则替换entry 中value
  2. 如果遍历Entry [] 遇到key为空的entry,则调用replaceStaleEntry 清除key为空的元素
  3. 如果未找到相等key 的entry ,则传入的key ,value 创建entry 放置在下标未i 的位置
  4. 如果数组大小超过阈值,则调用rehash 方法扩容

rehash 方法

 private void rehash() {// 调用expungeStaleEntries方法清理key为空的Entry
expungeStaleEntries();// Use lower threshold for doubling to avoid hysteresisif (size >= threshold - threshold / 4) //数组大小超过阈值的3/4  则调用resize 进行扩容resize();
}
private void resize() {Entry[] oldTab = table;int oldLen = oldTab.length;int newLen = oldLen * 2;//新数组大小位旧数组大小的两倍Entry[] newTab = new Entry[newLen];//创建新Entry 数组 ,数组大小为原数组的两倍int count = 0;for (int j = 0; j < oldLen; ++j) {//循环遍历原数组Entry e = oldTab[j];if (e != null) {ThreadLocal<?> k = e.get();if (k == null) {// 如果存在key 为空的entry 则将entry 中的value 置为空 e.value = null; // Help the GC} else {int h = k.threadLocalHashCode & (newLen - 1); //通过key 重新计算entry 的下标while (newTab[h] != null) // 如果新表的该位置已经有元素,则调用nextIndex方法直到寻找到空位置h = nextIndex(h, newLen);newTab[h] = e;// 将元素放在对应位置count++;}}}setThreshold(newLen);// 设置新表扩容的阈值size = count;// 更新sizetable = newTab;// table指向新表}

replaceStaleEntry 方法

private void replaceStaleEntry(ThreadLocal<?> key, Object value,int staleSlot) {Entry[] tab = table;int len = tab.length;Entry e;int slotToExpunge = staleSlot; //记录开始清除元素的位置//从后往前遍历 直到遇到 Entry 为空for (int i = prevIndex(staleSlot, len);(e = tab[i]) != null;i = prevIndex(i, len))if (e.get() == null)slotToExpunge = i; //记录Entry key 为空的最后索引位置//从前往后遍历 直到遇到 Entry 为空for (int i = nextIndex(staleSlot, len);(e = tab[i]) != null;i = nextIndex(i, len)) {ThreadLocal<?> k = e.get();//如果传入的key  和 entry 中key 相等 ,则传入的value 替换 entry 中的value if (k == key) {e.value = value;//staleSlot 位置 替换 i 位置元素tab[i] = tab[staleSlot]; tab[staleSlot] = e;//slotToExpunge == staleSlot  表示 从 staleSlot 向前遍历 未找到key 为空的元素if (slotToExpunge == staleSlot)// 因为原staleSlot的元素已经被放到i位置了,这时位置i前面的元素都不需要清除slotToExpunge = i;// 从slotToExpunge位置开始清除key为空的EntrycleanSomeSlots(expungeStaleEntry(slotToExpunge), len);return;}// 如果第一次遍历到key为null的元素,并且上面的向前寻找key为null的遍历没有找到,// 则将slotToExpunge设置为当前的位置if (k == null && slotToExpunge == staleSlot)slotToExpunge = i;}// If key not found, put new entry in stale slottab[staleSlot].value = null;tab[staleSlot] = new Entry(key, value);// 如果slotToExpunge!=staleSlot,代表除了staleSlot位置还有其他位置的元素需要清除// 需要清除的定义:key为null的Entry,调用cleanSomeSlots方法清除key为null的Entryif (slotToExpunge != staleSlot)cleanSomeSlots(expungeStaleEntry(slotToExpunge), len);}    
  1. slotToExpunge始终记录着需要清除的元素的最前面的位置(即slotToExpunge前面的元素是不需要清除的)
  2. 从位置staleSlot向前遍历,直到遇到Entry为空,用staleSlot记录最后一个key为null的索引位置(也就是遍历过位置最前的key为null的位置)
  3. 从位置staleSlot向后遍历,直到遇到Entry为空,如果遍历到key和入参key相同的,则将入参的value替换掉该Entry的value,并将i位置和staleSlot位置的元素对换(staleSlot位置较前,是要清除的元素),遍历的时候判断slotToExpunge的值是否需要调整,最后调用expungeStaleEntry方法和cleanSomeSlots方法清除key为null的元素。
  4. 如果key没有找到,则使用入参的key和value新建一个Entry,放在staleSlot位置判断是否还有其他位置的元素key为null,如果有则调用expungeStaleEntry方法和cleanSomeSlots方法清除key为null的元素

cleanSomeSlots 方法

private boolean cleanSomeSlots(int i, int n) {boolean removed = false;Entry[] tab = table;int len = tab.length;do {i = nextIndex(i, len);Entry e = tab[i];if (e != null && e.get() == null) { //循环遍历 key 为空的元素n = len;//重新设置n 的值removed = true;//设置移除元素标志位i = expungeStaleEntry(i);//}} while ( (n >>>= 1) != 0); return removed;}

expungeStaleEntry 方法

private int expungeStaleEntry(int staleSlot) {Entry[] tab = table;int len = tab.length;// expunge entry at staleSlottab[staleSlot].value = null; //将tab staleSlot 位元素清空tab[staleSlot] = null;size--;// Rehash until we encounter nullEntry e;int i;for (i = nextIndex(staleSlot, len); // 遍历下一个元素(e = tab[i]) != null;	// 遍历到Entry为空时, 跳出循环并返回索引位置i = nextIndex(i, len)) {ThreadLocal<?> k = e.get(); if (k == null) {    // 当前遍历Entry的key为空, 则将该位置的对象清空e.value = null;tab[i] = null;size--;} else {    // 当前遍历Entry的key不为空int h = k.threadLocalHashCode & (len - 1);  // 重新计算该Entry的索引位置if (h != i) {   // 如果索引位置不为当前索引位置itab[i] = null;  // 则将i位置对象清空, 替当前Entry寻找正确的位置// 如果h位置不为null,则向后寻找当前Entry的位置while (tab[h] != null)h = nextIndex(h, len);tab[h] = e;}}}return i;}

get 方法

public T get() {Thread t = Thread.currentThread(); //获取当前线程ThreadLocalMap map = getMap(t);// 通过当前线程获取 threadLocals = ThreadLocalMap if (map != null) {//ThreadLocalMap  不为空ThreadLocalMap.Entry e = map.getEntry(this);//通过ThreadLocal 获取 entry if (e != null) {//entry 不为空@SuppressWarnings("unchecked")T result = (T)e.value; //获取entry value 返回return result;  }}// 该线程的ThreadLocalMap为空,或者没有找到目标Entry,则调用setInitialValue方法return setInitialValue();}
  1. 和set 方法一样先获取当前线程,在获取当前线程的变量threadLocals
  2. 如果threadLocals 不为空,则通过当前对象ThreadLocal 作为key getEntry 方法获取value 值
  3. 如果threadLocals 为空,则通过setInitialValue方法初始化一个threadLocal 为key value 值为空的entry 设置在 ThreadLocalMap 中。

getEntry 方法

 private Entry getEntry(ThreadLocal<?> key) {int i = key.threadLocalHashCode & (table.length - 1); //通过threadLocal hashcode 与Entry数组长度进行与运算,得到数组下标Entry e = table[i];if (e != null && e.get() == key)//如果entry 不为空,key与传入key 相等 返回entryreturn e;else// 否则,e不是目标Entry, 则从e之后继续寻找目标Entryreturn getEntryAfterMiss(key, i, e);}

getEntryAfterMiss 方法

private Entry getEntryAfterMiss(ThreadLocal<?> key, int i, Entry e) {Entry[] tab = table;int len = tab.length;while (e != null) {ThreadLocal<?> k = e.get();// 找到目标Entry,直接返回if (k == key)  return e;// 调用expungeStaleEntry清除key为null的元素if (k == null)expungeStaleEntry(i);elsei = nextIndex(i, len);  // 下一个索引位置e = tab[i]; // 下一个遍历的Entry}return null;    // 找不到, 返回空
}

setInitialValue 方法

private T setInitialValue() {T value = initialValue(); //初始化value  value =null Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);//获取当前线程的threadLocals 属性// threadLocals不为空则将当前的ThreadLocal作为key,null作为value,插入到ThreadLocalMapif (map != null)map.set(this, value);else// 调用set方法的ThreadLocal和value作为该Entry的key和valuecreateMap(t, value);return value;}

remove 方法

public void remove() {ThreadLocalMap m = getMap(Thread.currentThread());//获取当前线程的threadLocals 属性if (m != null)//ThreadLocalMap  不为空m.remove(this);}private void remove(ThreadLocal<?> key) {Entry[] tab = table;int len = tab.length;// 根据hashCode计算出当前ThreadLocal的索引位置int i = key.threadLocalHashCode & (len-1);  // 从位置i开始遍历,直到Entry为nullfor (Entry e = tab[i];e != null;e = tab[i = nextIndex(i, len)]) {if (e.get() == key) {   // 如果找到key相同的e.clear(); 	// 则调用clear方法, 该方法会把key的引用清空expungeStaleEntry(i);//调用expungeStaleEntry方法清除key为null的Entryreturn;}
}

总结

  1. 每个线程都有一个ThreadLocalMap 类型的 threadLocals 属性。
  2. ThreadLocalMap 类相当于一个Map,key 是 ThreadLocal 本身,value 就是我们的值。
  3. 当我们通过 threadLocal.set(new Integer(123)); 我们就会在这个线程中的 threadLocals属性中放入一个键值对,key 是 这个 threadLocal.set(newInteger(123))的threadlocal,value 就是值new Integer(123)。 当我们通过threadlocal.get() 方法的时候,首先会根据这个线程得到这个线程的 threadLocals属性,然后由于这个属性放的是键值对,我们就可以根据键 threadlocal 拿到值。 注意,这时候这个键 threadlocal 我们 set 方法的时候的那个键 threadlocal 是一样的,所以我们能够拿到相同的值。
  4. ThreadLocalMap 的get/set/remove方法跟HashMap的内部实现都基本一样,通过 "key.threadLocalHashCode & (table.length - 1)"运算式计算得到我们想要找的索引位置,如果该索引位置的键值对不是我们要找的,则通过nextIndex方法计算下一个索引位置,直到找到目标键值对或者为空。
  5. hash冲突:在HashMap中相同索引位置的元素以链表形式保存在同一个索引位置;而在ThreadLocalMap中,没有使用链表的数据结构,而是将(当前的索引位置+1)对length取模的结果作为相同索引元素的位置:源码中的nextIndex方法,可以表达成如下公式:如果i为当前索引位置,则下一个索引位置 = (i + 1 < len) ? i + 1 : 0。

ThreadLocal 为啥会发生内存泄漏呢?

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

有源代码可以看出,Entry 中的key ThreadLocal 是 弱引用,如果一个ThreadLocal没有外部强引用来引用它,下一次系统GC时,这个ThreadLocal必然会被回收,这样一来,ThreadLocalMap中就会出现key为null的Entry,就没有办法访问这些key为null的Entry的value。

如果当前线程一直在运行,并且一直不执行get、set、remove方法,这些key为null的Entry的value就会一直存在一条强引用练:Thread Ref -> Thread -> ThreadLocalMap -> Entry -> value,导致这些key为null的Entry的value永远无法回收,造成内存泄漏。

如何解决内存泄漏
为了避免这种情况,我们可以在使用完ThreadLocal后,手动调用remove方法,以避免出现内存泄漏。

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

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

相关文章

ssm宠物网站系统-计算机毕业设计源码07183

摘 要 在信息飞速发展的今天&#xff0c;网络已成为人们重要的信息交流平台。宠物网站每天都有大量的信息需要通过网络发布&#xff0c;为此&#xff0c;本人开发了一个基于B/S&#xff08;浏览器/服务器&#xff09;模式的宠物网站系统。 该系统以JJava编程语言、MySQL和SSM框…

Linux sudo -i取消密码的方法

直接修改 /etc/sudoers 文件来实现 sudo -i 无需密码的配置。以下是具体步骤&#xff1a; 步骤 打开终端并使用 visudo 命令编辑 /etc/sudoers 文件 使用 visudo 编辑 sudoers 文件是推荐的方法&#xff0c;因为它会在保存前进行语法检查&#xff0c;防止出现配置错误。 sudo …

基于 VITA57.1 标准的 2 收 2 发射频子卡(国产 ADRV9009子卡)

FMC159 是一款基于 VITA57.1 标准规范&#xff0c;实现 2 收 2 发的射频子模块&#xff0c;该板卡基于国产化 ADRV9009 射频收发器&#xff0c;涵盖了50MHz~6GHz 频段&#xff0c;并集成了双通道收发链路&#xff0c;发送最大实时带宽可到 450MHz&#xff0c;接收最大带宽可以到…

十进制、二进制、十六进制之间的相互转换

实验目的 实现int 、float 转换为字符串并显示 实现数字字符以二进制、十进制、十六进制显示 实现十进制、二进制、十六进制之间的相互转换 #include "numconvert.h" #include "ui_numconvert.h"NumConvert::NumConvert(QWidget *parent): QWidget(parent)…

C#特性-CallerMemberName、CallerFilePath和CallerLineNumber的介绍和应用

介绍 在csharp中&#xff0c;CallerMemberName, CallerFilePath, 和 CallerLineNumber 是编译时常量&#xff0c;它们是csharp 5.0引入的特性&#xff0c;用于提供有关调用堆栈的信息&#xff0c;通常用于日志记录和调试。这些特性可以自动填充方法的参数&#xff0c;无需显式…

软考初级网络管理员__网络单选题

1.观察交换机状态指示灯初步判断交换机故障&#xff0c;交换机运行中指示灯显示红色表示()。 警告 正常 待机 繁忙 2.通常测试网络连通性采用的命令是()。 Netstat Ping Msconfig Cmd 3.一台16端口的交换机可以产生&#xff08;&#xff09;个冲突域? 1 4 15 16…

jQuery 常用函数解析

简介 jQuery 是一个流行的 JavaScript 库&#xff0c;它极大地简化了网页开发中的常见任务。在本文中&#xff0c;我们将深入探讨 jQuery 中一些非常有用的函数&#xff0c;包括 parent、find、siblings、prop、hasClass、removeClass、addClass、empty、append、text、val、r…

安装 Nuxt.js 的步骤和注意事项

title: 安装 Nuxt.js 的步骤和注意事项 date: 2024/6/17 updated: 2024/6/17 author: cmdragon excerpt: Nuxt.js在Vue.js基础上提供的服务器端渲染框架优势&#xff0c;包括提高开发效率、代码维护性和应用性能。指南详细说明了从环境准备、Nuxt.js安装配置到进阶部署技巧&…

3D元宇宙虚拟主播引领文旅产业迈向更加美好的未来!

随着文旅产业的蓬勃发展&#xff0c;3D数字代言人的应用正逐渐改变着传统的文旅传播方式。文旅3D数字代言人搭建编辑器的出现&#xff0c;正是满足大部分文旅产业借助数字人浪潮&#xff0c;将传统文化与现代科技完美融合的创新之举。 文旅3D数字代言人搭建编辑器不仅满足了Z世…

SelfGNN: Self-Supervised Graph Neural Networks for Sequential Recommendation

SelfGNN: Self-Supervised Graph Neural Networks for Sequential Recommendation&#xff08;Sigir2024&#xff09; 摘要 顺序推荐通过对用户的时间和顺序交互模式进行建模&#xff0c;有效地解决信息过载问题。 为了克服监督信号的局限性&#xff0c;最近的方法在推荐系统中…

奇安信齐向东:AI驱动安全,应对数字经济时代挑战

随着数字经济的蓬勃发展&#xff0c;网络安全问题日益凸显&#xff0c;AI技术的融入为网络安全带来了新的机遇和挑战。近日&#xff0c;备受瞩目的2024全球数字经济大会数字安全高层论坛暨北京网络安全大会战略峰会&#xff08;简称“BCS大会”&#xff09;在北京盛大开幕。本次…

GPT-4o的视觉识别能力,将绕过所有登陆的图形验证码

知识星球&#x1f517;除了包含技术干货&#xff1a;《Java代码审计》《Web安全》《应急响应》《护网资料库》《网安面试指南》还包含了安全中常见的售前护网案例、售前方案、ppt等&#xff0c;同时也有面向学生的网络安全面试、护网面试等。 我们来看一下市面上常见的图形验证…

3、双分支判断 - 课件

一、双分支的基本语法结构 双分支结构,也称为if-else语句,其基本语法如下: if (判断表达式) {// 条件为真时执行的代码块 } else {// 条件为假时执行的代码块 }说明: 判断表达式是一个布尔表达式,它的值为真(true)或假(false)。如果判断表达式的值为真,执行if后面的代码块;如…

Redis:原理、概念、用法与实例解析

Redis&#xff1a;原理、概念、用法与实例解析 在当今风起云涌的技术领域中&#xff0c;Redis 犹如一颗璀璨的明星&#xff0c;闪耀着独特的光芒。它作为一种备受瞩目的数据存储和缓存解决方案&#xff0c;以其卓越的性能、丰富多样的功能以及简单易用的特性&#xff0c;成为了…

【WEEK16】学习目标及总结【Spring Boot】【中文版】

学习目标&#xff1a; 学习SpringBoot 学习内容&#xff1a; 参考视频教程【狂神说Java】SpringBoot最新教程IDEA版通俗易懂Dubbo和Zookeeper集成 学习时间及产出&#xff1a; 第十六周TUE~FRI 2024.6.11【WEEK16】 【DAY2】Dubbo和Zookeeper集成第二部分【中文版】【WEEK16…

3秒生成!这个AI模型画风也太治愈了,新手也能轻松驾驭

还在为不会画画而苦恼吗&#xff1f;别担心&#xff0c;今天给大家介绍一个超好用的AI模型——Soft and Squishy Linework&#xff0c;即使是小白也能轻松生成可爱的动漫图像&#xff01; Soft and Squishy Linework&#xff1a;专门生成柔和的、低保真&#xff08;lofi&#…

AWS 批量添加安全组

定义内网ip列表池 cat ip_list.txt192.168.1.1 192.168.1.2定义脚本安全组id等元数据 # cat sg-add.sh #!/bin/bash# 定义安全组ID-宁夏 VPC:NX-NHRY-PRD-VPC vpc-xxx SECURITY_GROUP_ID"sg-0f08237289xxxxx"# 从文件中读取IP地址到数组 IFS read -ra INTERNAL_IP…

为何选择Xinstall?告别邀请码,让App推广更便捷!

在互联网日益繁荣的今天&#xff0c;App的推广和运营成为了各大企业关注的重点。然而&#xff0c;传统的推广方式如邀请码限制&#xff0c;往往会给用户带来不便&#xff0c;同时也限制了App的快速增长。在这个背景下&#xff0c;Xinstall凭借其独特的功能和服务&#xff0c;成…

快慢指针技巧

快慢指针技巧 在说快慢指针之前&#xff0c;我们先说一下双指针。 双指针 双指针&#xff1a;使用两个指针来解决问题。 所谓的指针其实就是指数组的下标&#xff0c;或者链表的节点的地址。 我们以数组为例介绍一下。 有两个指针分别存储着数组的两个下标&#xff0c;这就…

成都某展厅2套2x2透明OLED拼接屏项目

成都某展厅的2套2x2透明OLED拼接屏展示设计具有独特的技术魅力和视觉效果。以下是关于这一展示设计的详细介绍&#xff1a; 1.产品规格 类型&#xff1a;透明OLED拼接屏 尺寸与配置&#xff1a;每套为2x2拼接&#xff0c;即每套由4块屏幕组成。 2.应用场景 成都某展厅&#…