多线程之ThreadLocal

前言

  前几天在京东的同学给我打了个电话,聊了下家常,技术宅的我多嘴问了最近有没有学啥? 他说最近有点忙,但抽空也看了几篇博客,他说我考考你吧,我说可以啊,他问我: ThreadLocal 使用不当会导致 OOM 吗?我不假思索的回答:会。他继续追问道:为什么? 我说:因为 ThreadLocal 和操作它的线程绑定在一起,如果操作他的线程不被销毁,与之关联的 ThreadLocal 不会被 GC 。因为使用线程大多都是通过线程池来创建的,因此只要该线程活跃,就不会被线程池销毁,如果我们使用的时候忘记调用 ThreadLocal 的 remove 方法,则 ThreadLocal 保存的值无法被 GC ,如此多了就会发生 OOM 。然后他突然问了一句:为啥 Thread 里的threadLocals 属性的key是弱引用类型的? 这个之前我是不知道的。然后他给我解释了一下,这也是这篇文章的由来,好记性不如烂笔头,顺便验证一下他说的,也是对知识的巩固。

ThreadLocal

  多个线程间共享变量,可能会造成线程不安全的问题,需要加锁来实现线程安全,但是加锁会降低系统的吞吐量。
  但是有些变量就不需要线程间共享。比如数据库连接池里的连接,我们可以通过串行线程封闭技术来安全的使用连接池中的连接。一个线程A从连接池中把连接拿走,连接池保证不把该连接给别的线程,线程A同样不会把连接发布出去,用完之后返回给连接池,这样一个连接总是在一个线程中使用,不会同时被两个线程操作。线程A保存数据库连接就可以使用 ThreadLocal 来保存,可以在多个方法中获取操作数据库,用完删除即可。(生产者和消费者模式也是使用串行线程封闭技术,大家可以考虑下。)
   ThreadLocal 里的数据,其它线程无法访问,只要使用者不把数据发布出去,就可以安全操作它们。我们来看看如何一个 demo 来看下 ThreadLocal 如何使用:

public class NotThreadSafe {
    private ThreadLocal<Integer> count = ThreadLocal.withInitial(() -> Integer.MIN_VALUE);

    public void increment() {
        Integer countValue = count.get();
        countValue++;
        count.set(countValue);
    }

    public void decrement() {
        Integer countValue = count.get();
        countValue--;
        count.set(countValue);
    }

    public int getValue() {
        return count.get();
    }

    public void remove() {
        count.remove();
    }

    public static void main(String[] args) {
        NotThreadSafe notThreadSafe = new NotThreadSafe();
        new Thread(() -> {
            try {
                notThreadSafe.increment();
                System.out.println("increment i=" + notThreadSafe.getValue());
                notThreadSafe.decrement();
                System.out.println("decrement i=" + notThreadSafe.getValue());
            } finally {
                notThreadSafe.remove();
            }
        }).start();
    }
}

ThreadLocal与Thread如何绑定

  上文我说过 ThreadLocal 会与它所属的 Thread 绑定,这个绑定是什么意思呢,下面我们来看看 Thread的一处源码:

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

  注释 的译文:与此线程相关的ThreadLocal值。这个映射由ThreadLocal类维护。
  ThreadLocal.ThreadLocalMap 类型的 threadLocals 属性是保存与当前线程相关的ThreadLocal 实例,该mapThreadLocal来维护。下面我来看看 ThreadLocalMap 到底是个什么。
   先来看下官方解释:
ThreadLocalMap 是一个定制的散列映射,只适用于维护线程本地值。没有任何操作被导出到 ThreadLocal 类之外。类是包私有的,允许在类线程中声明字段。为了帮助处理非常大且长期存在的用法,哈希表条目对键使用 WeakReference 。但是,由于没有使用引用队列,所以只有在表空间不足时才会删除陈旧的条目。
   ThreadLocalMap其实就是一个散列表和HashMap差不多,只不过是定制的,只用于维护线程本地的值。为了帮助处理非常大且长期存在的用法,哈希表条目对键使用 WeakReference,现在大家比较关心这个散列表的 对应着的是什么吧?我们来看看ThreadLocalMap 中的Entry是如何定义的:

static class Entry extends WeakReference<ThreadLocal<?>> {
            /**与ThreadLocal关联的值。*/
            Object value;
            //key 就是ThreadLocal 对象本身,而值就是大家想要保存的数据如数据库连接
            Entry(ThreadLocal<?> k, Object v) {
              //将k置为弱引用
                super(k);
                value = v;
            }
        }

看了源码可知:ThreadLocalMap是以ThreadLocal 实例为健,用户要线程私有化的数据为值的散列表,并且 还是弱引用类型的。
   下面我们来讲下 ThreadLocal 如何与线程关联起来的。ThreadLocal 实例在调用 setget 的时候,会先获取当前线程的threadLocals 属性,判断 threadLocals 属性是否为空,若不为空则进行获取或者添加操作,否则会创建一个 ThreadLocalMap 实例赋给当前线程的属性 threadLocals;然后往里 put 一个键值对,当getset 方法时都是当前ThreadLocal实例,只不过是get时,值为ThreadLocal 中initValue方法返回的值,默认为 null ;方法为set时,则为调用者传进的实参。

ThreadLocal 的 get方法:

    public T get() {  
        Thread t = Thread.currentThread();
        //获取当前线程的 threadLocals 属性
        ThreadLocalMap map = getMap(t);
        if (map != null) {
         //若threadLocals属性不为空,以 this(当前 ThreadLocal)实例为健获取对应的值
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                //若已经设置过值或者有初始值就直接返回
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
      //当前线程的threadLocals属性为空或者没有设置过值时设置初始值
        return setInitialValue();
    }
   /**
     * 获取与给定线程相关联的ThreadLoal散列表 
     * @param  t 当前线程
     */
    ThreadLocalMap getMap(Thread t) {
        return t.threadLocals;
    }

    private T setInitialValue() {
        //调用 initialValue 获取初始值默认为 null
        T value = initialValue();
        Thread t = Thread.currentThread();
         //获取当前线程的 threadLocals 属性
        ThreadLocalMap map = getMap(t);
        if (map != null)
            //如果已经创建与当前线程关联的 ThreadLoal 散列表,则直接设值
            map.set(this, value);
        else
            //创建与当前线程相关的 ThreadLocal 散列表 并设值
            createMap(t, value);
        return value;
    }
   /**
     *  创建与当前线程关联的 ThreadLocal 散列表,
     *  并将它赋值给给定线程的 threadLocals 属性
     * @param t 当前线程
     * @param ThreadLocal散列表第一个Entry的初始值
     */
    void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

ThreadLocal 中的set 方法

   /**
     * 向当前线程的线程私有变量设置指定的值
     */
    public void set(T value) {
        Thread t = Thread.currentThread();
        //获取当前线程的 threadLocals 属性
        ThreadLocalMap map = getMap(t);
        if (map != null)
            //如果已经创建与当前线程关联的 ThreadLoal 散列表,则直接设值
            map.set(this, value);
        else
            //创建与当前线程相关的 ThreadLocal 散列表, 并设值
            createMap(t, value);
    }

  下面我们用一张图来概括下线程,线程私有变量以及用户定义的数据之间的关系,加深我们的理解:

线程,线程私有变量以及用户定义的数据之间的关系

上图中 Entry 中的 key 是弱引用类型的,因此用户程序使用完ThreadLocal 对象之后忘记调用 remove 方法,下一次 GC 会把只有一个弱引用的ThreadLocal 回收掉,此时 key 指向 null,则无论谁都不能访问到该key 对应的 value 对象,只要线程实例不退出就无法释放,如果value 对象占用内存很大,则可能会造成OOM。但是ThreadLocalMap 底层会对 key为 null的value进行清理。我们下一章讨论

后记

   我们讨论了 ThreadLocal 如何使用以及其与 Thread 之间关系,下一节我们讨论下 ThreadLocalMap 的具体实现。

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 206,723评论 6 481
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 88,485评论 2 382
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 152,998评论 0 344
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 55,323评论 1 279
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 64,355评论 5 374
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 49,079评论 1 285
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 38,389评论 3 400
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 37,019评论 0 259
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 43,519评论 1 300
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,971评论 2 325
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,100评论 1 333
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,738评论 4 324
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 39,293评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,289评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,517评论 1 262
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 45,547评论 2 354
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,834评论 2 345

推荐阅读更多精彩内容