告诉你为什么 ThreadLocal 可以做到线程隔离

 更新时间:2022年07月26日 09:05:19   作者:刘水镜  
对于 ThreadLocal 我们都不陌生,它的作用如同它的名字用于存放线程本地变量,这篇文章主要介绍了为什么 ThreadLocal 可以做到线程隔离,需要的朋友可以参考下

对于 ThreadLocal 我们都不陌生,它的作用如同它的名字——用于存放「线程本地」变量。

先通过一个小例子感受一下:

private static final ThreadLocal<String> threadLocal = new ThreadLocal<>();
public static void main(String[] args) throws Throwable {
    Thread threadOne = new Thread(()->{
        threadLocal.set("ThreadOne:" + Thread.currentThread().getName());
        log.info("线程 One 本地变量值为:{}", threadLocal.get());
        threadLocal.remove();
        log.info("线程 One remove 后本地变量值为:{}", threadLocal.get());
    });
    Thread threadTwo = new Thread(()->{
        threadLocal.set("ThreadTwo:" + Thread.currentThread().getName());
        log.info("线程 Two 本地变量值为:{}", threadLocal.get());
    });
    threadOne.start();
    threadTwo.start();
}

运行结果:

线程 One 本地变量值为:ThreadOne:Thread-0
线程 One remove 后本地变量值为:null
线程 Two 本地变量值为:ThreadTwo:Thread-1

OK,从效果上看,ThreadLocal 确实是线程隔离的,那么,它是如何做到线程隔离的呢?下面我们扒一扒源码,看看它是如何做到的:

public void set(T value) {
   Thread t = Thread.currentThread();
   ThreadLocalMap map = getMap(t);
   if (map != null)
       map.set(this, value);
   else
       createMap(t, value);
}

set() 方法的逻辑如下:

  • 获取当前线程
  • 根据当前线程获取一个 ThreadLocalMap 对象
  • 如果 map 不为 null 则保存
  • 如果 map 为 null 则创建一个 map

getMap() 和 createMap() 方法都干了啥呢?我们点进去看:

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

进入到两个方法内部后发现,不管执行哪个分支,最终是把值保存到了当前线程的 threadLocals 属性中。

查看 Thread 类的源码,你会发现类中定义了一个 threadLocals 属性,且初始值为 null,其类型为ThreadLocal.ThreadLocalMap。

public class Thread implements Runnable {
// ...
   ThreadLocal.ThreadLocalMap threadLocals = null;
// ...
}

到此,我们发现了,原来 ThreadLocal 就是把我们要传递的对象放到了当前线程的 threadLocals 属性中。也就是说每个线程在用 ThreadLocal 保存对象时,其实就是将对象放到了当前线程实例对象的 threadLocals 属性里面。这样一来线程之间自然就是互相独立的啦。

再看看 get() 方法:

public T get() {
   Thread t = Thread.currentThread();
   ThreadLocalMap map = getMap(t);
   if (map != null) {
       ThreadLocalMap.Entry e = map.getEntry(this);
       if (e != null) {
           @SuppressWarnings("unchecked")
           T result = (T)e.value;
           return result;
      }
  }
   return setInitialValue();
}

private T setInitialValue() {
   T value = initialValue();
   Thread t = Thread.currentThread();
   ThreadLocalMap map = getMap(t);
   if (map != null)
       map.set(this, value);
   else
       createMap(t, value);
   return value;
}

ThreadLocal 的 get() 方法其实和 set() 方法逻辑很相似,先从当前线程的 threadLocals 属性中取,如果该属性为 null,那么就初始化。

当线程结束时,会调用当前线程实例的 exit() 方法,将 threadLocals 设置为 null,以便垃圾回收器将其回收掉。

// THread 类中的方法
private void exit() {
   // ...
   threadLocals = null;
   // ...
}

最后,有一点需要格外注意:用完 ThreadLocal 一定要记得手动调用 remove() 方法,否则可能会产生脏数据甚至产生内存泄漏。

为啥呢?上面不是说线程结束时,会将 threadLocals 置为 null 吗?

是的,线程结束时,确实会做清理工作。

但,如果线程一直不结束呢?如果线程会被复用呢?比如使用了线程池。

所以,使用 ThreadLocal 一定要手动 remove()。​

补充:下面看下ThreadLocal 是什么?有哪些使用场景?

ThreadLocal是一个本地线程副本变量工具类,主要用于将私有线程和该线程存放的副本对象做一个映射,各个线程之间的变量互不干扰。

说人话就是,ThreadLocal在每个线程都创建副本,每个线程可以访问自己的副本,线程之间相互不影响。

使用场景:

多线程环境中为每一个jdbc分配一个Connection连接,使用ThreadLocal去保存连接,这样就保证了每个线程在自己的连接上操作数据库,不会出现A线程关闭B的Connnection操作

Web中的session管理时,可以使用ThreadLocal记录每个线程的Session,这样保证每个线程都可以获取自己的session

解决线程安全问题,对于需要进行线程隔离的变量,可以使用ThreadLocal存储,确保线程隔离

总结:

ThreadLocal可以简单看作一个map,每个线程保存一个map,这个map只能存储一组数据,key为线程id, value就是要存的值

一个ThreadLocal只能存储一个变量,如果要存多个就创建多个ThreadLocal对象。

到此这篇关于为什么 ThreadLocal 可以做到线程隔离?的文章就介绍到这了,更多相关ThreadLocal 线程隔离内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!

相关文章

  • 创建SpringBoot工程并集成Mybatis的方法

    创建SpringBoot工程并集成Mybatis的方法

    这篇文章主要介绍了创建SpringBoot工程并集成Mybatis,需要的朋友可以参考下
    2018-06-06
  • Spring的事务控制实现方法

    Spring的事务控制实现方法

    这篇文章主要为大家详细介绍了Spring的事务控制实现方法,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-07-07
  • Java利用位运算实现乘法运算详解

    Java利用位运算实现乘法运算详解

    这篇文章主要为大家详细介绍了Java如何用位运算实现乘法运算,在实现乘法时要用位运算实现,并且不能出现加减乘除任何符号,感兴趣的可以了解一下
    2023-04-04
  • Java实现FTP上传与下载功能

    Java实现FTP上传与下载功能

    这篇文章主要为大家详细介绍了Java实现FTP上传与下载功能,文中示例代码介绍的非常详细,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2022-02-02
  • 史上最全的IDEA快捷键总结

    史上最全的IDEA快捷键总结

    这篇文章主要介绍了史上最全的IDEA快捷键总结,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧
    2020-01-01
  • 如何实现java8 list按照元素的某个字段去重

    如何实现java8 list按照元素的某个字段去重

    这篇文章主要介绍了如何实现java8 list按照元素的某个字段去重,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,,需要的朋友可以参考下
    2019-06-06
  • maven搭建spring项目(图文教程)

    maven搭建spring项目(图文教程)

    下面小编就为大家带来一篇maven搭建spring项目(图文教程)。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2017-06-06
  • springcloud整合seata的实现代码

    springcloud整合seata的实现代码

    这篇文章主要介绍了springcloud整合seata的实现方法,整合步骤通过引入spring-cloud-starter-alibaba-seata jar包,文中结合实例代码给大家介绍的非常详细,需要的朋友可以参考下
    2022-05-05
  • JVM调试命令与调试工具详解

    JVM调试命令与调试工具详解

    JVM statistics Monitoring,用于监视虚拟机运行时状态信息的命令,它可以显示出虚拟机进程中的类装载、内存、垃圾收集、JIT编译等运行数据,这篇文章主要介绍了JVM调试命令与调试工具,需要的朋友可以参考下
    2023-10-10
  • 浅谈java Collection中的排序问题

    浅谈java Collection中的排序问题

    下面小编就为大家带来一篇浅谈java Collection中的排序问题。小编觉得挺不错的,现在就分享给大家,也给大家做个参考。一起跟随小编过来看看吧
    2016-12-12

最新评论