ThreadLocal

    ThreadLocal不是JUC并发包下工具,它在java.lang包下面。多线程访问同一个共享变量的时候容易出现并发问题,特别是多个线程对一个变量进行写入的时候,为了保证线程安全,一般使用者在访问共享变量的时候需要进行额外的同步措施才能保证线程安全性。ThreadLocal是除了加锁这种同步方式之外的一种保证一种规避多线程访问出现线程不安全的方法,当我们在创建一个变量后,如果每个线程对其进行访问的时候访问的都是线程自己的变量这样就不会存在线程不安全问题。
    如果创建了一个ThreadLocal变量,那么访问这个变量的每个线程都会有这个变量的一个副本,在实际多线程操作的时候,操作的是自己本地内存中的变量。

    ThreadLocal的线程局部值是由它的静态内部类ThreadLocalMap维护的。


ThreadLocal组成

知道他的逻辑组成之后,直接看源码.从内往外看,首先看ThreadLocalMap的组成。

 static class ThreadLocalMap {

        // Entry是ThreadLocalMap哈希数组中的元素
        // 键是ThreadLocal对象,值是ThreadLocal set的值,同时也是个弱引用
        // entry.get()=null 的时候意味着Entry不再引用该键
        static class Entry extends WeakReference<ThreadLocal<?>> {
            /** The value associated with this ThreadLocal. */
            Object value;

            Entry(ThreadLocal<?> k, Object v) {
                // WeakReference的构造函数
                super(k);
                value = v;
            }
        }

        /**
         * 初识容量必须为2的次幂
         */
        private static final int INITIAL_CAPACITY = 16;

        /**
         * ThreadLocalMap的哈希表,表的长度始终是2的次幂
         */
        private Entry[] table;

        /**
         * 哈希表中元素的个数
         */
        private int size = 0;

        /**
         * The next size value at which to resize.
         */
        private int threshold; // Default to 0
}

我们走一遍使用主流程,构造函数没什么好看的了。

  /**
     * Creates a thread local variable.
     * @see #withInitial(java.util.function.Supplier)
     */
    public ThreadLocal() {
    }

接着set方法

 // 将此线程局部变量的当前线程副本设置为指定值
 public void set(T value) {
        Thread t = Thread.currentThread();
        // 获取当前线程绑定的ThreadLocalMap
        ThreadLocalMap map = getMap(t);
        // 若当前线程有绑定ThreadLocalMap,那么用新value覆盖旧value
        if (map != null)
            map.set(this, value);
        else
        // 否则创建ThreadLocalMap
            createMap(t, value);
    }
  
  // 获取当前线程绑定的ThreadLocalMap
   ThreadLocalMap getMap(Thread t) {
        // Thread类里面有个threadLocals属性就是每个线程绑定的ThreadLocal.ThreadLocalMap
        return t.threadLocals;
    }

让我们进到ThreadLocalMap的set方法里面去

private void set(ThreadLocal<?> key, Object value) {

            // We don't use a fast path as with get() because it is at
            // least as common to use set() to create new entries as
            // it is to replace existing ones, in which case, a fast
            // path would fail more often than not.
          
            // 拿到hash表并且计算出当前key的hash值和HashMap很像
            Entry[] tab = table;
            int len = tab.length;
            int i = key.threadLocalHashCode & (len-1);
            
            // 遍历hash表找到对应的key,用新值替换旧值
            for (Entry e = tab[i];
                 e != null;
                 e = tab[i = nextIndex(i, len)]) {
                ThreadLocal<?> k = e.get();
                // 找到key了用新值替换旧值
                if (k == key) {
                    e.value = value;
                    return;
                }

               //若当前key不再被引用了,就清除和占用该过期槽
                if (k == null) {
                    replaceStaleEntry(key, value, i);
                    return;
                }
            }
          
            // 没有找到对应的key,那么在计算的索引位置新建hash表中的元素Entry
            tab[i] = new Entry(key, value);
            int sz = ++size;
            //当清理成功同时到达阈值,需要扩容
            if (!cleanSomeSlots(i, sz) && sz >= threshold)
                rehash();
        }

set方法的主流程完事了,我们看下get方法

public T get() {
        // 获取当前线程绑定的ThreadLocalMap
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            // 用当前ThreadLocal,也就是key获取值Entry,然后返回Entry中的值
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        // 若当前线程没有绑定ThreadLocalMap,那么初始化一个,并返回值
        return setInitialValue();
    }

 // 为当前线程初始化一个ThreadLocalMap,并返回值
 private T setInitialValue() {
        T value = initialValue();
        // 再次检验当前线程是否绑定ThreadLocalMap
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
        return value;
    }

protected T initialValue() {
        return null;
    }

// 为指定线程创建一个ThreadLocalMap,指定值,并且绑定到指定线程
void createMap(Thread t, T firstValue) {
        t.threadLocals = new ThreadLocalMap(this, firstValue);
    }

最后需要看的是remove方法,删除当前线程绑定的ThreadLocalMap中的值

public void remove() {
         ThreadLocalMap m = getMap(Thread.currentThread());
         if (m != null)
             m.remove(this);
     }

// 根据指定的key(ThreadLocal),删除对应的值
private void remove(ThreadLocal<?> key) {
            Entry[] tab = table;
            int len = tab.length;
          // 计算出下标
            int i = key.threadLocalHashCode & (len-1);
            for (Entry e = tab[i];
                 e != null;
                 e = tab[i = nextIndex(i, len)]) {
                // 遍历hash表找到对应的key,清除Entry的值
                if (e.get() == key) {
                    e.clear();
                    expungeStaleEntry(i);
                    return;
                }
            }
        }

Q:ThreadLocal是怎么实现线程局部变量的?
A:每个线程也就是Thread类都有自己的threadLocals属性,它是ThreadLocal的静态内部类ThreadLocalMap,在ThreadLocal,set值和get值的时候都会去取当前线程的threadLocals属性,用threadLocals来完成set和get操作。每个Thread的threadLocals都是独立的,他们不共享。
Thread的threadLocals属性定义如下:

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

推荐阅读更多精彩内容