ThreadLocal概述

news2024/9/21 3:31:08

一、概述

        ThreadLocal被称为线程局部变量,用于在线程中保存数据。由于在ThreadLocal中保存的数据仅属于当前线程,所以该变量对其他线程而言是隔离的,也就是说该变量是当前线程独有的变量。

        ThreadLocal用于在同一个线程间,在不同的类和方法之间共享数据的的场景,也可以用于在不同线程间隔离数据的场景。
ThreadLocal利用Thread中的ThreadLocalMap来进行数据存储。

示例: 

public class Test01 {

	public static ThreadLocal<String> threadLoacl = new ThreadLocal<String>();

	public static void main(String[] args) throws InterruptedException {

		Thread t1 = new Thread(new Runnable() {

			@Override
			public void run() {
				threadLoacl.set("苏妲己");
				show();
				Sample.dosth();
			}
		}, "线程1");

		Thread t2 = new Thread(new Runnable() {

			@Override
			public void run() {
				threadLoacl.set("ddc");
				show();
				Sample.dosth();
			}
		}, "线程2");

		t1.start();
		t2.start();

		t1.join();
		t2.join();
	}

	public static void show() {
		System.out.println("show" + Thread.currentThread().getName() + "分配角色:" + threadLoacl.get());
	}
}

class Sample {
	// 线程1或线程2
	public static void dosth() {
		System.out.println("dosth:" + Thread.currentThread().getName() + "分配角色:" + Test01.threadLoacl.get());
	}
}

二、常用方法 

1. 存储数据至当前线程的ThreadLocalMap:public void set(T value)

public void set(T value) {
        // 获取当前线程
        Thread t = Thread.currentThread();

        // 获取当前线程的ThreadLocalMap
        ThreadLocalMap map = getMap(t);
        // 存储数据到当前的ThreadLocalMap中
        // 使用ThreadLocal做key 保存数据value
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
    }

2. 从当前线程的ThreadLocalMap中获取数据:public T get()

public T get() {
        // 获取当前线程的ThreadLocalMap
        Thread 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. 从当前线程的 ThreadLocalMap 中删除数据: public void remove()

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

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

        ThreadLocal的get()方法、set()方法和remove()方法,其实最终操作的都是ThreadLocalMap类中的数据。

三、ThreadLocalMap内部结构

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

static class ThreadLocalMap {
     static class Entry extends WeakReference<ThreadLocal<?>> {
     Object value;
     Entry(ThreadLocal<?> k, Object v) {
         super(k);
         value = v;
     }
 }
     ...
     private Entry[] table;
     ...
}

 3.1 为什么使用ThreadLocal做key

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

示例:

public class ThreadLocalService {
     private static final ThreadLocal<Integer> threadLocal = new ThreadLocal<>();
} 

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

public class ThreadLocalService {
     private static final ThreadLocal<Integer> threadLocal1 = new ThreadLocal<>();
     private static final ThreadLocal<Integer> threadLocal2 = new ThreadLocal<>();
     private static final ThreadLocal<Integer> threadLocal3 = new ThreadLocal<>();
}

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

3.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.3 父子线程如何共享数据

        在实际工作中,有可能需要在父子线程中共享数据的。即:在父线程中往 ThreadLocal 设置了值,在子线程中能够获取到。

public class ThreadLocalTest {
    public static void main(String[] args) {
        ThreadLocal<String> threadLocal = new ThreadLocal<String>();
        threadLocal.set("叮叮车");
        System.out.println("main主线程:"+threadLocal.get());
        Thread thread = new Thread(new Runnable() {
            @Override
            public void run() {
                System.out.println("子线程:"+threadLocal.get());
            }
        });
        thread.start();
    }
}

运行结果为null,就是没有获取到

        在这种情况下使用 ThreadLocal 是行不通的。 main 方法是在主线程中执行的,相当于父线程。在 main 方法中开启了另外一个线程,相当于子线程。两个线程对象,各自拥有不同的 ThreadLocalMap 。应该使用 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() {
            @Override
            public void run() {
                System.out.println("子线程:"+threadLocal.get());
            }
        });
        thread.start();
    }
}

结果成功获取到值

3.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应用场景

4.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);
        }
}

4.2 跨函数传递

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

例如:获取HttpServletRequest

// SpringMVC或SpringBoot框架使用中获取HttpServletRequest
HttpServletRequest request = 
 ((ServletRequestAttributes)RequestContextHolder.getRequestAttributes()).getRequest();

 

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

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

相关文章

Prompt GPT推荐社区

大家好&#xff0c;我是荷逸&#xff0c;这次给大家带来的是我日常学习Prompt社区推荐 Snack Prompt 访问地址&#xff1a;http://snackprompt.com Snack Prompt是一个采用的Prompts诱导填空式的社区&#xff0c;它提供了一种简单的prompt修改方式&#xff0c;你只需要输入关…

​Spring Cloud Alibaba与Nacos版本对应关系​

下面是Spring Cloud Alibaba与Nacos版本对应关系 Spring Cloud Alibaba VersionNacos Version2021.0.1.0*1.4.22.2.7.RELEASE2.0.32.2.6.RELEASE1.4.22021.1 or 2.2.5.RELEASE or 2.1.4.RELEASE or 2.0.4.RELEASE1.4.12.2.3.RELEASE or 2.1.3.RELEASE or 2.0.3.RELEASE1.3.32.…

curl请求https|http网站时出现Binary output can mess up your terminal

请求网站时出现​ 那么这里有几种情况 文件本身为二进制文件内容压缩 如果是第一种情况&#xff0c;那么直接保存你要下载的二进制文件&#xff0c;使用 curl https://a.com -o 文件名保存在一个文件中 或者使用 -o -直接输出在终端 curl https://a.com -o -如果你本来访问…

Nacos源码构建报错程序包不存在com.alibaba.nacos.consistency.entity

直接启动 Nacos.java 报错。 Nacos源码构建报错程序包不存在com.alibaba.nacos.consistency.entity 解决方案 执行 mvn compile。 原因 com.alibaba.nacos.consistency.entity包目录是由protobuf在编译时自动生成。可通过mvn compile来自动生成他们。如果使用的是IDEA&…

问道管理:A股连续两日放量上扬,分析称筹码充分交换后或趋势性上涨

利好加持下前一买卖日高开低走后&#xff0c;A股迎来全线暴升&#xff01; 8月29日&#xff0c;三大指数均涨超1%&#xff0c;其间深证成指和创业板指更是涨逾2%&#xff0c;分别上行2.17%、2.82%。值得一提的是&#xff0c;商场上行中科创板股票全线迸发&#xff0c;科创50指…

供水管网安全运行监测,持续保障市民用水安全需求

供水管网是城市供水系统的核心组成部分&#xff0c;安全运行对人民的生活和社会发展至关重要。要持续不断地向城市供应数量充足、质量合格的水&#xff0c;应解决管道爆管问题、管网漏损导致严重的资源浪费等&#xff0c;及时发现管网故障&#xff0c;提高维护效率、降低损失&a…

【数据结构】初识树

目录 一&#xff0c;树的基本概念 1.1树的相关概念 1.2树的表示 二&#xff0c;二叉树的基本概念 2.1特殊的二叉树&#xff1a; 2.2二叉树的性质 2.3二叉树的存储结构 1. 顺序存储 2.链式存储 一&#xff0c;树的基本概念 树是一类重要的非线性数据结…

芯探科技--泛自动驾驶激光雷达解决方案

泛自动驾驶应用领域: 无人配送车 无人叉车 服务机器人 无人清扫车 …… 泛自动驾驶激光雷达解决方案介绍 在中低速移动过程中,类似无人配送车、无人叉车、服务型机器人、无人清扫车等具有自动驾驶功能的车辆,其需要对周围的环境进行探测,进而实现…

大数据Flink简介与架构剖析并搭建基础运行环境

文章目录 前言Flink 简介Flink 集群剖析Flink应用场景Flink基础运行环境搭建Docker安装docker-compose文件编写创建并运行容器访问Flink web界面 前言 前面我们分别介绍了大数据计算框架Hadoop与Spark,虽然他们有的有着良好的分布式文件系统和分布式计算引擎&#xff0c;有的有…

算法:分治思想处理快排递归以及快速选择/最小K个数问题

文章目录 算法原理实现思路典型例题颜色分类快速排序优化数组中最大的K个数最小的K个数 总结 算法原理 分治的原理就是分而治之&#xff0c;从原理上讲&#xff0c;就是把一个复杂的问题划分成子问题&#xff0c;再将子问题继续划分&#xff0c;直到可以解决 实现思路 基于分…

nvm 安装nodejs

1. 下载nvm 地址&#xff1a;Releases coreybutler/nvm-windows GitHub 2. 按要求一步步进行 3. 安装完成后配置nvm 的环境变量 找到nvm文件的路径&#xff0c;选中path&#xff0c;点击编辑讲nvm的路径放进去确定保存即可

RK3562 到底性能如何?安兔兔实测

RK3562采用四核A53Mali G52架构&#xff0c;主频2GHz&#xff0c;内置1T NPU算力以及13M ISP&#xff0c;拥有丰富的外围接口。其次在解码方面&#xff0c;支持H.264 1080P60fps、H.265 4K30fps&#xff1b;编码方面支持H.264 1080P60fps&#xff0c;此外还有高质量JPEG编解码。…

无涯教程-Android Intent Standard Actions函数

下表列出了各种重要的Android Intent标准操作。您可以查看Android官方文档以获取完整的操作列表- Sr.NoActivity Action Intent & Description1 ACTION_ALL_APPS 列出设备上所有可用的应用程序。 2 ACTION_ANSWER 处理来电。 3 ACTION_ATTACH_DATA 用于表示应将某些数据…

Python股票交易---均值回归

免责声明&#xff1a;本文提供的信息仅用于教育目的&#xff0c;不应被视为专业投资建议。在做出投资决策时进行自己的研究并谨慎行事非常重要。投资涉及风险&#xff0c;您做出的任何投资决定完全由您自己负责。 在本文中&#xff0c;您将了解什么是均值回归交易算法&#xff…

你的香港公司开始年审了吗?

小青是个SOHO&#xff0c;在19年找A注册的香港公司&#xff0c;一开始是想着有个自己的公司收款或者给客户做合同的时候不需要麻烦供应商&#xff0c;会相对方便一些。公司下来之后&#xff0c;每年年审的费用也就上千块&#xff0c;还不算太高。 一开始做年审&#xff0c;都是…

Rn实现省市区三级联动

省市区三级联动选择是个很频繁的需求&#xff0c;但是查看了市面上很多插件不是太老不维护就是不满足需求&#xff0c;就试着实现一个 这个功能无任何依赖插件 功能略简单&#xff0c;但能实现需求 核心代码也尽力控制在了60行左右 pca-code.json树型数据来源 Administrative-d…

基于RabbitMQ的模拟消息队列之三——硬盘数据管理

文章目录 一、数据库管理1.设计数据库2.添加sqlite依赖3.配置application.properties文件4.创建接口MetaMapper5.创建MetaMapper.xml文件6.数据库操作7.封装数据库操作 二、文件管理1.消息持久化2.消息文件格式3.序列化/反序列化4.创建文件管理类MessageFileManager5.垃圾回收 …

【校招VIP】测试计划之测试分类

考点介绍&#xff1a; 本专题主要介绍了软件测试在不同场景下的划分。并且讲解了基于软件测试的划分衍生出的常见面试题。 测试分类也是校招里面考察的一个重点。 『测试计划之测试分类』相关题目及解析内容可点击文章末尾链接查看&#xff01; 一、考点试题 1.软件测试按开…

【安卓】拿注册码的两种方式

【安卓】拿注册码的两种方式 文章仅用于学习交流&#xff0c;请勿利用文章中的技术对任何计算机系统进行入侵操作。利用此文所提供的信息而造成的直接或间接后果和损失&#xff0c;均由使用者本人负责。首发吾爱&#xff1a;https://www.52pojie.cn/thread-1826802-1-1.html言归…

OBS Studio 30.0 承诺在 Linux 上支持英特尔 QSV,为 DeckLink 提供 HDR 回放功能

导读OBS Studio 30.0 现已推出公开测试版&#xff0c;承诺为这款广受欢迎的免费开源截屏和流媒体应用程序提供多项令人兴奋的新功能&#xff0c;以及大量其他更改和错误修复。 OBS Studio 30.0 承诺在 Linux 上支持英特尔 QSV&#xff08;快速同步视频&#xff09;、WHIP/WebRT…