3.3类ThreadLocal的使用

变量值的共享可以使用public static变量的形式,所有的线程都使用同一个public static变量。如果想实现每一个线程都有自己的共享变量该如何解决呢?JDK中提供的类ThreadLocal正是为了解决这样的问题。

类ThreadLocal主要解决的就是每个线程绑定自己的值,可以将ThreadLocal类比喻成全局存放数据的盒子,盒子中可以存储每个线程的私有数据

3.3.1 方法get()与null

/**
 * @author wuyoushan
 * @date 2017/3/20.
 */
public class Run {
    public static ThreadLocal t1=new ThreadLocal();

    public static void main(String[] args) {
        if(t1.get()==null){
            System.out.println("从未放过值");
            t1.set("我的值");
        }
        System.out.println(t1.get());
        System.out.println(t1.get());
    }
}

程序的运行结果:

从未放过值
我的值
我的值

从程序的运行结果来看,第一调用t1对象的get()方法时返回的值是null,通常调用set()方法赋值后顺利取出值并打印到控制台上。类ThreadLocal解决的是变量在不同线程间的隔离性,也就是不同线程拥有自己的值,不同线程中的值是可以放入ThreadLocal类中进行保存的。

3.3.2 验证线程变量的隔离性

/**
 * @author wuyoushan
 * @date 2017/5/23.
 */
public class Tools {
    public static  ThreadLocal t1=new ThreadLocal();
}

/**
 * @author wuyoushan
 * @date 2017/4/4.
 */
public class ThreadA extends Thread{

    @Override
    public void run() {
       try{
           for (int i = 0; i <100; i++) {
                 Tools.t1.set("ThreadA"+(i+1));
               System.out.println("ThreadA get Value="+Tools.t1.get());
               Thread.sleep(200);
           }
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
    }
}

/**
 * @author wuyoushan
 * @date 2017/4/4.
 */
public class ThreadB extends Thread{

    @Override
    public void run() {
        try{
            for (int i = 0; i <100; i++) {
                Tools.t1.set("ThreadB"+(i+1));
                System.out.println("ThreadB get Value="+Tools.t1.get());
                Thread.sleep(200);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

/**
 * @author wuyoushan
 * @date 2017/3/20.
 */
public class Run {

    public static void main(String[] args) {
        try {
            ThreadA a=new ThreadA();
            ThreadB b=new ThreadB();
            a.start();
            b.start();
            for (int i = 0; i < 100; i++) {
                Tools.t1.set("Main"+(i+1));
                System.out.println("Main get Value="+Tools.t1.get());
                Thread.sleep(200);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

程序的运行结果为:

Main get Value=Main97
ThreadB get Value=ThreadB97
ThreadA get Value=ThreadA97
Main get Value=Main98
ThreadB get Value=ThreadB98
ThreadA get Value=ThreadA98
Main get Value=Main99
ThreadB get Value=ThreadB99
ThreadA get Value=ThreadA99
Main get Value=Main100
ThreadB get Value=ThreadB100
ThreadA get Value=ThreadA100

虽然3个线程都向t1对象中set()数据值,但每个线程还是能取出自己的数据。

/**
 * @author wuyoushan
 * @date 2017/5/23.
 */
public class Tools {
    public static  ThreadLocal<Date> t1=new ThreadLocal();
}

/**
 * @author wuyoushan
 * @date 2017/4/4.
 */
public class ThreadA extends Thread{

    @Override
    public void run() {
       try{
           for (int i = 0; i <100; i++) {
               if(Tools.t1.get()==null){
                   Tools.t1.set(new Date());
               }
               System.out.println("A "+Tools.t1.get().getTime());
               Thread.sleep(100);
           }
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
    }
}

/**
 * @author wuyoushan
 * @date 2017/4/4.
 */
public class ThreadB extends Thread{

    @Override
    public void run() {
        try{
            for (int i = 0; i <100; i++) {
                if(Tools.t1.get()==null){
                    Tools.t1.set(new Date());
                }
                System.out.println("B "+Tools.t1.get().getTime());
                Thread.sleep(100);
            }
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

/**
 * @author wuyoushan
 * @date 2017/3/20.
 */
public class Run {

    public static void main(String[] args) {
        try {
            ThreadA a=new ThreadA();
            a.start();
            Thread.sleep(1000);
            ThreadB b=new ThreadB();
            b.start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

程序的运行结果为:

A 1495499916793
A 1495499916793
B 1495499917792
A 1495499916793
A 1495499916793
B 1495499917792
A 1495499916793
B 1495499917792
B 1495499917792
A 1495499916793

运行结果只有两种时间。

在第一次调用ThreadLocal类的get()方法返回值是null,怎么样实现第一次调用get()不返回null呢?也就是具有默认值的效果。

3.3.3 解决get()返回null问题

/**
 * @author wuyoushan
 * @date 2017/5/24.
 */
public class ThreadLocalExt extends ThreadLocal {

    @Override
    protected Object initialValue() {
        return "我是默认值,第一次get不再为null";
    }
}

/**
 * @author wuyoushan
 * @date 2017/3/20.
 */
public class Run {

    private static ThreadLocalExt t1=new ThreadLocalExt();

    public static void main(String[] args) {
        if(t1.get()==null){
            System.out.println("从未放过值");
            t1.set("我的值");
        }
        System.out.println(t1.get());
        System.out.println(t1.get());
    }
}

程序的运行结果为:

我是默认值,第一次get不再为null
我是默认值,第一次get不再为null

此案例仅仅证明main线程有自己的值,那其他线程是否会有自己的初始值呢?

3.3.4 再次验证线程变量的隔离性

/**
 * @author wuyoushan
 * @date 2017/5/23.
 */
public class Tools {
    public static  ThreadLocalExt t1=new ThreadLocalExt();
}

/**
 * @author wuyoushan
 * @date 2017/5/24.
 */
public class ThreadLocalExt extends ThreadLocal {

    @Override
    protected Object initialValue() {
        return new Date().getTime();
    }
}

/**
 * @author wuyoushan
 * @date 2017/4/4.
 */
public class ThreadA extends Thread{

    @Override
    public void run() {
       try{
           for (int i = 0; i <10; i++) {
               System.out.println("在ThreadA线程中取值= "+Tools.t1.get());
               Thread.sleep(100);
           }
       } catch (InterruptedException e) {
           e.printStackTrace();
       }
    }
}

/**
 * @author wuyoushan
 * @date 2017/3/20.
 */
public class Run {

    public static void main(String[] args) {
        try {
            for (int i = 0; i < 10; i++) {
                System.out.println("在Main线程中取值="+Tools.t1.get());
                Thread.sleep(100);
            }
            Thread.sleep(5000);
            ThreadA a=new ThreadA();
            a.start();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}

程序的运行结果为:

在Main线程中取值=1495583100820
在Main线程中取值=1495583100820
在Main线程中取值=1495583100820
在Main线程中取值=1495583100820
在ThreadA线程中取值= 1495583106829
在ThreadA线程中取值= 1495583106829
在ThreadA线程中取值= 1495583106829
在ThreadA线程中取值= 1495583106829

子线程和父线程各有各自所拥有的值

摘选自 java多线程核心编程技术-3.3

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
平台声明:文章内容(如有图片或视频亦包括在内)由作者上传并发布,文章内容仅代表作者本人观点,简书系信息发布平台,仅提供信息存储服务。

推荐阅读更多精彩内容

  • 从三月份找实习到现在,面了一些公司,挂了不少,但最终还是拿到小米、百度、阿里、京东、新浪、CVTE、乐视家的研发岗...
    时芥蓝阅读 42,356评论 11 349
  • Spring Cloud为开发人员提供了快速构建分布式系统中一些常见模式的工具(例如配置管理,服务发现,断路器,智...
    卡卡罗2017阅读 134,868评论 18 139
  • 1. Java基础部分 基础部分的顺序:基本语法,类相关的语法,内部类的语法,继承相关的语法,异常的语法,线程的语...
    子非鱼_t_阅读 31,754评论 18 399
  • "沙子是废物,水泥也是废物,但他们混在一起是混凝土,就是精品;大米是精品,汽油也是精品,但他们混在一起就是废物。是...
    7381d9e0c63c阅读 181评论 0 0