您当前位置：首页 > php开源 > php教程 > 聊一聊ThreadLocal

聊一聊ThreadLocal

来源：程序员人生发布时间：2016-08-22 08:58:03 阅读次数：2655次

对ThreadLocal感兴趣是从1个问题开始的：ThreadLocal在何种情况下会产生内存泄漏？对这个问题的思考不能不去了解ThreadLocal本身的实现和1些细节问题等。接下去顺次介绍ThreadLocal的功能，实现细节，使用处景和1些使用建议。

概述

ThreadLocal不是用来解决对象同享访问问题的，而主要提供了线程保持对象的方法和避免参数传递的方便的对象访问方式。1般情况下，通过ThreadLocal.set()到线程中的对象是该线程自己使用的对象，其他线程是不需要访问的，也访问不到的。各个线程中访问的是不同的对象。

ThreadLocal使用处合主要解决多线程中数据因并发产生不1致的问题。ThreadLocal为每一个线程的中并发访问的数据提供1个副本，通过访问副本来运行业务，这样的结果是耗费了内存，但大大减少了线程同步所带来的线程消耗，也介绍了线程并发控制的复杂度。

另外，说ThreadLocal使得各线程能够保持各自独立的1个对象，其实不是通过ThreadLocal.set()来实现的，而是通过每一个线程中的new对象的操作来创建的对象，每一个线程创建1个，不是甚么对象的拷贝或副本。通过ThreadLocal.set()将这个新创建的对象的援用保存到各线程的自己的1个map(Thread类中的ThreadLocal.ThreadLocalMap的变量)中，每一个线程都有这样1个map，履行ThreadLocal.get()时，各线程从自己的map中取出放进去的对象，因此取出来的是各自自己线程中的对象，ThreadLocal实例是作为map的key来使用的。
【代码1】

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

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

很多人会有这样的无解：感觉这个ThreadLocal对象建立了1个类似于全局的map，然后每一个线程作为map的key来存取对应的线程本地的value。实际上是ThreadLocal类中有1个ThreadLocalMap静态内部类，可以简单的理解为1个map，这个map为每一个线程复制1个变量的“拷贝”存储其中。下面是ThreadLocalMap的部份源码：
【代码2】

static class ThreadLocalMap {
        static class Entry extends WeakReference<ThreadLocal> {
            Object value;
            Entry(ThreadLocal k, Object v) {
                super(k);
                value = v;
            }
        }     
        private static final int INITIAL_CAPACITY = 16;
        private Entry[] table;
        private int size = 0;
        private int threshold; // Default to 0
        //部份省略
}

ThreadLocal类中1共有4个方法：

T get()
protected T initialValue()
void remove()
void set(T value)

就以get()方法为例
【代码3】

    public T get() {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null)
                return (T)e.value;
        }
        return setInitialValue();
    }
    ThreadLocalMap getMap(Thread t) {
        return t.threadLocals;
    }

get()方法的源码如上所示，可以看到map中真实的key是线程ThreadLocal实例本身（ThreadLocalMap.Entry e = map.getEntry(this);中的this）。可以看1下getEntry(ThreadLocal key)的源码.
【代码4】

        private Entry getEntry(ThreadLocal key) {
            int i = key.threadLocalHashCode & (table.length - 1);
            Entry e = table[i];
            if (e != null && e.get() == key)
                return e;
            else
                return getEntryAfterMiss(key, i, e);
        }

那末map中的value是甚么呢？我们继续来看源码：
【代码5】

    private T setInitialValue() {
        T value = initialValue();
        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;
    }

代码5中只能够视察到通过[protected T initialValue()]方法设置了1个初始值，固然也能够通过set方法来赋值，继续看源码：
【代码6】

    public void set(T value) {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null)
            map.set(this, value);
        else
            createMap(t, value);
    }

ThreadLocal设置值有两种方案：1. Override其initialValue方法；2. 通过set设置。

关于重写initialValue方法可以参考下面这个例子简便的实现：
【代码7】

    private static final ThreadLocal<Long> TIME_THREADLOCAL = new ThreadLocal<Long>(){
        @Override
        protected Long initialValue()
        {
            return System.currentTimeMillis();
        }
    };

内存泄漏

通过代码1和代码2的片断可以看出，在Thread类中保有ThreadLocal.ThreadLocalMap的援用，即在1个Java线程栈中指向了堆内存中的1个ThreadLocal.ThreadLocalMap的对象，此对象中保存了若干个Entry，每一个Entry的key(ThreadLocal实例)是弱援用，value是强援用（这点类似于WeakHashMap）。

用到弱援用的只是key，每一个key都弱援用指向threadLocal，当把threadLocal实例置为null以后，没有任何强援用指向threadLocal实例，所以threadLocal将会被gc回收，但是value却不能被回收，由于其还存在于ThreadLocal.ThreadLocalMap的对象的Entry当中。只有当前Thread结束以后，所有与当前线程有关的资源才会被GC回收。所以，如果在线程池中使用ThreadLocal，由于线程会复用，而又没有显示的调用remove的话的确是会有可能产生内存泄漏的问题。

其实在ThreadLocal.ThreadLocalMap的get或set方法中会探测其中的key是不是被回收（调用expungeStaleEntry方法），然后将其value设置为null，这个功能几近和WeakHashMap中的expungeStaleEntries()方法1样。因此value在key被gc后可能还会存活1段时间，但终究也会被回收，但是若不再调用get或set方法时，那末这个value就在线程存活期间没法被释放。
【代码8】

        private int expungeStaleEntry(int staleSlot) {
            Entry[] tab = table;
            int len = tab.length;

            // expunge entry at staleSlot
            tab[staleSlot].value = null;
            tab[staleSlot] = null;
            size--;

            // Rehash until we encounter null
            Entry e;
            int i;
            for (i = nextIndex(staleSlot, len);
                 (e = tab[i]) != null;
                 i = nextIndex(i, len)) {
                ThreadLocal k = e.get();
                if (k == null) {
                    e.value = null;
                    tab[i] = null;
                    size--;
                } else {
                    int h = k.threadLocalHashCode & (len - 1);
                    if (h != i) {
                        tab[i] = null;

                        // Unlike Knuth 6.4 Algorithm R, we must scan until
                        // null because multiple entries could have been stale.
                        while (tab[h] != null)
                            h = nextIndex(h, len);
                        tab[h] = e;
                    }
                }
            }
            return i;
        }

其实ThreadLocal本身可以看成是没有内存泄漏问题的，通过显示的调用remove方法便可。

使用处景及方式

ThreadLocal的利用场景，最合适的是按线程多实例（每一个线程对应1个实例）的对象的访问，并且这个对象很多地方都要用到。

对多线程资源同享的问题，同步机制采取了“以时间换空间”的方式，比如定义1个static变量，同步访问，而ThreadLocal采取了“以空间换时间”的方式。前者仅提供1份变量，让不同的线程排队访问，而后者为每个线程都提供了1份变量，因此可以同时访问而互不影响。

在多线程的开发中，常常会斟酌到的策略是对1些需要公然访问的属性通过设置同步的方式来访问。这样每次能保证只有1个线程访问它，不会有冲突。但是这样做的结果会使得性能和对高并发的支持不够。在某些情况下，如果我们不1定非要对1个变量同享不可，而是给每一个线程1个这样的资源副本，让他们可以独立都各自跑各自的，这样不是可以大幅度的提高并行度和性能了吗？

还有的情况是有的数据本身不是线程安全的，或说它只能被1个线程使用，不能被其它线程同时使用。如果等1个线程使用完了再给另外一个线程使用就根本不现实。这样的情况下，我们也能够斟酌用ThreadLocal。

ThreadLocal建议：
1. ThreadLocal类变量由于本身定位为要被多个线程来访问，它通常被定义为static变量。
2. 能够通过值传递的参数，不要通过ThreadLocal存储，以避免造成ThreadLocal的滥用。
3. 在线程池的情况下，在ThreadLocal业务周期处理完成时，最好显示的调用remove()方法，清空“线程局部变量”中的值。
4. 在正常情况下使用ThreadLocal不会造成OOM, 弱援用的知识ThreadLocal,保存值仍然是强援用，如果ThreadLocal仍然被其他对象利用，线程局部变量将没法回收。

InheritableThreadLocal

InheritableThreadLocal是ThreadLocal的子类，代码量很少，可以看1下：
【代码9】

public class InheritableThreadLocal<T> extends ThreadLocal<T> {
    protected T childValue(T parentValue) {
        return parentValue;
    }
    ThreadLocalMap getMap(Thread t) {
       return t.inheritableThreadLocals;
    }
    void createMap(Thread t, T firstValue) {
        t.inheritableThreadLocals = new ThreadLocalMap(this, firstValue);
    }
}

这里主要的还是1个childValue这个方法。
在代码7中示范了ThreadLocal的方法，而使用类InheritableThreadLocal可以在子线程中获得父线程继承下来的值。可以采取重写childValue（Object parentValue）方法来更改继承的值。
查看案例：
【代码10】

public class InheriableThreadLocal
{
    public static final InheritableThreadLocal<?> itl = new InheritableThreadLocal<Object>(){
        @Override protected Object initialValue()
        {
            return new Date().getTime();
        }

        @Override protected Object childValue(Object parentValue)
        {
            return parentValue+" which plus in subThread.";
        }
    };

    public static void main(String[] args)
    {
        System.out.println("Main: get value = "+itl.get());
        Thread a = new Thread(new Runnable(){
            @Override public void run()
            {
                System.out.println(Thread.currentThread().getName()+": get value = "+itl.get());
            }
        });
        a.start();
    }
}

运行结果：

Main: get value = 1467100984858
Thread-0: get value = 1467100984858 which plus in subThread.

如果去掉@Override protected Object childValue(Object parentValue)方法运行结果：

Main: get value = 1461585396073 
Thread-0: get value = 1461585396073

参考资料
1. Java多线程知识小抄集(1)
2. 深入JDK源码之ThreadLocal类
3. Java集合框架：WeakHashMap

生活不易，码农辛苦
如果您觉得本网站对您的学习有所帮助,可以手机扫描二维码进行捐赠
程序员人生

------分隔线----------------------------

上一篇 （仿微信Android）聊天+红包+直播+朋友圈源码发布了

下一篇 HBase作为存储方案

分享到:

------分隔线----------------------------

为码而活

积分：4237

15粉丝

7关注

栏目热点