全网整合营销服务商

电脑端+手机端+微信端=数据同步管理

免费咨询热线:400-708-3566

java  中ThreadLocal实例分析

java  中ThreadLocal实例分析

从概念上理解,threadlocal使变量在多个线程中相互隔离实现线程安全,threadlocal包装的变量最终都专属于对应的每个线程,线程之间相互独立,用一个具体实现来说明:

public interface Consumer {
  int consume();
}
public class ComsumeThread implements Runnable {

  private Consumer consumer;

  public ComsumeThread(Consumer consumer) {
    this.consumer = consumer;
  }

  @Override
  public void run() {
    for(int i=0;i<10;i++){
      System.out.println(Thread.currentThread().getName()+" After Consume left:"+consumer.consume());
    }

  }
}
public class ConsumeClientA implements Consumer {

  private static int leftNum = 30;

  @Override
  public int consume() {
    int orgLeftNum = leftNum;
    Random random = new Random(System.currentTimeMillis());
    try {
      Thread.sleep(random.nextInt(3));
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    orgLeftNum = orgLeftNum -1;
    leftNum = orgLeftNum;
    return leftNum;
  }

  public static void main(String[] args){
    Consumer consumer = new ConsumeClientA();
    Thread thread1 = new Thread(new ComsumeThread(consumer));
    Thread thread2 = new Thread(new ComsumeThread(consumer));
    Thread thread3 = new Thread(new ComsumeThread(consumer));

    thread1.start();
    thread2.start();
    thread3.start();
  }
}

ConsumeClientA是在没有做任何线程安全处理,结果如下:

Thread-2 After Consume left:29
Thread-1 After Consume left:29
Thread-3 After Consume left:29
Thread-2 After Consume left:28
Thread-1 After Consume left:28
Thread-3 After Consume left:28
Thread-2 After Consume left:27
Thread-1 After Consume left:27
Thread-2 After Consume left:26
Thread-3 After Consume left:27
Thread-1 After Consume left:25
Thread-2 After Consume left:25
Thread-3 After Consume left:25
Thread-1 After Consume left:24
Thread-2 After Consume left:24
Thread-3 After Consume left:24
Thread-1 After Consume left:23
Thread-2 After Consume left:23
Thread-3 After Consume left:23
Thread-1 After Consume left:22
Thread-2 After Consume left:22
Thread-3 After Consume left:22
Thread-1 After Consume left:21
Thread-2 After Consume left:21
Thread-3 After Consume left:21
Thread-1 After Consume left:20
Thread-2 After Consume left:20
Thread-3 After Consume left:20
Thread-1 After Consume left:19
Thread-3 After Consume left:18

增加threadlocal处理,每个线程相互独立,实现如下:

public class ConsumeClientB implements Consumer {
  private ThreadLocal<Integer> leftNumThreadLocal = new ThreadLocal<Integer>(){
    @Override
    protected Integer initialValue() {
      return 30;
    }
  };

  @Override
  public int consume() {
    int orgLeftNum = leftNumThreadLocal.get();
    Random random = new Random(System.currentTimeMillis());
    try {
      Thread.sleep(random.nextInt(3));
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
    orgLeftNum = orgLeftNum -1;
    leftNumThreadLocal.set(orgLeftNum);
    return leftNumThreadLocal.get();
  }

  public static void main(String[] args){
    Consumer consumer = new ConsumeClientB();
    Thread thread1 = new Thread(new ComsumeThread(consumer));
    Thread thread2 = new Thread(new ComsumeThread(consumer));
    Thread thread3 = new Thread(new ComsumeThread(consumer));

    thread1.start();
    thread2.start();
    thread3.start();
  }
}

运行的结果如下:

Thread-1 After Consume left:29
Thread-3 After Consume left:29
Thread-2 After Consume left:29
Thread-1 After Consume left:28
Thread-3 After Consume left:28
Thread-2 After Consume left:28
Thread-1 After Consume left:27
Thread-3 After Consume left:27
Thread-2 After Consume left:27
Thread-1 After Consume left:26
Thread-3 After Consume left:26
Thread-2 After Consume left:26
Thread-1 After Consume left:25
Thread-3 After Consume left:25
Thread-2 After Consume left:25
Thread-1 After Consume left:24
Thread-3 After Consume left:24
Thread-2 After Consume left:24
Thread-1 After Consume left:23
Thread-3 After Consume left:23
Thread-2 After Consume left:23
Thread-1 After Consume left:22
Thread-3 After Consume left:22
Thread-2 After Consume left:22
Thread-1 After Consume left:21
Thread-3 After Consume left:21
Thread-2 After Consume left:21
Thread-1 After Consume left:20
Thread-3 After Consume left:20
Thread-2 After Consume left:20

每个线程拥有自己的独立变量,相互隔离实现线程安全。

那ThreadLocal是怎样实现这种线程隔离的线程安全的呢?

从ThreadLocal源码可以看到,真正实现线程隔离,与线程挂钩的,其实是ThreadLocal.ThreadLocalMap这个实现类,最明显的体现就在于Thread类源码的这样一个变量申明说明了ThreadLocal.ThreadLocalMap与Thread的关系:

ThreadLocal.ThreadLocalMap threadLocals, inheritableThreadLocals;

Thread类是包含threadLocals对象的,ThreadLocal的具体实现就是根据提供的get,set等接口,对当前thread的threadLocals变量进行相关操作的,如get操作代码如下:

  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();
  }

  ThreadLocal.ThreadLocalMap getMap(Thread t) {
    return t.threadLocals;
  }

可以看到,getMap()方法就是从当前thread获取对应的threadLocals变量,然后从这个ThreadLocal.ThreadLocalMap类型的threadLocals变量中获取对应线程中该ThreadLocal对象对应的变量值。

set方法的操作也是一样:

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

  }

  void createMap(Thread t, T firstValue) {
    t.threadLocals = new ThreadLocalMap(this, firstValue);
  }

static class Entry extends WeakReference<ThreadLocal> {
      Object value;

      Entry(ThreadLocal var1, Object var2) {
        super(var1);
        this.value = var2;
      }
    }

ThreadLocalMap中存的是内部类Entry的数组,Entry是继承WeakReference实现,WeakReference的好处是保存对象引用,而又不干扰该对象被GC回收,线程执行完回收threadLocals变量时不会受到Entry封装的变量的干扰。

而且ThreadLocalMap中的key是ThreadLocal,所以一个ThreadLocal对象只能在一个Thread对象中保存一个ThreadLocal的value。

综上,很多人说ThreadLocal的实现是ThreadLocalMap中存Thread对象为key,变量为value的map结构,其实是错误的。

感谢阅读,希望能帮助到大家,谢谢大家对本站的支持!


# java  # 中ThreadLocal  # ThreadLocal详解及实例  # java ThreadLocal使用案例详解  # java多线程编程之InheritableThreadLocal  # java 中ThreadLocal 的正确用法  # Java 并发编程之ThreadLocal详解及实例  # Java ThreadLocal 线程安全问题解决方案  # 实例详解Java中ThreadLocal内存泄露  # Java ThreadLocal的设计理念与作用  # 可以看到  # 自己的  # 的是  # 是在  # 多个  # 是从  # 希望能  # 是怎样  # 这样一个  # 人说  # 又不  # 谢谢大家  # 说明了  # 就在于  # 量为  # 概念上  # 综上  # 变量值  # 只能在  # Consume 


相关文章: 制作网站的过程怎么写,用凡科建站如何制作自己的网站?  自助网站制作软件,个人如何自助建网站?  建设网站制作价格,怎样建立自己的公司网站?  如何在Ubuntu系统下快速搭建WordPress个人网站?  网站制作需要会哪些技术,建立一个网站要花费多少?  头像制作网站在线观看,除了站酷,还有哪些比较好的设计网站?  建站一年半SEO优化实战指南:核心词挖掘与长尾流量提升策略  C++时间戳转换成日期时间的步骤和示例代码  如何在腾讯云服务器快速搭建个人网站?  想学网站制作怎么学,建立一个网站要花费多少?  建站之星ASP如何实现CMS高效搭建与安全管理?  建站主机助手选型指南:2025年热门推荐与高效部署技巧  成都响应式网站开发,dw怎么把手机适应页面变成网页?  建站主机与虚拟主机有何区别?如何选择最优方案?  设计网站制作公司有哪些,制作网页教程?  网站设计制作公司地址,网站建设比较好的公司都有哪些?  网站按钮制作软件,如何实现网页中按钮的自动点击?  ,有什么在线背英语单词效率比较高的网站?  北京制作网站的公司,北京铁路集团官方网站?  如何选择网络建站服务器?高效建站必看指南  建站主机如何安装配置?新手必看操作指南  极客网站有哪些,DoNews、36氪、爱范儿、虎嗅、雷锋网、极客公园这些互联网媒体网站有什么差异?  高防服务器:AI智能防御DDoS攻击与数据安全保障  如何在服务器上三步完成建站并提升流量?  Thinkphp 中 distinct 的用法解析  已有域名和空间,如何快速搭建网站?  如何在IIS7中新建站点?详细步骤解析  如何在Golang中实现微服务服务拆分_Golang微服务拆分与接口管理方法  如何确保西部建站助手FTP传输的安全性?  C++中的Pimpl idiom是什么,有什么好处?(隐藏实现)  西安大型网站制作公司,西安招聘网站最好的是哪个?  c# await 一个已经完成的Task会发生什么  网站视频怎么制作,哪个网站可以免费收看好莱坞经典大片?  香港服务器如何优化才能显著提升网站加载速度?  美食网站链接制作教程视频,哪个教做美食的网站比较专业点?  建站之星客服服务时间及联系方式如何?  如何安全更换建站之星模板并保留数据?  网站企业制作流程,用什么语言做企业网站比较好?  宝塔新建站点报错如何解决?  非常酷的网站设计制作软件,酷培ai教育官方网站?  重庆网站制作公司哪家好,重庆中考招生办官方网站?  网站制作和推广的区别,想自己建立一个网站做推广,有什么快捷方法马上做好一个网站?  标准网站视频模板制作软件,现在有哪个网站的视频编辑素材最齐全的,背景音乐、音效等?  网页设计网站制作软件,microsoft office哪个可以创建网页?  定制建站价位费用解析与套餐推荐全攻略  怀化网站制作公司,怀化新生儿上户网上办理流程?  高防服务器租用如何选择配置与防御等级?  如何在宝塔面板中创建新站点?  如何高效利用亚马逊云主机搭建企业网站?  如何通过免费商城建站系统源码自定义网站主题与功能? 

您的项目需求

*请认真填写需求信息,我们会在24小时内与您取得联系。