多线程(6) — ThreadLocal线程范围内的共享数据

看问题：

package ThreadPractice;

import java.util.Random;

/**
 * Created by qiaorenjie on 2018/3/25.
 */
public class ThreadScopeShareData {

    private static int data = 0;
    public static void main(String[] args) {
        new Thread(new Runnable() {
            @Override
            public void run() {
                data = new Random().nextInt();
                System.out.println(Thread.currentThread().getName()
                                + " 放入数据：" + data);
                new A().get();
                new B().get();
            }
        }).start();
    }

    static class A{
        public void get(){
            System.out.println("A的" + Thread.currentThread().getName()
                    + " 获取数据：" + data);
        }
    }

    static class B{
        public void get(){
            System.out.println("B的" + Thread.currentThread().getName()
                    + " 获取数据：" + data);
        }
    }

}

======console=====
Thread-0 放入数据：-172518424
A的Thread-0 获取数据：-172518424
B的Thread-0 获取数据：-172518424

一个线程的data都是一样的看起来没问题，但是加上for循环开启两个线程的时候出现了下面的问题：

image.png

可见第一个线程放入的数据和后面调用A、B取得的数据不一样。所以怎么样让各自线程独立呢？

image.png

可见通过Map就实现了各自线程的独立。

这其中主要是因为共享数据是同一个对其的操作是一致的

也就是说在多线程中要考虑后面的线程或方法对于共享变量的更改以及线程安全，而这里用Map将各个线程与数据隔离开来，实现了线程范围内的共享数据。

ThreadLocal类就是为了解决这个问题而设计

ThreadLocal类部分源码：

public class ThreadLocal<T> {
       ..............
      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();
    }

    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;
    }
  ......
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;
            }
        }
      ......
      private ThreadLocalMap(ThreadLocalMap parentMap) {
            Entry[] parentTable = parentMap.table;
            int len = parentTable.length;
            setThreshold(len);
            table = new Entry[len];

            for (int j = 0; j < len; j++) {
                Entry e = parentTable[j];
                if (e != null) {
                    ThreadLocal key = e.get();
                    if (key != null) {
                        Object value = key.childValue(e.value);
                        Entry c = new Entry(key, value);
                        int h = key.threadLocalHashCode & (len - 1);
                        while (table[h] != null)
                            h = nextIndex(h, len);
                        table[h] = c;
                        size++;
                    }
                }
            }
        }
      ........
}

由源码可以看出来ThreadLocal类其实就是给每一个操作的Thread对映一个ThreadLocalMap,而Entry(ThreadLocal k, Object v)以ThreadLocal为key，存储的数据为Object，将每个线程分开。由此实现了每个线程对数据的隔离。

一个ThreadLocal代表一个变量，如果有几个ThreadLocal，则需要创建多个ThreadLocal，若有多个变量需要线程共享，可以先定义一个对象封装这多个变量，然后在ThreadLocal中存储这一个对象。

public class ThreadLocalTest {

    static ThreadLocal<Integer> threadLocal = new ThreadLocal<>();
    static ThreadLocal<MyThreadScopeData> myThreadScopeData = new ThreadLocal<>();

    public static void main(String[] args) {
        for (int i = 0; i <2 ; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    int data = new Random().nextInt();
                    System.out.println(Thread.currentThread().getName()
                            + " 放入数据：" + data);
                    threadLocal.set(data);  // 这里默认对当前线程的数据操作：Thread.currentThread()
                    MyThreadScopeData myData = new MyThreadScopeData();
                    myData.setName("name" + data);
                    myData.setAge(data);
                    myThreadScopeData.set(myData);
                    new A().get();
                    new B().get();
                }
            }).start();
        }
    }

    static class A{
        public void get(){
            int data = threadLocal.get();  // 不用输线程号，就是当前线程
            System.out.println("A的" + Thread.currentThread().getName()
                    + " 获取数据：" + data);
            MyThreadScopeData myData = myThreadScopeData.get();
            System.out.println("A的" + Thread.currentThread().getName()
                    + " 获取myData数据：" + myData.getName() + "," +
                    myData.getAge());
        }
    }

    static class B{
        public void get(){
            int data = threadLocal.get();
            System.out.println("B的" + Thread.currentThread().getName()
                    + " 获取数据：" + data);
        }
    }

}

class MyThreadScopeData{

    private String name;
    private int age;

    public String getName() {
        return name;
    }
    public void setName(String name) {
        this.name = name;
    }
    public int getAge() {
        return age;
    }
    public void setAge(int age) {
        this.age = age;
    }
}
======console=======
Thread-0 放入数据：1185524060
A的Thread-0 获取数据：1185524060
A的Thread-0 获取myData数据：name1185524060,1185524060
B的Thread-0 获取数据：1185524060
Thread-1 放入数据：1025645101
A的Thread-1 获取数据：1025645101
A的Thread-1 获取myData数据：name1025645101,1025645101
B的Thread-1 获取数据：1025645101

通过将数据存到ThreadLocal或者数据量多时创建对象将对象放入ThreadLocal即可实现数据的隔离。

由此已经实现了其功能

（ThreadLocal在这里知乎上也有很多讨论
https://www.zhihu.com/question/23089780）

但是这种方法不够好，每次都要new实例，能不能每个线程就一个实例节约空间，对代码进行重构。
(从这里开始又涉及到—《Java设计模式》这一块儿内容，对于代码的优化与重构在公司里也极其看重，这一块儿内容也十分重要，后面有空可能会开辟新空间来讲)

public class ThreadLocalTest {

    static ThreadLocal<Integer> threadLocal = new ThreadLocal<>();
    static ThreadLocal<MyThreadScopeData> myThreadScopeData = new ThreadLocal<>();

    public static void main(String[] args) {
        for (int i = 0; i <2 ; i++) {
            new Thread(new Runnable() {
                @Override
                public void run() {
                    int data = new Random().nextInt();
                    System.out.println(Thread.currentThread().getName()
                            + " 放入数据：" + data);
                    threadLocal.set(data);  // 这里默认对当前线程的数据操作：Thread.currentThread()
//                    MyThreadScopeData myData = new MyThreadScopeData();
//                    myData.setName("name" + data);
//                    myData.setAge(data);
//                    myThreadScopeData.set(myData);
                    MyThreadScopeData.getThreadInstance().setName("name"+ data);
                    MyThreadScopeData.getThreadInstance().setAge(data);
                    new A().get();
                    new B().get();
                }
            }).start();
        }
    }

    static class A{
        public void get(){
            int data = threadLocal.get();  // 不用输线程号，就是当前线程
            System.out.println("A的" + Thread.currentThread().getName()
                    + " 获取数据：" + data);
//          MyThreadScopeData myData = myThreadScopeData.get();
            MyThreadScopeData myData = MyThreadScopeData.getThreadInstance();

            System.out.println("A的" + Thread.currentThread().getName()
                    + " 获取myData数据：" + myData.getName() + "," +
                    myData.getAge());
        }
    }

    static class B{
        public void get(){
            int data = threadLocal.get();
            System.out.println("B的" + Thread.currentThread().getName()
                    + " 获取数据：" + data);
            MyThreadScopeData myData = MyThreadScopeData.getThreadInstance();
            System.out.println("B的" + Thread.currentThread().getName()
                    + " 获取myData数据：" + myData.getName() + "," +
                    myData.getAge());
        }
    }

}

class MyThreadScopeData{

    private MyThreadScopeData(){}

      //1. 饿汉式：只有一个类的实例对象，不管是否调用实例对象都已经创建好了
//    public static MyThreadScopeData getInstance(){
//        return instance;
//    }
//    private static MyThreadScopeData instance = new MyThreadScopeData();

    //2. 懒汉式：等到需要的时候才创建。由于可能在第一个线程new了个MyThreadScopeData()还没有赋值
    //       CPU就切换产生两个对象，所以要加Synchronized保证线程安全
//    public static synchronized MyThreadScopeData getInstance(){
//        if (instance == null){
//            instance = new MyThreadScopeData();
//        }
//        return instance;
//    }
//    private static MyThreadScopeData instance = null;

    //3. 用ThreadLocal
    public static MyThreadScopeData getThreadInstance(){  // 不用加synchronized
        MyThreadScopeData instance = map.get();
        if (instance == null){
            instance = new MyThreadScopeData();
            map.set(instance);
        }
        return instance;
    }
    private static ThreadLocal<MyThreadScopeData> map = new ThreadLocal<>();

    private String name;
    private int age;

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    public int getAge() {
        return age;
    }

    public void setAge(int age) {
        this.age = age;
    }
}

每一个线程对应一个容器对象把该线程所有数据装在这个容器里面，其他线程过来则对应另外一个容器对象。

最后编辑于：2018.09.02 11:36:19

人面猴
序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
沈念sama阅读 202,980评论 5赞 476
死咒
序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
沈念sama阅读 85,178评论 2赞 380
救了他两次的神仙让他今天三更去死
文/潘晓璐我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
开封第一讲书人阅读 149,868评论 0赞 336
道士缉凶录：失踪的卖姜人
文/不坏的土叔我叫张陵，是天一观的道长。经常有香客问我，道长，这世上最难降的妖魔是什么？我笑而不...
开封第一讲书人阅读 54,498评论 1赞 273
港岛之恋（遗憾婚礼）
正文为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
茶点故事阅读 63,492评论 5赞 364
恶毒庶女顶嫁案：这布局不是一般人想出来的
文/花漫我一把揭开白布。她就那样静静地躺着，像睡着了一般。火红的嫁衣衬着肌肤如雪。梳的纹丝不乱的头发上，一...
开封第一讲书人阅读 48,521评论 1赞 281
城市分裂传说
那天，我揣着相机与录音，去河边找鬼。笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。我是一名探鬼主播，决...
沈念sama阅读 37,910评论 3赞 395
双鸳鸯连环套：你想象不到人心有多黑
文/苍兰香墨我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
开封第一讲书人阅读 36,569评论 0赞 256
万荣杀人案实录
序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
沈念sama阅读 40,793评论 1赞 296
护林员之死
正文独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋以下内容为张勋视角年9月15日...
茶点故事阅读 35,559评论 2赞 319
白月光启示录
正文我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
茶点故事阅读 37,639评论 1赞 329
活死人
序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
沈念sama阅读 33,342评论 4赞 318
日本核电站爆炸内幕
正文年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
茶点故事阅读 38,931评论 3赞 307
男人毒药：我在死后第九天来索命
文/蒙蒙一、第九天我趴在偏房一处隐蔽的房顶上张望。院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
开封第一讲书人阅读 29,904评论 0赞 19
一桩弑父案，背后竟有这般阴谋
文/苍兰香墨我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。一阵脚步声响...
开封第一讲书人阅读 31,144评论 1赞 259
情欲美人皮
我被黑心中介骗来泰国打工，没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。一个月前我还...
沈念sama阅读 42,833评论 2赞 349
代替公主和亲
正文我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
茶点故事阅读 42,350评论 2赞 342

多线程(6) — ThreadLocal线程范围内的共享数据

推荐阅读更多精彩内容