全网整合营销服务商

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

免费咨询热线: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 


相关文章: 网站制作公司广州有几家,广州尚艺美发学校网站是多少?  制作宣传网站的软件,小红书可以宣传网站吗?  宝塔新建站点报错如何解决?  ,制作一个手机app网站要多少钱?  linux top下的 minerd 木马清除方法  如何高效利用亚马逊云主机搭建企业网站?  如何在建站之星绑定自定义域名?  如何选择适合PHP云建站的开源框架?  网站好制作吗知乎,网站开发好学吗?有什么技巧?  大连网站制作费用,大连新青年网站,五年四班里的视频怎样下载啊?  宝塔面板如何快速创建新站点?  高防网站服务器:DDoS防御与BGP线路的AI智能防护方案  如何彻底删除建站之星生成的Banner?  建站之星IIS配置教程:代码生成技巧与站点搭建指南  焦点电影公司作品,电影焦点结局是什么?  寿县云建站:智能SEO优化与多行业模板快速上线指南  济南专业网站制作公司,济南信息工程学校怎么样?  陕西网站制作公司有哪些,陕西凌云电器有限公司官网?  视频网站app制作软件,有什么好的视频聊天网站或者软件?  如何在万网主机上快速搭建网站?  制作证书网站有哪些,全国城建培训中心证书查询官网?  建站之星免费版是否永久可用?  如何在IIS中新建站点并配置端口与物理路径?  一键制作网站软件下载安装,一键自动采集网页文档制作步骤?  如何用IIS7快速搭建并优化网站站点?  如何在IIS7中新建站点?详细步骤解析  企业微网站怎么做,公司网站和公众号有什么区别?  制作网站外包平台,自动化接单网站有哪些?  如何确保西部建站助手FTP传输的安全性?  如何选择高性价比服务器搭建个人网站?  贸易公司网站制作流程,出口贸易网站设计怎么做?  Python lxml的etree和ElementTree有什么区别  网站建设制作、微信公众号,公明人民医院怎么在网上预约?  php8.4新语法match怎么用_php8.4match表达式替代switch【方法】  定制建站流程解析:需求评估与SEO优化功能开发指南  免费制作小说封面的网站有哪些,怎么接网站批量的封面单?  网页设计网站制作软件,microsoft office哪个可以创建网页?  Android使用GridView实现日历的简单功能  网站专业制作公司有哪些,做一个公司网站要多少钱?  如何通过云梦建站系统实现SEO快速优化?  如何通过IIS搭建网站并配置访问权限?  如何选择可靠的免备案建站服务器?  测试制作网站有哪些,测试性取向的权威测试或者网站?  如何用低价快速搭建高质量网站?  广州网站建站公司选择指南:建站流程与SEO优化关键词解析  如何配置WinSCP新建站点的密钥验证步骤?  头像制作网站在线观看,除了站酷,还有哪些比较好的设计网站?  如何在宝塔面板中创建新站点?  制作网站软件推荐手机版,如何制作属于自己的手机网站app应用?  如何登录建站主机?访问步骤全解析 

您的项目需求

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