跳至主要內容

ThreadLocal

Jin大约 18 分钟

ThreadLocal

1、ThreadLocal简介

1.1、大厂面试题

  • ThreadLocal中ThreadLocalMap的数据结构和关系？
  • ThreadLocal的key是弱引用，这是为什么？
  • ThreadLocal内存泄漏问题你知道吗？
  • ThreadLocal中最后为什么要加remove方法？
Threadopen in new window线程是程序中执行的线程。
ThreadGroupopen in new window线程组表示一组线程。
ThreadLocalopen in new window该类提供线程局部变量。
Throwableopen in new windowThrowable类是Java语言中所有错误和异常的超类。

1.2、概念

​ ThreadLocal提供线程局部变量。这些变量与正常的变量不同，因为每一个线程在访问ThreadLocal实例的时候（通过其get或set方法）都有自己的、独立初始化的变量副本。 ThreadLocal实例通常是类中的私有静态字段，使用它的目的是希望将状态（例如，用户ID或事务ID）与线程关联起来。

1.3、作用

  • 实现每一个线程都有自己专属的本地变量副本(自己用自己的变量不麻烦别人，不和其他人共享，人人有份，人各一份)，
  • 主要解决了让每个线程绑定自己的值，通过使用get()和set()方法，获取默认值或将其值更改为当前线程所存的副本的值从而避免了线程安全问题。

1.4、API

变量和类型方法描述
Tget()返回当前线程的此线程局部变量副本中的值。
protected TinitialValue()返回此线程局部变量的当前线程的“初始值”。
voidremove()删除此线程局部变量的当前线程值。
voidset(T value)将此线程局部变量的当前线程副本设置为指定值。
static <S> ThreadLocal<S>withInitial(Supplier<? extends S> supplier)创建一个线程局部变量。

1.5、案例

  • 3个销售卖房子，集团高层只关心销售总量的准确统计数，按照总销售额统计，方便集团公司发奖金
class MovieTicket {
    int number = 0;

    public synchronized void saleTicket() {
        if (number > 0) {
            System.out.println(Thread.currentThread().getName() + "\t" + "号售票员卖出第： " + (number++));
        } else {
            System.out.println("--------卖完了");
        }
    }
}

    @Test
    public void demo01() {
        MovieTicket movieTicket = new MovieTicket();

        for (int i = 1; i <= 3; i++) {
            new Thread(() -> {
                for (int j = 0; j < 20; j++) {
                    movieTicket.saleTicket();
                }
            }, String.valueOf(i)).start();
        }
        try {
            TimeUnit.MILLISECONDS.sleep(300);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println(Thread.currentThread().getName() + "\t" + "共计卖出多少套：" + movieTicket.number);//main	共计卖出多少套：0
    }

需求变化了

  • 希望各自分灶吃饭，各凭销售本事提成，按照出单数各自统计
    • 比如某房产中介销售都有自己的销售额指标，自己专属于自己的，不和别人掺和

正好对应了前面的【每个线程都有自己专属的本地变量副本】

上述需求该如何处理？

  • 利用ThreadLocal

  • 先初始化，给个0值

  • 利用set get方法

  • ------注意，也要调用remove(） 接口，不然容易导致内存泄漏

  • 阿里巴巴手册：必须回收自定义的ThreadLocal变量，尤其在线程池场景下，线程经常会被复用，如果不清理自定义的ThreadLocal变量，可能会影像后序业务逻辑和造成内存泄露等问题。尽量在代理中使用try-finally块进行回收。

class House {
    //两个都是创建一个线程局部变量并返回初始值
    /**
     * 一个比较老式的写法（这个阿里巴巴手册里也也有），initialValue()这个api已经淘汰了
     */
    ThreadLocal<Integer> saleVolume = new ThreadLocal<Integer>() {
        @Override
        protected Integer initialValue() {
            return 0;
        }
    };
    //java8之后带来的新写法
    ThreadLocal<Integer> threadLocal = ThreadLocal.withInitial(() -> 0);

    public void saleHouse() {
        Integer value = threadLocal.get();
        value++;
        threadLocal.set(value);
    }
}

@Test
    public void demo02() {
        House house = new House();

        new Thread(() -> {
            try {
                for (int i = 1; i <= 3; i++) {
                    house.saleHouse();
                }
                System.out.println(Thread.currentThread().getName() + "\t" + "---" + house.threadLocal.get());
            } finally {
                house.threadLocal.remove();//如果不清理自定义的 ThreadLocal 变量，可能会影响后续业务逻辑和造成内存泄露等问题
            }
        }, "t1").start();

        new Thread(() -> {
            try {
                for (int i = 1; i <= 2; i++) {
                    house.saleHouse();
                }
                System.out.println(Thread.currentThread().getName() + "\t" + "---" + house.threadLocal.get());
            } finally {
                house.threadLocal.remove();
            }
        }, "t2").start();

        new Thread(() -> {
            try {
                for (int i = 1; i <= 5; i++) {
                    house.saleHouse();
                }
                System.out.println(Thread.currentThread().getName() + "\t" + "---" + house.threadLocal.get());
            } finally {
                house.threadLocal.remove();
            }
        }, "t3").start();


        System.out.println(Thread.currentThread().getName() + "\t" + "---" + house.threadLocal.get());
    }

总结：

  • 因为每个 Thread 内有自己的实例副本且该副本只由当前线程自己使用
  • 既然其它 Thread 不可访问，那就不存在多线程间共享的问题。
  • 统一设置初始值，但是每个线程对这个值的修改都是各自线程互相独立的

2、阿里ThreadLocal规范

3.1、非线程安全的SimpleDateFormat

image-20220727134802822
image-20220727134802822

官网文档open in new window

image-20220727135656418
image-20220727135656418

SimpleDateFormat中的日期格式不是同步的。推荐（建议）为每个线程创建独立的格式实例。如果多个线程同时访问一个格式，则它必须保持外部同步。

问题复现

    public static final SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");


    public static Date parseDate(String stringDate) throws Exception {
        return sdf.parse(stringDate);
    }

    /**
     * 模拟并发环境下使用SimpleDateFormat的parse方法将字符串转换成Date对象
     */
    @Test
    public void demo1() {
        for (int i = 1; i <= 30; i++) {
            new Thread(() -> {
                try {
                    System.out.println(DateUtils.parseDate("2022-11-11 11:11:11"));
                } catch (Exception e) {
                    e.printStackTrace();
                }
            }, String.valueOf(i)).start();
        }
    }

执行结果：

Fri Nov 11 11:11:11 CST 2022
Fri Nov 11 11:11:11 CST 2022
Fri Nov 11 11:11:00 CST 2022
Fri Nov 11 11:11:11 CST 2022
java.lang.NumberFormatException: For input string: ""
	at java.lang.NumberFormatException.forInputString(NumberFormatException.java:65)
	at java.lang.Long.parseLong(Long.java:601)
	at java.lang.Long.parseLong(Long.java:631)
	at java.text.DigitList.getLong(DigitList.java:195)
	at java.text.DecimalFormat.parse(DecimalFormat.java:2084)
	at java.text.SimpleDateFormat.subParse(SimpleDateFormat.java:1869)
	at java.text.SimpleDateFormat.parse(SimpleDateFormat.java:1514)
	at java.text.DateFormat.parse(DateFormat.java:364)
	at com.jin.juc.threadlocal.DateUtils.parseDate(DateUtils.java:19)
	at com.jin.juc.threadlocal.DateUtils.lambda$demo1$0(DateUtils.java:30)
	at java.lang.Thread.run(Thread.java:748)
Fri Nov 11 11:11:11 CST 2022
Fri Nov 11 11:11:11 CST 2022
java.lang.NumberFormatException: For input string: ".111E.111E22"
	at sun.misc.FloatingDecimal.readJavaFormatString(FloatingDecimal.java:2043)
	at sun.misc.FloatingDecimal.parseDouble(FloatingDecimal.java:110)
	at java.lang.Double.parseDouble(Double.java:538)
	at java.text.DigitList.getDouble(DigitList.java:169)
	at java.text.DecimalFormat.parse(DecimalFormat.java:2089)
	at java.text.SimpleDateFormat.subParse(SimpleDateFormat.java:2162)
Fri Nov 11 11:11:11 CST 2022

源码分析结论

​ SimpleDateFormat类内部有一个Calendar对象引用,它用来储存和这个SimpleDateFormat相关的日期信息,例如sdf.parse(dateStr),sdf.format(date) 诸如此类的方法参数传入的日期相关String,Date等等, 都是交由Calendar引用来储存的.这样就会导致一个问题如果你的SimpleDateFormat是个static的, 那么多个thread 之间就会共享这个SimpleDateFormat, 同时也是共享这个Calendar引用。

image-20220727140734284
image-20220727140734284
image-20220727140908626
image-20220727140908626

解决方案1

  • 将SimpleDateFormat定义成局部变量。
    • 缺点：每调用一次方法就会创建一个SimpleDateFormat对象，方法结束又要作为垃圾回收。
    public static Date parseDate(String stringDate) throws Exception {
        return sdf.parse(stringDate);
    }

    @Test
    public void demo2() {
        for (int i = 1; i <= 30; i++) {
            new Thread(() -> {

                try {
                    SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
                    System.out.println(simpleDateFormat.parse("2020-11-11 11:11:11"));
                    simpleDateFormat = null;
                } catch (Exception e) {
                    e.printStackTrace();
                }

            }, String.valueOf(i)).start();
        }
    }

解决方案2

  • ThreadLocal，也叫做线程本地变量或者线程本地存储
private static final ThreadLocal<SimpleDateFormat> sdf_threadLocal =
        ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));

/**
 * ThreadLocal可以确保每个线程都可以得到各自单独的一个SimpleDateFormat的对象，那么自然也就不存在竞争问题了。
 *
 * @param stringDate
 * @return
 * @throws Exception
 */
public static Date parseDateTL(String stringDate) throws Exception {
    return sdf_threadLocal.get().parse(stringDate);
}

@Test
public void demo3() {
    for (int i = 1; i <= 30; i++) {
        new Thread(() -> {
            try {
                Date date = DateUtils.parseDateTL("2022-11-11 11:11:11");
                System.out.println(date);
            } catch (Exception e) {
                e.printStackTrace();
            }
         	sdf_threadLocal.remove();
        }, String.valueOf(i)).start();
    }
}

解决方案3

  1. 加锁
  2. 使用第三方时间库

自定义工具类

    //2   ThreadLocal可以确保每个线程都可以得到各自单独的一个SimpleDateFormat的对象，那么自然也就不存在竞争问题了。
    public static final ThreadLocal<SimpleDateFormat> SIMPLE_DATE_FORMAT_THREAD_LOCAL = ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"));

    public static String format(Date date) {
        return SIMPLE_DATE_FORMAT_THREAD_LOCAL.get().format(date);
    }

    public static Date parse(String datetime) throws ParseException {
        return SIMPLE_DATE_FORMAT_THREAD_LOCAL.get().parse(datetime);
    }

3、ThreadLocal源码分析

Thread，ThreadLocal，ThreadLocalMap 关系

  • 根据官方API，Thread是程序中执行的线程；ThreadLocal类提供线程局部变量。
  • 先打开Thread.java类，发现每个Thread类里面有一个ThreadLocal类
image-20220727142923824
image-20220727142923824
  • 而ThreadLocalMap是ThreadLocal的一个静态内部类
image-20220727143020307
image-20220727143020307
  • 三者总概括
image-20220727143100777
image-20220727143100777
  • threadLocalMap实际上就是一个以threadLocal实例为key，任意对象为value的Entry对象。
  • 当我们为threadLocal变量赋值，实际上就是以当前threadLocal实例为key，值为value的Entry往这个threadLocalMap中存放
img
img

总结

ThreadLocalMap从字面上就可以看出这是一个保存ThreadLocal对象的map(其实是以ThreadLocal为Key)，不过是经过了两层包装的ThreadLocal对象：

image-20220727143421561
image-20220727143421561
  • JVM内部维护了一个线程版的Map<Thread,T>(通过ThreadLocal对象的set方法，结果把ThreadLocal对象自己当做key，放进了ThreadLoalMap中),每个线程要用到这个T的时候，用当前的线程去Map里面获取，通过这样让每个线程都拥有了自己独立的变量，
  • 人手一份，竞争条件被彻底消除，在并发模式下是绝对安全的变量。

4、ThreadLocal内存泄露问题（重点）

4.1、从阿里面试题开始讲起

image-20220727143721393
image-20220727143721393
  • 看着阿里规范，引出三个问题
  1. 什么是内存泄露?
  2. 为什么要用弱引用？
  3. 不用如何？

4.2、什么是内存泄露

  • 不再会被使用的对象或者变量占用的内存不能被回收，就是内存泄露。

4.3、为什么会出现内存泄露

  • 再回首ThreadLocalMap
image-20220727144552021
image-20220727144552021
image-20220727144821690
image-20220727144821690
  • ThreadLocalMap从字面上就可以看出这是一个保存ThreadlLocal对象的map(以ThreadLocal为Key，不过是经过了两层包装的 ThreadLocal对象：
    • （1）第一层包装是使用 WeakReference<ThreadLocal<?>> 将ThreadLocal对象变成一个弱引用的对象。
    • （2）第二层包裝是定义了一个专门的类 Entry 来扩展 WeakReference<ThreadLocals?>>。

强引用、软引用、弱引用、虚引用分别是什么？

  • Java技术允许使用finalize()方法在垃圾收集器将对象从内存中清除出去之前做必要的清理工作。

  • 官方API:finalize()的通常目的是在对象被不可撤销地丢弃之前执行清理操作。

  • (我自己理解，某个对象被干掉前还会调用finalize()清理一下）

  • Reference是强引用

  • SoftReference是软引用

  • WeakReference是弱引用

  • PhantomReference是虚引用

整体架构
image-20220727144937536
image-20220727144937536

Java 技术允许使用 finalize() 方法在垃圾收集器将对象从内存中清除出去之前做必要的清理工作。

image-20220727145105613
image-20220727145105613

新建一个带finalize()方法的对象ReferenceDemo

public class ReferenceDemo {

    //一般开发中不用调用这个方法，本次只是为了讲课演示
    @Override
    protected void finalize() throws Throwable {
        System.out.println(Thread.currentThread().getName() + "\t" + "---finalize method invoked....");
    }
}
强引用（默认支持模式）

  • 当内存不足，JVM开始垃圾回收，对于强引用的对象，就算是出现了OOM也不会对该对象进行回收，死都不收。

  • 强引用是我们最常见的普通对象引用，只要还有强引用指向一个对象，就能表明对象还“活着”，垃圾收集器不会碰这种对象。在 Java 中最常见的就是强引用，把一个对象赋给一个引用变量，这个引用变量就是一个强引用。当一个对象被强引用变量引用时，它处于可达状态，它是不可能被垃圾回收机制回收的，即使该对象以后永远都不会被用到JVM也不会回收。因此强引用是造成Java内存泄漏的主要原因之一。

  • 对于一个普通的对象，如果没有其他的引用关系，只要超过了引用的作用域或者显式地将相应（强）引用赋值为 null，一般认为就是可以被垃圾收集的了(当然具体回收时机还是要看垃圾收集策略)。

    //一般开发中不用调用这个方法，本次只是为了演示
    @Override
    protected void finalize() throws Throwable {
        System.out.println(Thread.currentThread().getName() + "\t" + "---finalize method invoked....");
    }

    @Test
    public void strongReference() {
        ReferenceDemo myObject = new ReferenceDemo();
        System.out.println("-----gc before: " + myObject);

        myObject = null;//new 一个对象是一个强引用，如果不把他指为null，垃圾回收回收不了他
        System.gc();// myObject未置为null 之前，不会执行 finalize() 方法，置为null之后会执行 finalize() 方法
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("-----gc after: " + myObject);
    }
//-----gc before: com.jin.juc.threadlocal.ReferenceDemo@1ee807c6
//Finalizer	---finalize method invoked....
//-----gc after: null
软引用

  • 软引用是一种相对强引用弱化了一些的引用，需要用java.lang.ref.SoftReference类来实现，可以让对象豁免一些垃圾收集。

  • 对于只有软引用的对象来说，

    • 当系统内存充足时它 不会 被回收，
    • 当系统内存不足时它 会 被回收。

  • 软引用通常用在对内存敏感的程序中，比如高速缓存就有用到软引用，内存够用的时候就保留，不够用就回收！

-Xms10m -Xmx10m
image-20220728220319690
image-20220728220319690

案列代码

@Override
protected void finalize() throws Throwable {
    System.out.println(Thread.currentThread().getName() + "\t" + "---finalize method invoked....");
}

public static void main(String[] args) {
        SoftReference<ReferenceDemo> softReference = new SoftReference<>(new ReferenceDemo());
        System.gc();
        try {
            TimeUnit.SECONDS.sleep(1);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("-------gc after内存够用" + softReference.get());

        try {
            byte[] bytes = new byte[20 * 1024 * 1024];
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            System.out.println("---------gc after内存不够" + softReference.get());
        }
    }
//-------gc after内存够用com.jin.juc.threadlocal.ReferenceDemo@377dca04
//---------gc after内存不够null
//Finalizer    ---finalize method invoked....
//Exception in thread "main" java.lang.OutOfMemoryError: Java heap space
//at com.jin.juc.threadlocal.ReferenceDemo.main(ReferenceDemo.java:74)
image-20220728222425524
image-20220728222425524
弱引用
  • 弱引用需要用java.lang.ref.WeakReference类来实现，它比软引用的生存期更短，
  • 对于只有弱引用的对象来说，只要垃圾回收机制一运行，不管JVM的内存空间是否足够，都会回收该对象占用的内存。
/**
 * 弱引用
 */
@Override
protected void finalize() throws Throwable {
    System.out.println(Thread.currentThread().getName() + "\t" + "---finalize method invoked....");
}

@Test
public void weakReference() {
    WeakReference<ReferenceDemo> weakReference = new WeakReference<>(new ReferenceDemo());
    System.out.println("-----gc before 内存够用 " + weakReference.get());

    System.gc();
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    //暂停几秒钟线程
    System.out.println("----gc after内存够用 " + weakReference.get());
}
//-----gc before 内存够用 com.jin.juc.threadlocal.ReferenceDemo@5cdd8682
//Finalizer	---finalize method invoked....
//----gc after内存够用 null

  • 适用场景

    • 假如有一个应用需要读取大量的本地图片:

  • 如果每次读取图片都从硬盘读取则会严重影响性能,

  • 如果一次性全部加载到内存中又可能造成内存溢出。

此时使用软引用可以解决这个问题。

设计思路是：用一个HashMap来保存图片的路径和相应图片对象关联的软引用之间的映射关系，在内存不足时，JVM会自动回收这些缓存图片对象所占用的空间，从而有效地避免了OOM的问题。

Map<String, SoftReference<Bitmap>> imageCache = new HashMap<String, SoftReference<Bitmap>>();
虚引用

  • 定义 虚引用必须和引用队列 (ReferenceQueue)联合使用 虚引用需要java.lang.ret.PhantomReterence类来实现,顾名思义， 就是形同虚设，与其他几种引用都不同，虚引用并不会决定对象的生命周期。如果一个对象仅持有院引用，那么它就和没有任何引用一样，在任何时候都可能被垃圾回收器回收，它不能单独使用也不能通过它访问对象，虚引用必须和引用队列(ReferenceQueue)联合使用。

  • PhantomReference的get方法总是返回null 虚引用的主要作用是跟踪对象被垃圾回收的状态。仅仅是提供了一和确保对象被 finalize以后，做某些事情的通知机制。 PhantomReference的get方法总是返回null，因此无法访问对应的引用对象。

  • **处理监控通知使用

    **换句话说，设置虚引用关联对象的唯一目的，就是在这个对象被收集器回收的时候收到一个系统通知或者后续添加进一步的处理，用来实现比finalize机制更灵活的回收操作。

构造方法

构造器描述
ReferenceQueue()构造一个新的引用对象队列。
  • 引用队列

我被回收前需要被引用队列保存下

image-20220728223757825
image-20220728223757825
  • case

记得先给设置成-Xms10m -Xmx10m

public class EmptyReference {

    @Override
    protected void finalize() throws Throwable {
        System.out.println(Thread.currentThread().getName() + "\t" + "---finalize method invoked....");
    }

    public static void main(String[] args) {
        EmptyReference myObject = new EmptyReference();
        ReferenceQueue<EmptyReference> referenceQueue = new ReferenceQueue<>();
        PhantomReference<EmptyReference> phantomReference = new PhantomReference<>(myObject, referenceQueue);
        // System.out.println(phantomReference.get());//这里就是个null--虚引用的get()就是null

        List<byte[]> list = new ArrayList<>();

        new Thread(() -> {
            while (true)//模拟一个无限循环
            {
                list.add(new byte[1 * 1024 * 1024]);
                try {
                    TimeUnit.MILLISECONDS.sleep(600);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
                System.out.println(phantomReference.get());
            }
        }, "t1").start();

        new Thread(() -> {
            while (true) {
                Reference<? extends EmptyReference> reference = referenceQueue.poll();
                if (reference != null) {
                    System.out.println("有虚对象加入队列了");
                }
            }
        }, "t2").start();
    }
}

打印结果

null
null
null
null
null
null
Exception in thread "t1" java.lang.OutOfMemoryError: Java heap space
	at com.jin.juc.threadlocal.EmptyReference.lambda$main$0(EmptyReference.java:34)
	at com.jin.juc.threadlocal.EmptyReference$$Lambda$1/326549596.run(Unknown Source)
	at java.lang.Thread.run(Thread.java:748)
Finalizer	---finalize method invoked....

GCRoots和四大引用小总结

image-20220728225059807
image-20220728225059807

关系

image-20220728225124198
image-20220728225124198
image-20220728225137227
image-20220728225137227
  • 每个Thread对象维护着一个ThreadLocalMap的引用
  • ThreadLocalMap是ThreadLocal的内部类，用Entry来进行存储
  • 调用ThreadLocal的set()方法时，实际上就是往ThreadLocalMap设置值，key是ThreadLocal对象，值Value是传递进来的对象
  • 调用ThreadLocal的get()方法时，实际上就是往ThreadLocalMap获取值，key是ThreadLocal对象
  • ThreadLocal本身并不存储值，它只是自己作为一个key来让线程从ThreadLocalMap获取value，正因为这个原理，所以ThreadLocal能够实现“数据隔离”，获取当前线程的局部变量值，不受其他线程影响～

为什么要用弱引用?不用如何？

    @Test
    public void weakReference2() {
        ThreadLocal tl = new ThreadLocal<Integer>();    //line1
        tl.set(2021);                                   //line2
        tl.get();                                       //line3
        System.out.println(tl.get());//2021
    }
//        line1新建了一个ThreadLocal对象，t1 是强引用指向这个对象；
//        line2调用set()方法后新建一个Entry，通过源码可知Entry对象里的k是弱引用指向这个对象。
image-20220728225636236
image-20220728225636236

为什么源代码用弱引用？

  • 当weakReference2方法执行完毕后，栈帧销毁强引用 tl 也就没有了。但此时线程的ThreadLocalMap里某个entry的key引用还指向这个对象
  • 若这个key引用是强引用，就会导致key指向的ThreadLocal对象及v指向的对象不能被gc回收，造成内存泄漏；
  • 若这个key引用是弱引用就大概率会减少内存泄漏的问题(还有一个key为null的雷)。使用弱引用，就可以使ThreadLocal对象在方法执行完毕后顺利被回收且Entry的key引用指向为null。

此后我们调用get,set或remove方法时，就会尝试删除key为null的entry，可以释放value对象所占用的内存。

弱引用就万事大吉了吗？

  1. 当我们为threadLocal变量赋值，实际上就是当前的Entry(threadLocal实例为key，值为value)往这个threadLocalMap中存放。Entry中的key是弱引用，当threadLocal外部强引用被置为null(tl=null),那么系统 GC 的时候，根据可达性分析，这个threadLocal实例就没有任何一条链路能够引用到它，这个ThreadLocal势必会被回收，这样一来，ThreadLocalMap中就会出现key为null的Entry，就没有办法访问这些key为null的Entry的value，如果当前线程再迟迟不结束的话，这些key为null的Entry的value就会一直存在一条强引用链：Thread Ref -> Thread -> ThreaLocalMap -> Entry -> value永远无法回收，造成内存泄漏。

  2. 当然，如果当前thread运行结束，threadLocal，threadLocalMap,Entry没有引用链可达，在垃圾回收的时候都会被系统进行回收。

  3. 但在实际使用中我们有时候会用线程池去维护我们的线程，比如在Executors.newFixedThreadPool()时创建线程的时候，为了复用线程是不会结束的，所以threadLocal内存泄漏就值得我们小心

key为null的entry，原理解析
image-20220728230855256
image-20220728230855256

  • ThreadLocalMap使用ThreadLocal的弱引用作为key，如果一个ThreadLocal没有外部强引用引用他，那么系统gc的时候，这个ThreadLocal势必会被回收，这样一来，ThreadLocalMap中就会出现key为null的Entry，就没有办法访问这些key为null的Entry的value，如果当前线程再迟迟不结束的话(比如正好用在线程池)，这些key为null的Entry的value就会一直存在一条强引用链。

  • 虽然弱引用，保证了key指向的ThreadLocal对象能被及时回收，但是v指向的value对象是需要ThreadLocalMap调用get、set时发现key为null时才会去回收整个entry、value，因此弱引用不能100%保证内存不泄露。我们要在不使用某个ThreadLocal对象后，手动调用remoev方法来删除它，尤其是在线程池中，不仅仅是内存泄露的问题，因为线程池中的线程是重复使用的，意味着这个线程的ThreadLocalMap对象也是重复使用的，如果我们不手动调用remove方法，那么后面的线程就有可能获取到上个线程遗留下来的value值，造成bug。

set、get方法会去检查所有键为null的Entry对象
set()
image-20220728231243782
image-20220728231243782
image-20220728231332712
image-20220728231332712
get()
image-20220728231535390
image-20220728231535390
image-20220728231553762
image-20220728231553762
image-20220728231648014
image-20220728231648014
remove()
image-20220728231824065
image-20220728231824065
结论
  • 从前面的set,getEntry,remove方法看出，在threadLocal的生命周期里，针对threadLocal存在的内存泄漏的问题，
  • 都会通过expungeStaleEntry，cleanSomeSlots,replaceStaleEntry这三个方法清理掉key为null的脏entry。

5、总结

  1. ThreadLocal 并不解决线程间共享数据的问题
  2. ThreadLocal 适用于变量在线程间隔离且在方法间共享的场景
  3. ThreadLocal 通过隐式的在不同线程内创建独立实例副本避免了实例线程安全的问题
  4. 每个线程持有一个只属于自己的专属Map并维护了ThreadLocal对象与具体实例的映射，该Map由于只被持有它的线程访问，故不存在线程安全以及锁的问题
  5. ThreadLocalMap的Entry对ThreadLocal的引用为弱引用，避免了ThreadLocal对象无法被回收的问题
  6. 都会通过expungeStaleEntry，cleanSomeSlots,replaceStaleEntry这三个方法回收键为 null 的 Entry 对象的值（即为具体实例）以及 Entry 对象本身从而防止内存泄漏，属于安全加固的方法
  7. 群雄逐鹿起纷争，人各一份天下安
贡献者: Jin
Jin 的个人经历、个人兴趣、个人感悟、个人思考
Copyright © 2025 Jin