Java并发编程之threadLocal

package com.heiye.learn1;

public class ThreadLocalTest {
    //print方法
    static void print(String threadName) {
        //打印当前线程本地内存中LocalVariable变量的值
        System.out.println(threadName + ":" + localVariable.get());
        //清除当前线程本地内存中的localVariable变量值
        //localVariable.remove();
    }

    //创建ThreadLocal变量
    static ThreadLocal<String> localVariable = new ThreadLocal<>();

    public static void main(String[] args) {
        //创建线程threadOne
        Thread threadOne = new Thread(new Runnable() {
            @Override
            public void run() {
                //设置线程one变量localVariable值
                localVariable.set("threadOne local Variable");
                //调用打印函数
                print("threadOne");
                //打印本地变量值
                System.out.println("threadOne remove after" + ":" + localVariable.get());
            }
        });
        //创建线程threadTwo
        Thread threadTwo = new Thread(new Runnable() {
            @Override
            public void run() {
                //设置线程two变量localVariable值
                localVariable.set("threadTwo local Variable");
                //调用打印函数
                print("threadTwo");
                //打印本地变量值
                System.out.println("threadTwo remove after" + ":" + localVariable.get());
            }
        });

        threadOne.start();
        threadTwo.start();
    }
}

 //set
 public void set(T value) {
        //获取当前线程
        Thread t = Thread.currentThread();
        //将当前线程作为key,到ThreadLocalMap取查找对应的线程变量
        ThreadLocalMap map = getMap(t);
        //如果找到，则设置
        if (map != null)
            map.set(this, value);
        else //第一次调用就创建当前线程所在的hashmap
            createMap(t, value);
    }

 //get
 public T get() {
        Thread t = Thread.currentThread();
        ThreadLocalMap map = getMap(t);
        if (map != null) {
            ThreadLocalMap.Entry e = map.getEntry(this);
            if (e != null) {
                @SuppressWarnings("unchecked")
                T result = (T)e.value;
                return result;
            }
        }
        return setInitialValue();
    }

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