ThreadLocal

举报
别团等shy哥发育 发表于 2023/10/18 14:41:34 2023/10/18
【摘要】 ThreadLocal ThreadLocal原理通常情况下,我们创建的变量可以被任何一个线程访问并修改。如果想实现每一个线程都有自己的专属本地变量该如何解决?JDK自带的ThreadLocal正是为了解决这个问题。ThreadLocal类主要解决的是让每个线程绑定自己的值,可以将ThreadLocal类形象的比喻成存放数据的盒子,盒子中可以存储每个线程的私有数据。如果你创建了一个Thre...

ThreadLocal

ThreadLocal原理

通常情况下,我们创建的变量可以被任何一个线程访问并修改。如果想实现每一个线程都有自己的专属本地变量该如何解决?JDK自带的ThreadLocal正是为了解决这个问题。

ThreadLocal类主要解决的是让每个线程绑定自己的值,可以将ThreadLocal类形象的比喻成存放数据的盒子,盒子中可以存储每个线程的私有数据。

如果你创建了一个ThreadLocal变量,那么访问这个变量的每个线程都会有这个变量的本地副本,它们可以使用get()set()方法来获取默认值或将其值更改为当前线程所存的副本的值,从而避免了线程安全问题。

image-20230808111612153

ThreadLocal类的set方法如下:

public void set(T value) {
    //获取当前请求的线程
    Thread t = Thread.currentThread();
    //取出 Thread 类内部的 threadLocals 变量(哈希表结构)
    ThreadLocalMap map = getMap(t);
    if (map != null)
        // 将需要存储的值放入到这个哈希表中
        map.set(this, value);
    else
        createMap(t, value);
}
ThreadLocalMap getMap(Thread t) {
    return t.threadLocals;
}

通过上面这些内容,最终的变量是放在了当前线程的ThreadLocalMap中,并不是存在ThreadLocal上,ThreadLocal可以理解为只是ThreadLocalMap的封装,传递了变量值ThreadLocal类中可以通过Thread.currentThread()获取到当前线程对象后,直接通过getMap(Thread t)可以访问到该线程的ThreadLocalMap对象。

每个Thread中都具有一个ThreadLocalMap,而ThreadLocalMap可以存储以ThreadLocal为Key,Object对象为value的键值对。

比如我们在同一个线程中声明了两个ThreadLocal对象的话,Thread内部都是使用仅有的那个ThreadLocalMap存放数据的,ThreadLocalMap的key就是ThreadLocal对象,value就是ThreadLocal对象调用set方法设置的值。

public class ThreadLocalExample implements Runnable {
    // SimpleDateFormat 不是线程安全的,所以每个线程都要有自己独立的副本
    private static final ThreadLocal<SimpleDateFormat> formatter =
            ThreadLocal.withInitial(() -> new SimpleDateFormat("yyyyMMdd HHmm"));

    @Override
    public void run() {
        System.out.println("Thread Name=" + Thread.currentThread().getName() + "default formatter=" + formatter.get().toPattern());
        try {
            Thread.sleep(new Random().nextInt(1000));
        } catch (InterruptedException e) {
            throw new RuntimeException(e);
        }
        formatter.set(new SimpleDateFormat());
        System.out.println("Thread Name=" + Thread.currentThread().getName() + "formatter=" + formatter.get().toPattern());
    }

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

        ThreadLocalExample obj = new ThreadLocalExample();
        for (int i = 0; i < 10; i++) {
            Thread t = new Thread(obj, "" + i);
            Thread.sleep(new Random().nextInt(1000));
            t.start();
        }
    }
}

image-20230815113635791

从输出中可以看出,虽然Thread-0已经改变了formatter的值,但Thread-1默认格式化值与初始化值相同,其他线程也一样。

ThreadLocal内存泄露问题怎么导致的?

ThreadLocalMap中使用的key为ThreadLocal的弱引用,而value是强引用。所以,如果ThreadLocal没有被外部强引用的情况下,在垃圾回收的时候,key会被清理掉,而value不会被清理。

这样一来,ThreadLocalMap中就会出现key为null的Entry。假如我们不做任何措施,value将永远无法被GC回收,这个时候就可能会产生内存泄漏。ThreadLocalMap实现中已经考虑了这种情况,在调用set()get()remove()方法的时候,会清理掉key为null的记录。所以使用完ThreadLocal方法后最好手动调用remove()方法。

ThreadLocalMap是ThreadLocal的静态内部类

static class ThreadLocalMap {
     static class Entry extends WeakReference<ThreadLocal<?>> {
        /** The value associated with this ThreadLocal. */
        Object value;

        Entry(ThreadLocal<?> k, Object v) {
            super(k);
            value = v;
        }
    }
    //...
}

弱引用请参考JVM部分中Java的四种引用类型

【版权声明】本文为华为云社区用户原创内容,转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息, 否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。