ThreadLocal使用和原理简析

1. 解决共享资源冲突

  对于并发工作,需要某种方式来防止两个任务同时访问相同的资源,至少在关键阶段不能出现这种冲突情况。

  方法之一就是当资源被一个任务使用时,在其上加锁。第一个访问某项资源的任务必须锁定这项资源,使其他任务在其被解锁之前,就无法访问它了,而在其被解锁之时,另一个任务就可以锁定并使用它,以此类推。Java中的synchronized、ReentrantLock就属于这种方式,关于这部分,前面有专门撰文详述:

  第二种方式是根除对变量的共享。线程本地存储是一种自动化机制,可以为使用相同变量的每个不同的线程都创建不同的存储。因此,如果你有5个线程都要使用变量x所表示的对象,那线程本地存储就会生成5个用于x的不同的存储块。它使得你可以将状态与线程关联起来。创建和管理线程本地存储可以由java.lang.ThreadLocal类来实现。本文我们就来学习ThreadLocal的用法,并且从源码层面探究一下其实现原理。

  按照官方的说法:

  • ThreadLocal可以让线程拥有自己独享的变量,就是说多个线程共享同一个ThreadLocal对象,但是每个线程都可以通过ThreadLocal的get方法获取或set方法设置属于该线程的变量副本,变量只属于该线程并且其他线程无关;
  • ThreadLocal对象一般作为类的private static属性,可以用来为线程设置一些状态信息比如userId或者transactionId;

2. ThreadLocal使用

  到这里,如果之前没有使用过ThreadLocal,可能对于ThreadLocal的作用依然不清楚,我们通过官方的一个示例熟悉一下吧(如果之前使用过ThreadLocal的可以直接跳过此处):

public class ThreadLocalId {

  private final static AtomicInteger nextId = new AtomicInteger(0);

  private final static ThreadLocal<Integer> threadId = new ThreadLocal<Integer>() {
    @Override    // 重写ThreadLocal中的方法,用于如果没有通过set设置值时,第1次通过get来获取值时会调用这个方法生成初始值,可以重写该方法来指定初始值生成规则
    protected Integer initialValue() {
      return nextId.getAndIncrement();
    }
  };

  public static Integer get() {
    return threadId.get();
  }

  public static void main(String[] args) {
    for(int i = 0; i < 5; i++) {
      new Thread(new Runnable() {
        @Override
        public void run() {
          int id = ThreadLocalId.get();
          System.out.println("thread:" + Thread.currentThread().getName() + ",threadId-->" + id);
          threadId.set(id);
          try {
            Thread.sleep(100);
          } catch (InterruptedException e) {
            e.printStackTrace();
          }
          System.out.println("thread:" + Thread.currentThread().getName() + ",threadId-->" + threadId.get());
        }
      }).start();
    }
  }
}

// 输出结果
thread:Thread-0,threadId-->0
thread:Thread-1,threadId-->1
thread:Thread-2,threadId-->2
thread:Thread-3,threadId-->3
thread:Thread-4,threadId-->4
thread:Thread-4,threadId-->4
thread:Thread-2,threadId-->2
thread:Thread-1,threadId-->1
thread:Thread-0,threadId-->0
thread:Thread-3,threadId-->3

  如上,开启5个线程,每个线程都调用同一个ThreadLocal对象threadId的get方法获取一个id值作为线程标识,并通过set方法保存到ThreadLocal中,然后再通过get方法来获取,从输出结果上我们可以看,每个线程虽然都是操作的同一个ThreadLocal对象,但是它们获取到的值并没有被其它线程覆盖,都是自己set进去的值。这就是ThreadLocal的作用:提供线程本地变量,这样一来就不会受到其他线程的影响了,从而可以保证线程安全。那ThreadLocal又是如何做到的呢?我们来看一下源码:

3. 线程本地存储

  我们先从其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();
}

ThreadLocalMap getMap(Thread t) {   // ThreadLocalMap作为Thread的一个属性
    return t.threadLocals;
}

  get方法的主要逻辑如下:

  • 先获取当前线程t;
  • 然后获取ThreadLocalMap;
  • 如果map不为空,则以当前对象(ThreadLocal对象)为key获取value;
  • 如果map为空,则执行初始化操作;

  在第2步中,从哪里获取map?我们可以看到是从当前线程直接获取的(ThreadLocal作为Thread类的一个属性),也就是说这个map是属于当前线程的,而我们想要保存的值是存在这个map中的,这就是ThreadLocal的魔法所在,通过线程本地保存的方式来实现线程之间状态的互不干扰。

  好,接下来我们看看如果是第一次调用get时ThreadLocalMap如果还没有的话是如何初始化ThreadLocalMap并生成初始值的:

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;
}
// 通过这个方法生成初始值,可以重写该方法来指定生成初始值规则
protected T initialValue() {
    return null;
}
// new一个ThreadLocalMap
void createMap(Thread t, T firstValue) {
    t.threadLocals = new ThreadLocalMap(this, firstValue);
}

  setInitialValue的主要逻辑如下:

  • 首先通过initialValue方法生成初始值;
  • 然后获取ThreadLocalMap;
  • 如果map不为空,则将第1步生成的值set进去,以当前对象(ThreadLocal对象)为key;
  • 如果map为空,则new一个ThreadLocalMap出来;
  • 返回生成的初始值;

  现在我们知道了ThreadLocal的get方法是从一个保存在线程本地(就是Thread.currentThread()获取到的Thread实例对象中)的一个叫threadLocals的ThreadLocalMap的数据结构中,这是一个定制化的hash类型的map,专门用于保存线程本地变量。现在我们再看一下ThreadLocal是如何保存元素的:

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

  逻辑比较简单:

  • 获取当前线程;
  • 从当前线程获取ThreadLocalMap;
  • 如果map不为空,则以当前ThreadLocal对象为key保存到ThreadLocalMap中;
  • 如果map为空,则初始化ThreadLocalMap;

  好了,现在我们知道ThreadLocal是通过将变量保存在线程本地来实现线程之间相互隔离的,可以结合下图一起理解。

4. 总结

  • Java中通过java.lang.ThreadLocal类来实现创建和管理线程本地存储;
  • 线程本地存储是指Thread类中的threadLocals,类型为ThreadLocalMap,其类定义在ThreadLocal中;
  • 每个线程通过同一个ThreadLocal进行set和get变量时,实际上是以这个ThreadLocal为key进行存储和获取数据,线程之间共享的是ThreadLocal这个对象,但是数据是保存在线程各自本地;

  ThreadLocalMap是保存数据的关键,它的内部原理又是怎样的呢?ThreadLocal又存在什么问题呢?请看下文。。。

原文地址:https://www.cnblogs.com/volcano-liu/p/10681399.html

时间: 2024-10-06 21:07:35

ThreadLocal使用和原理简析的相关文章

Java Annotation 及几个常用开源项目注解原理简析

PDF 版: Java Annotation.pdf, PPT 版:Java Annotation.pptx, Keynote 版:Java Annotation.key 一.Annotation 示例 Override Annotation Java 1 2 3 @Override public void onCreate(Bundle savedInstanceState); Retrofit Annotation Java 1 2 3 @GET("/users/{username}&quo

[转载] Thrift原理简析(JAVA)

转载自http://shift-alt-ctrl.iteye.com/blog/1987416 Apache Thrift是一个跨语言的服务框架,本质上为RPC,同时具有序列化.发序列化机制:当我们开发的service需要开放出去的时候,就会遇到跨语言调用的问题,JAVA语言开发了一个UserService用来提供获取用户信息的服务,如果服务消费端有PHP/Python/C++等,我们不可能为所有的语言都适配出相应的调用方式,有时候我们会很无奈的使用Http来作为访问协议;但是如果服务消费端不能

cgroup原理简析:进程调度

本篇来探究下cgroup对cpu的限制机制,前文提到过cgroup也是通过进程调度子系统来达到限制cpu的目的,因此需要了解下进程调度子系统. 因为是介绍cgroup的文章,因此只介绍进程调度中与cgroup密切关联的部分,详细完成的进程调度实现可参考进程调度的相关资料. 本文分为三个部分,首先介绍进程调度中的调度算法,在该基础上引入组调度,最后结合前面文章(cgroup原理简析:vfs文件系统)来说明上层通过echo pid >> tasks, echo n > cpu.shares等

Java Android 注解(Annotation) 及几个常用开源项目注解原理简析

不少开源库(ButterKnife.Retrofit.ActiveAndroid等等)都用到了注解的方式来简化代码提高开发效率. 本文简单介绍下 Annotation 示例.概念及作用.分类.自定义.解析,并对几个 Android 开源库 Annotation 原理进行简析.PDF 版: Java Annotation.pdf, PPT 版:Java Annotation.pptx, Keynote 版:Java Annotation.key 完整版原文见:Java Android 注解(Ann

SIFT特征原理简析(HELU版)

SIFT(Scale-Invariant Feature Transform)是一种具有尺度不变性和光照不变性的特征描述子,也同时是一套特征提取的理论,首次由D. G. Lowe于2004年以<Distinctive Image Features from Scale-Invariant Keypoints[J]>发表于IJCV中.开源算法库OpenCV中进行了实现.扩展和使用. 本文主要依据原始论文和网络上相关专业分析,对SIFT特征提取的算法流程进行简单分析.由于涉及到的知识概念较多,本人

ARP攻击原理简析及防御措施

0x1  简介 网络欺骗攻击作为一种非常专业化的攻击手段,给网络安全管理者,带来严峻的考验.网络安全的战场已经从互联网蔓延到用户内部的网络, 特别是局域网.目前利用ARP欺骗的木马病毒在局域网中广泛传播,导致网络随机掉线甚至整体瘫痪,通讯被窃听,信息被篡改等严重后果. 0x2  ARP协议概述 ARP协议(address resolution protocol)地址解析协议 一台主机和另一台主机通信,要知道目标的IP地址,但是在局域网中传输数据的网卡却不能直接识别IP地址,所以用ARP解析协议将

spring security使用和原理简析(2)

转自https://pjmike.github.io/2018/10/12/%E6%B5%85%E6%9E%90Spring-Security-%E6%A0%B8%E5%BF%83%E7%BB%84%E4%BB%B6/ 上一篇我们主要讲述了如何搭项目,这里我们就来简单探究一下原理 Spring Security的核心类 Spring Security的核心类主要包括以下几个: SecurityContextHolder: 存放身份信息的容器 Authentication: 身份信息的抽象接口 A

iOS Block原理简析

Block的语法 Block是iOS闭包的实现方式,能够获取局部变量的匿名函数. Block的OC声明 返回值类型 (^Block变量名字)(参数列表) = (参数列表){}; 例子 int (^add)(int a,int b) = ^(int a, int b) { return a + b; }; int sum = add(1,4); NSLog(@"sum = %d",sum); NSString* (^getFullName)(NSString *first,NSStrin

Android热补丁技术—dexposed原理简析(手机淘宝采用方案)

本文由嵌入式企鹅圈原创团队成员.阿里资深工程师Hao分享. 上篇文章<Android无线开发的几种常用技术>我们介绍了几种android移动应用开发中的常用技术,其中的热补丁正在被越来越多的开发团队所使用,它涉及到dalvik虚拟机和android的一些核心技术,现在就来介绍下它的一些原理. 本篇先介绍dexposed方案:https://github.com/alibaba/dexposed,它是手机淘宝团队使用的热补丁方案,后来开源到github上,取的名字dexposed表明了自己是基于