当前位置: 首页 > news >正文

深入解析ThreadLocal:线程数据隔离利器

目录

一、概述

二、ThreadLocal内部结构

三、常用方法

【1】存储数据void set(T value)

【2】获取数据T get()

【3】删除数据void remove()

四、常见问题

【1】为什么用ThreadLocal做key?

【2】ThreadLocalMap如何查找数据?

【3】父子线程如何共享数据?

【4】ThreadLocal如何避免内存泄露?

五、ThreadLocal应用场景

【1】线程数据隔离

【2】跨函数传递


一、概述

        ThreadLocal被称为线程局部变量,用于在线程中保存数据。由于在ThreadLocal中保存的数据仅属于当前线程,所以该变量对其他线程而言是隔离的,也就是说该变量是当前线程独有的变量。
        ThreadLocal用于在同一个线程间,在不同的类和方法之间共享数据的的场景,也可以用于在不同线程间隔离数据的场景。
        ThreadLocal利用Thread中的ThreadLocalMap来进行数据存储。

public class Test {// 线程局部变量public static ThreadLocal<String> threadLocal = new ThreadLocal<String>();public static void main(String[] args) {Thread t1 = new Thread(new Runnable() {@Overridepublic void run() {threadLocal.set("妲己");show();Sample.dosth();}},"线程1");Thread t2 = new Thread(new Runnable() {@Overridepublic void run() {threadLocal.set("后羿");show();Sample.dosth();}},"线程2");t1.start();t2.start();}public static void show() {String role = threadLocal.get();System.out.println("show:"+Thread.currentThread().getName()+"分配角色:" + role);}
}class Sample {public static void dosth() {String role = Test.threadLocal.get();System.out.println("dosth:"+Thread.currentThread().getName()+"分配角色:" + role);}
}

二、ThreadLocal内部结构

        ThreadLocalMap内部数据结构是一个Entry类型的数组。每个Entry对象的key为ThreadLocal对象,value为存储的数据。


三、常用方法

【1】存储数据void set(T value)

存储数据至当前线程的ThreadLocalMap

public void set(T value) {// 获取当前线程Thread t = Thread.currentThread();// 获取当前线程的ThreadLocalMapThreadLocalMap map = getMap(t);// 存储数据至当前线程的ThreadLocalMap中// 使用ThreadLocal对象做key,保存数据valueif (map != null)map.set(this, value);elsecreateMap(t, value);
}

【2】获取数据T get()

从当前线程的ThreadLocalMap中获取数据

public T get() {// 获取当前线程的ThreadLocalMapThread t = Thread.currentThread();ThreadLocalMap map = getMap(t);// 使用ThreadLocal对象做key,获取数据(Entry类型)if (map != null) {ThreadLocalMap.Entry e = map.getEntry(this);if (e != null) {@SuppressWarnings("unchecked")T result = (T)e.value;return result;}}return setInitialValue();
}

【3】删除数据void remove()

从当前线程的ThreadLocalMap中删除数据:
在线程池的线程复用场景中,线程执行完毕时一定要调用remove(),避免在线程被重新放入线程池中时被本地变量的旧状态仍然被保存。

public void remove() {// 获取当前线程的ThreadLocalMapThreadLocalMap m = getMap(Thread.currentThread());// 使用当前ThreadLocal对象做key,删除数据if (m != null)m.remove(this);
}

四、常见问题

【1】为什么用ThreadLocal做key?

        如果在应用中,一个线程中只使用了一个ThreadLocal对象,那么使用Thread做key也是可以的,代表每个Thread线程对应一个value。

        但是,在实际应用程序开发过程中,一个线程中很有可能不只使用了一个ThreadLocal对象。这时使用Thread做key就会产生混淆。

        所以,不能使用Thread做key,而应该改成用ThreadLocal对象做key,这样才能通过具体ThreadLocal对象的get()方法,获取到当前线程的ThreadLocalMap,然后进一步获取到对应的Entry。


【2】ThreadLocalMap如何查找数据?

        当我们使用ThreadLocal获取当前线程中保存的Value数据时,是以ThreadLocal对象作为Key,通过访问Thread当前线程对象的内部ThreadLocalMap集合来获取到Value。

        ThreadLocalMap集合的底层数据结构使用Entry[]数组保存Key-Value键值对数据。所以,当通过ThreadLocal的get、set()、remove()等方法,访问ThreadLocalMap时,最终都会通过一个下标,来完成对数组中的元素访问。

int i = key.threadLocalHashCode & (len-1);

        通过key的“hashCode值”跟"数组的长度减1" 做“&按位与”运算。其中key就是ThreadLocal对象。这种计算方式,相当于用“hashCode值”跟“数组的长度”进行“%取余”运算。
假设:len=16,key.threadLocalHashCode=31
hash & len-1的计算结果与hash % len的计算结果一直,均为15,但是“&按位与”运算的效率更高。


【3】父子线程如何共享数据?

        使用InheritableThreadLocal,它是JDK自带的类,继承了ThreadLocal类。

public class ThreadLocalTest {public static void main(String[] args) {InheritableThreadLocal<String> threadLocal = new InheritableThreadLocal<String>();threadLocal.set("天王盖地虎");System.out.println("main主线程:"+threadLocal.get());Thread thread = new Thread(new Runnable() {@Overridepublic void run() {System.out.println("子线程:"+threadLocal.get());}});thread.start();}
}


【4】ThreadLocal如何避免内存泄露?

        使用完毕后,在finally调用ThreadLocal对象的remove()方法。

public class CurrentUser {private static final ThreadLocal<UserInfo> THREA_LOCAL = new ThreadLocal();public static void set(UserInfo userInfo) {THREA_LOCAL.set(userInfo);}public static UserInfo get() {THREA_LOCAL.get();}public static void remove() {THREA_LOCAL.remove();}
}
//然后在业务代码中调用相关方法
public void doSamething(UserDto userDto) {UserInfo userInfo = convert(userDto);try{CurrentUser.set(userInfo);...//业务代码UserInfo userInfo = CurrentUser.get();...} finally {CurrentUser.remove();}
}

        需要特别注意的地方是:一定要在finally代码块中,调用remove()方法清理没用的数据。如果业务代码出现异常,也能及时清理没用的数据。
        remove()方法中会把Entry中的key和value都设置成null,这样就能被GC及时回收,无需触发额外的清理机制,所以它能解决内存泄露问题。


五、ThreadLocal应用场景

【1】线程数据隔离

        ThreadLocal的主要价值在于线程隔离,ThreadLocal中的数据只属于当前线程,该数据对别的线程是不可见的,起到隔离作用。这样操作,可以在多线程环境下,可以防止当前线程的数据被其他线程修改。另外,由于各个线程之间的数据相互隔离,避免了同步加锁带来的性能损失,大大提升了并发性的性能。

        例如:SqlSession会话对象绑定,避免多个线程使用同一个SqlSession对象,由于关闭导致异常。

private static final ThreadLocal threadSession= new ThreadLocal();public static SqlSession getSession(){SqlSession s = (SqlSession)threadSession.get();if(s==null){s = getSqlSessionFactory().openSqlSession();threadSession.set(s);}
}

【2】跨函数传递

        数据通常用于同一个线程内,跨类、跨方法传递数据时,如果不用ThreadLocal,那么相互之间的数据传递势必要靠返回值和参数,这样无形之中增加了这些类或者方法之间的耦合度。


        感谢你花时间读到这里~ 如果你觉得这篇内容对你有帮助,不妨点个赞让更多人看到;如果有任何想法、疑问,或者想分享你的相关经历,欢迎在评论区留言交流,你的每一条互动对我来说都很珍贵~ 我们下次再见啦!😊😊


文章转载自:

http://TUi7S4DT.nytgk.cn
http://3U7rbDZm.nytgk.cn
http://ULFXO5uG.nytgk.cn
http://QilK4zqP.nytgk.cn
http://rOaC4L78.nytgk.cn
http://GXDFTsne.nytgk.cn
http://M42IPifE.nytgk.cn
http://rddrpjF8.nytgk.cn
http://1FX17GJh.nytgk.cn
http://WXkjqSvm.nytgk.cn
http://rJLNtmGl.nytgk.cn
http://uKrVFVui.nytgk.cn
http://mi89Z8nu.nytgk.cn
http://Dhi0t90V.nytgk.cn
http://ZZEgZ0lw.nytgk.cn
http://NlABQqqn.nytgk.cn
http://5uUDAAAN.nytgk.cn
http://inv8BBNt.nytgk.cn
http://x1LVpAPN.nytgk.cn
http://YKNb3LM3.nytgk.cn
http://Fa9Ci3th.nytgk.cn
http://szYGlP9l.nytgk.cn
http://18Z63qaf.nytgk.cn
http://Pf1Wzzez.nytgk.cn
http://g9W7UZ5B.nytgk.cn
http://TBzJzohB.nytgk.cn
http://yWyylAdz.nytgk.cn
http://kq7Dzr12.nytgk.cn
http://b3Izz9FT.nytgk.cn
http://6u5mMX6G.nytgk.cn
http://www.dtcms.com/a/376580.html

相关文章:

  • D01-【计算机二级】Python(1)基本操作第41题
  • API开发工具postman、国内xxapi和SmartApi的性能对比
  • Scikit-learn Python机器学习 - 分类算法 - 线性模型 逻辑回归
  • SciKit-Learn 全面分析 digits 手写数据集
  • 《sklearn机器学习——数据预处理》标准化或均值去除和方差缩放
  • 保序回归Isotonic Regression的sklearn实现案例
  • 《sklearn机器学习——数据预处理》离散化
  • 无人机桨叶转速技术要点与突破
  • GPFS存储服务如何使用及运维
  • ELK 日志采集与解析实战
  • BI数据可视化:驱动数据价值释放的关键引擎
  • FinChat-金融领域的ChatGPT
  • OpenTenBase日常操作锦囊(新手上路DML)
  • Dart 中的 Event Loop(事件循环)
  • C++/Java编程小论——方法设计与接口原则总结
  • Java-Spring入门指南(四)深入IOC本质与依赖注入(DI)实战
  • 线扫相机采集图像起始位置不正确原因总结
  • JVM 对象创建的核心流程!
  • 秋日私语:一片落叶,一个智能的温暖陪伴
  • springCloud之配置/注册中心及服务发现Nacos
  • 第1讲 机器学习(ML)教程
  • Ubuntu 系统 YOLOv8 部署教程(GPU CPU 一键安装)
  • 【C++】string 的使用(初步会用 string,看这一篇文章就够了)
  • 基于 lua_shared_dict 的本地内存限流实现
  • 基于场景的自动驾驶汽车技术安全需求制定方法
  • 【lucene】pointDimensionCount` vs `pointIndexDimensionCount`:
  • 大语言模型入门指南:从原理到实践应用
  • 旧设备新智慧:耐达讯自动化RS232转Profibus连接流量泵工业4.0通关秘籍
  • 扭蛋机小程序有哪些好玩的创新功能?
  • 小程序非主页面的数据动作关联主页面的数据刷新操作