ThreadLocal 应用原理解析与常见问题

ThreadLocal是大家比较常用到的,在多线程下存储线程相关数据十分合适。可是很多时候我们并没有深入去了解它的原理。

首选提出几个问题,稍后再针对这些问题一一解答。

  1. 提到ThreadLocal,大家常说ThreadLocal是弱引用,那么ThreadLocal究竟是如何实现弱引用的呢?
  2. ThreadLocal是如何做到可以当做线程局部变量的呢?
  3. 大家创建ThreadLocal变量时,为什么都要用static修饰?
  4. 大家争论不止的ThreadLocal内存泄漏是什么鬼?

进入正题,先简单了解下ThreadLocal 和 Thread,ThreadLocal的类结构:

可以看到,ThreadLocal有个内部类ThreadLocalMap,ThreadLocalMap又有个内部类Entry。

Thread类有这样一段源码:

class Thread implements Runnable {

    ...省略若干代码

    /* ThreadLocal values pertaining to this thread. This map is maintained
     * by the ThreadLocal class. */
    ThreadLocal.ThreadLocalMap threadLocals = null;

    /*
     * InheritableThreadLocal values pertaining to this thread. This map is
     * maintained by the InheritableThreadLocal class.
     */
    ThreadLocal.ThreadLocalMap inheritableThreadLocals = null;

通过Thread源码我们了解到,Thread持有的对象是ThreadLocal的ThreadLocalMap,这一点特别重要,线程相关数据都是通过ThreadLocalMap存储的,而不是ThreadLocal。

此时我们得到的结论如下图所示:

Thread的threadLocals属性直接关联的ThreadLocal.ThreadLocalMap,和ThreadLocal没有丝毫关系

那么ThreadLocal是做什么的呢?其实ThreadLocal可以看做线程操作ThreadLocalMap的工具类,ThreadLocal暴漏了两个公共方法get()和set(T)用来获取和设置ThreadLocalMap。

了解一下set方法源码:

1     public void set(T value) {
2         Thread t = Thread.currentThread();
3         ThreadLocalMap map = getMap(t);
4         if (map != null)
5             map.set(this, value);
6         else
7             createMap(t, value);
8     }

从源码第五行我们可以得到两个重要的信息:

  • 获取ThreadLocalMap时,使用了当前Thread对象 t 作为参数。

    getMap(t)方法的实现很简单:

      

    ThreadLocalMap getMap(Thread t) {
        return t.threadLocals;
    }

    它返回的是Thread的 threadLocals 属性,代码上验证了:“线程局部变量”是存储在Thread对象的threadLocals属性中,和 ThreadLocal 本身没什么关系。ThreadLocal 可以当做访问的工具类。

    这里我们第2个问题:ThreadLocal是如何做到可以当做线程局部变量的已经有答案啦,所有的操作其实都是对Thread 下 threadLocals 的操作,所以跨线程操作也不会产生问题的,因为getMap()永远返回当前线程的threadLocals属性。

  • ThreadLocalMap是一个类似Map键值对的结构,此处传入的key是固定值this,这个this不是线程对象哟,是当前的ThreadLocal对象,value即我们传入的参数。

    小伙伴们是不是很奇怪为什么要把this当做key呢?这就扯到我们文章开头的第一个问题了:弱引用!

    跟进map.set(this, value);源码一看究竟:

 1         private void set(ThreadLocal<?> key, Object value) {
 2
 3             Entry[] tab = table;
 4             int len = tab.length;
 5             int i = key.threadLocalHashCode & (len-1);
 6
 7             for (Entry e = tab[i];
 8                  e != null;
 9                  e = tab[i = nextIndex(i, len)]) {
10                 ThreadLocal<?> k = e.get();
11
12                 if (k == key) {
13                     e.value = value;
14                     return;
15                 }
16
17                 if (k == null) {
18                     replaceStaleEntry(key, value, i);
19                     return;
20                 }
21             }
22
23             tab[i] = new Entry(key, value);
24             int sz = ++size;
25             if (!cleanSomeSlots(i, sz) && sz >= threshold)
26                 rehash();
27         }

  查看23行Entry的构造方法:

1         static class Entry extends WeakReference<ThreadLocal<?>> {
2             /** The value associated with this ThreadLocal. */
3             Object value;
4
5             Entry(ThreadLocal<?> k, Object v) {
6                 super(k);
7                 value = v;
8             }
9         }

    Entry只有一个构造方法,该构造方法接受两个参数k和v,k就是当前ThreadLocal对象,v是我要存储的线程相关数据。通过上述代码标红部分我们可以了解到对 k 使用了弱引用,但是value不是,value是强引用。至此第一个问题已经真相了,大家所说的ThreadLocal弱引用其实是ThreadLocalMap和ThreadLocal是弱引用关系。

    为什么要这么设计呢?

    首选我们整理下当前引用关系如下图:

    

    value一般是线程相关的数据,线程回收后value -> null,强引用就不存在了。但是ThreadLocal对象的生命周期不一定和线程相关,可能线程消亡后ThreadLocal对象仍然被其它线程引用,如果使用强引用的话,ThreadLocalMap对象就无法释放内存,发生内存泄漏的情况。使用弱引用就安全的多了,发生gc时弱引用指向的对象会被内存回收。

问题1和2已经在上文中提到,继续看问题3,创建ThreadLocal对象时为什么要用static修饰呢?

  个人感觉是基于两点的考虑:

  • 第一是避免重复创建ThreadLocal对象,使用同一个ThreadLocal对象和多个ThreadLocal对象对代码本身没什么影响,实在没必要重复创建多个对象。
  • 延长ThreadLocal的生命周期,方便使用。

  网上很多地方把static和内存泄漏联系起来,原谅我没看出来这两者有什么关系。

    

最后来到第四个问题,也大家都关心的内存泄漏啦,。

  通过上面的引用关系图我们了解到存在两个引用关系,分别是key的弱引用和value的强引用。弱引用首选不可能导致内存泄漏,因为gc发生时弱引用的对象就有可能被回收了。所以。。。内存泄漏发生在强引用这个关系上。

  因为现在线程切换的开销比较大,大家现在普遍使用线程池的技术去避免线程的频繁创建。在线程池中,线程不会消亡,会被重复使用,so。。。。上边的强引用得不到释放了,内存泄漏就这样发生了。其实我在JDK8上看到的是java已经为此做了一些工作了,比如执行下次set操作时遍历key是null的Entry对象并释放value的引用。虽然java本身做了一些工作,仍然强烈建议使用完ThreadLocal执行remove方法主动消除引用关系。

  文章结束了,如有纰漏,欢迎指出。

原文地址:https://www.cnblogs.com/dreamowneryong/p/11697469.html

时间: 2024-11-15 11:44:42

ThreadLocal 应用原理解析与常见问题的相关文章

Java并发编程:ThreadLocal的使用以及实现原理解析

前言 前面的文章里,我们学习了有关锁的使用,锁的机制是保证同一时刻只能有一个线程访问临界区的资源,也就是通过控制资源的手段来保证线程安全,这固然是一种有效的手段,但程序的运行效率也因此大大降低.那么,有没有更好的方式呢?答案是有的,既然锁是严格控制资源的方式来保证线程安全,那我们可以反其道而行之,增加更多资源,保证每个线程都能得到所需对象,各自为营,互不影响,从而达到线程安全的目的,而ThreadLocal便是采用这样的思路. ThreadLocal实例 ThreadLocal翻译成中文的话大概

Java类加载原理解析

1       基本信息 摘要: 每个java开发人员对java.lang.ClassNotFoundExcetpion这个异常肯定都不陌生,这背后就涉及到了java技术体系中的类加载.Java的类加载机制是java技术体系中比较核心的部分,虽然和大部分开发人员直接打交道不多,但是对其背后的机理有一定理解有助于排查程序中出现的类加载失败等技术问题,对理解java虚拟机的连接模型和java语言的动态性都有很大帮助. 由于关于java类加载的内容较多,所以打算分三篇文章简述一下: 第一篇:java类

Jetty的工作原理解析以及与Tomcat的比较

Jetty 的基本架构 Jetty 目前的是一个比较被看好的 Servlet 引擎,它的架构比较简单,也是一个可扩展性和非常灵活的应用服务器,它有一个基本数据模型,这个数据模型就是 Handler,所有可以被扩展的组件都可以作为一个 Handler,添加到 Server 中,Jetty 就是帮你管理这些 Handler. Jetty 的基本架构 下图是 Jetty 的基本架构图,整个 Jetty 的核心组件由 Server 和 Connector 两个组件构成,整个 Server 组件是基于 H

MyBatis框架中Mapper映射配置的使用及原理解析(七) MapperProxy,MapperProxyFactory

从上文<MyBatis框架中Mapper映射配置的使用及原理解析(六) MapperRegistry> 中我们知道DefaultSqlSession的getMapper方法,最后是通过MapperRegistry对象获得Mapper实例: public <T> T getMapper(Class<T> type, SqlSession sqlSession) { final MapperProxyFactory<T> mapperProxyFactory =

Android中微信抢红包插件原理解析和开发实现

一.前言 自从去年中微信添加抢红包的功能,微信的电商之旅算是正式开始正式火爆起来.但是作为Android开发者来说,我们在抢红包的同时意识到了很多问题,就是手动去抢红包的速度慢了,当然这些有很多原因导致了.或许是网络的原因,而且这个也是最大的原因.但是其他的不可忽略的因素也是要考虑到进去的,比如在手机充电锁屏的时候,我们并不知道有人已经开始发红包了,那么这时候也是让我们丧失了一大批红包的原因.那么关于网络的问题,我们开发者可能用相关技术无法解决(当然在Google和Facebook看来的话,他们

MyBatis框架中Mapper映射配置的使用及原理解析(三) 配置篇 Configuration

从上文<MyBatis框架中Mapper映射配置的使用及原理解析(二) 配置篇 SqlSessionFactoryBuilder,XMLConfigBuilder> 我们知道XMLConfigBuilder调用parse()方法解析Mybatis配置文件,生成Configuration对象. Configuration类主要是用来存储对Mybatis的配置文件及mapper文件解析后的数据,Configuration对象会贯穿整个Mybatis的执行流程,为Mybatis的执行过程提供必要的配

MyBatis框架中Mapper映射配置的使用及原理解析(二) 配置篇 SqlSessionFactoryBuilder,XMLConfigBuilder

在 <MyBatis框架中Mapper映射配置的使用及原理解析(一) 配置与使用> 的demo中看到了SessionFactory的创建过程: SqlSessionFactory sessionFactory = null; String resource = "mybatisConfig.xml"; try { sessionFactory = new SqlSessionFactoryBuilder().build(Resources .getResourceAsRea

Spring Boot启动原理解析

Spring Boot启动原理解析http://www.cnblogs.com/moonandstar08/p/6550758.html 前言 前面几章我们见识了SpringBoot为我们做的自动配置,确实方便快捷,但是对于新手来说,如果不大懂SpringBoot内部启动原理,以后难免会吃亏.所以这次博主就跟你们一起一步步揭开SpringBoot的神秘面纱,让它不在神秘. 正文 我们开发任何一个Spring Boot项目,都会用到如下的启动类 从上面代码可以看出,Annotation定义(@Sp

游戏外挂原理解析与制作 - [内存数值修改类 篇一]

本章旨在讲解外挂实现原理,未深入涉及至代码层面.希望能与对这方面感兴趣的朋友多多交流,毕竟理论是死的,套路是固定的,只有破解经验是花大量时间和心血积累的. 对于单机游戏而言,游戏中绝大部分的参数(比如血.蓝.能量亦或是金币)都存储在计算机的堆栈中,一些类似剧情进度的则加密后写入本地的自定义配置文件中: 对于页游.网游和手游,虽然服务器保存了大量的重要的参数,但由于客户端不可避免的需要进行大量的计算和资源的加载,本地内存种必定存有部分的临时变量,通过判断这些变量的变化规律和函数的破密寻到利于自身的