ThreadLocal源码浅析

简介:
  ThreadLocal不是一个具体的线程。它是一个线程内部的数据存储类,通过它可以再指定的线程中存储数据,数据存储以后,只有在指定线程中可以获取到存储的数据,对于其它线程来说则无法获取到数据。
  ThreadLocal之所以有这么神奇的效果,是因为不同线程访问同一个ThreadLocal的get方法,ThreadLocal内部会将各自线程的引用当做table数组的一个值存在,然后从数组中根据当前ThreadLocal的reference去查找出相应的value。这就是为什么通过ThreadLocal可以再不同线程中维护一套数据的副本并且彼此互不干扰。
  在java中ThreadLocal以Map的形式存储数据(ThreadLocal对象为 key  数值为value)。在Android中做了些改动,在Thread-Local的add方法中,可以看到它会把ThradLocal对象(key)和相对应的value放在table数组连续的位置中。 也就是table被设计为下标为0,2,4...2n的位置存放key,而1,3,5...(2n +1 )的位置存放value。
void add(ThreadLocal<?> key, Object value) {
            for (int index = key .hash & mask ;; index = next(index )) {
                Object k = table[ index];
                if (k == null) {
                    table[ index] = key. reference;
                    table[ index + 1] = value;
                    return;
                }
            }
        }

类中最重要的两个方法是get(),set()。下面开始分析set()源码。
    public void set(T value ) {
        Thread currentThread = Thread.currentThread();
        Values values = values( currentThread);
        if (values == null) {
            values = initializeValues(currentThread );
        }
        values.put( this, value );
    }
首先获取当前线程对象 currentThread,然后执行values( currentThread )方法。源码如下:
Values values(Thread current) {
      return current .localValues;
  }
     在values (currentThread )中返回了currentThread .localValues。跟进Thread的源码可以发现:这个currentThread .localValues其实就是ThreadLocal.Values  localValues 。Values 是ThreadLocal中的一个静态内部类。此时获取到返回的Values对象。
     接下来进行判空操作,如果返回的values为空,那么再次实例化currentThread。跟进initializeValue-s(currentThread)可以发现
Values initializeValues(Thread current) {
        return current .localValues = new Values();
    }

new Values()的实例化过程:

       Values() {
            initializeTable( INITIAL_SIZE);//INITIAL_SIZE 默认值16
            this.size = 0;
            this.tombstones = 0;
        }

      private void initializeTable( int capacity ) {
            this.table = new Object[capacity * 2];
            this.mask = table .length - 1;
            this.clean = 0;
            this.maximumLoad = capacity * 2 / 3; // 2/3
        }
此时可以确保有了Values的一个实例,接下来就可以执行values .put(this, value ),跟进put方法
void put(ThreadLocal<?> key, Object value) {
            cleanUp();

            // Keep track of first tombstone. That's where we want to go back
            // and add an entry if necessary.
            int firstTombstone = -1;

            for (int index = key .hash & mask ;; index = next(index )) {
                Object k = table[ index];

                if (k == key .reference ) {
                    // Replace existing entry.
                    table[ index + 1] = value;
                    return;
                }

                if (k == null) {
                    if (firstTombstone == -1) {
                        // Fill in null slot.
                        table[ index] = key.reference ;
                        table[ index + 1] = value;
                        size++;
                        return;
                    }

                    // Go back and replace first tombstone.
                    table[ firstTombstone] = key.reference ;
                    table[ firstTombstone + 1] = value;
                    tombstones--;
                    size++;
                    return;
                }

                // Remember first tombstone.
                if (firstTombstone == -1 && k == TOMBSTONE) {
                    firstTombstone = index ;
                }
            }
        }

 依据上面的代码可以得出一个存储规则:ThreadLocal的值在table数组中的存储位置总是为reference字段所表示的对象的下一个位置。
table[index] =key.reference;
table[index+ 1] =value;
最终ThreadLocal的值会被存储在table数组中:table[index+ 1] =value;至此,set方法解析完毕。下面看一下get方法。

public T get() {
        // Optimized for the fast path.
        Thread currentThread = Thread.currentThread();
        Values values = values( currentThread);
        if (values != null) {
            Object[] table = values. table;
            int index = hash & values .mask ;
            if (this .reference == table [index ]) {
                return (T) table [index + 1];
            }
        } else {
            values = initializeValues(currentThread );
        }

        return (T) values .getAfterMiss(this);
    }
看完set方法后再看get就比较简单了,首先得到一个Values对象,然后求出table数组ThreadLocal.reference的下标。前文说过: ThradLocal对象(key)和相对应的value放在table数组连续的位置中。 也就是table被设计为下标为0,2,4...2n的位置存放key,而1,3,5...(2n +1 )的位置存放value。现在得到index后再index+1就是value在table数组中的下标。即value=table[index+1];return value即可。
到此想必读者对ThreadLocal为什么能在不同线程中能够为不同线程创建不同的线程副本(其实不太准确,应该是相同对象的不同值),原因就在于采用了key value形式的table数组。key为不同线程的reference,value就五花八门了。

        ThreadLocal浅析到此结束。谢谢欣赏~






相关文章
|
6月前
|
存储 安全 Java
面试题:用过ThreadLocal吗?ThreadLocal是在哪个包下的?看过ThreadLocal源码吗?讲一下ThreadLocal的get和put是怎么实现的?
字节面试题:用过ThreadLocal吗?ThreadLocal是在哪个包下的?看过ThreadLocal源码吗?讲一下ThreadLocal的get和put是怎么实现的?
78 0
|
3月前
|
存储 设计模式 安全
深入理解ThreadLocal原理
本文深入探讨了Java中的ThreadLocal及其内部数据结构ThreadLocalMap的工作原理和特性,帮助读者理解如何利用ThreadLocal实现线程局部变量的隔离和线程安全。
深入理解ThreadLocal原理
|
4月前
|
存储 算法 Java
ThreadLocal 源码浅析
【7月更文挑战第5天】`ThreadLocal` 是Java中用于创建线程局部变量的工具类,确保每个线程拥有独立的变量副本。源码中,每个`ThreadLocal`实例都有一个唯一的哈希码用于映射到`ThreadLocalMap`,这个内部静态类使用弱引用存储键(`ThreadLocal`实例)以防止内存泄漏。`ThreadLocalMap`使用 Entry 数组,Entry 是一个扩展了 WeakReference 的类,持有线程变量值。`ThreadLocal`的`get()`和`set()`方法通过哈希计算定位并访问或设置线程局部变量。
|
6月前
|
存储 安全 Java
ThreadLocal原理讲解
ThreadLocal原理讲解
56 0
|
存储 SpringCloudAlibaba Java
浅析ThreadLocal使用及实现原理
提供了线程局部 (thread-local) 变量。这些变量不同于它们的普通对应物,因为访问某个变量(通过其`get` 或 `set`方法)的每个线程都有自己的局部变量,它独立于变量的初始化副本。`ThreadLocal`实例通常是类中的 private static 字段,它们希望将状态与某一个线程(例如,用户 ID 或事务 ID)相关联 。所以ThreadLocal与线程同步机制不同,线程同步机制是多个线程共享同一个变量,而ThreadLocal是为每一个线程创建一个单独的变量副本,故而每个线程都可以独立地改变自己所拥有的变量副本,而不会影响其他线程所对应的副本。可以这么说Th
109 0
浅析ThreadLocal使用及实现原理
|
Java
ThreadLocal笔记
ThreadLocal笔记
202 0
ThreadLocal笔记
|
存储 安全 Java
ThreadLocal源码分析
ThreadLocal,即线程局部变量。主要用于线程间数据隔离。这些变量在多线程环境下访问(通过get或set方法访问)时能保证各个线程里的变量相对独立于其他线程内的变量,ThreadLocal实例通常来说都是private static类型。ThreadLocal不是为了解决多线程访问共享变量,而是为每个线程创建一个单独的变量副本,提供了保持对象的方法和避免参数传递的复杂性。
|
存储 算法 安全
ThreadLocal原理剖析
ThreadLocal原理剖析
222 0
|
存储 安全 Java
|
Java 定位技术
ThreadLocal原理
经典八股文之ThreadLocal原理
190 0