当前位置: 首页 > news >正文

java--ThreadLocal创建以及get源码解析

1.Supplier 

        在了解ThreadLocal之前先来理解什么是Supplier 

        在 Java 中,Supplier 是一个函数式接口,位于 java.util.function 包下,用于定义不接受参数但返回值的操作。它是 Java 8 引入的函数式编程特性之一,常用于延迟计算或提供默认值的场景。

1. Supplier 接口的定义

java

@FunctionalInterface
public interface Supplier<T> {T get(); // 唯一的抽象方法,返回类型为T的对象
}
  • 特点
    • 仅包含一个无参数的抽象方法 get()
    • 可用作 Lambda 表达式或方法引用的目标类型。

2. 核心用途

  1. 延迟计算
    只有在需要结果时才执行计算,避免不必要的资源消耗。

  2. 提供默认值
    为方法或变量提供默认生成逻辑,例如 ThreadLocal.withInitial()

3. 使用示例

public class Cat {@Overridepublic String toString() {return "Cat{" +"name='" + name + '\'' +'}';}String name = "aa";private static String getName(){return "aa";}public static void main(String[] args) {// Supplier<String> supplier = xxxx; xxxx只能是static方法或者构造方法Supplier<String> supplierGetName = Cat::getName;Supplier<Cat> supplierCat = Cat::new;String name = supplierGetName.get();Cat cat1 = supplierCat.get();System.out.println(cat1); //Cat{name='aa'}System.out.println(name); //aa}
}

所以我们看到对于supplier可以使用get方法获取对应的函数的返回值

2.什么ThreadLocal

        ThreadLocal 是 Java 中用于实现线程局部变量的核心类,它提供了线程级别的数据隔离机制。每个线程都可以通过 ThreadLocal 独立访问自己的数据副本,不同线程之间的数据互不干扰。

        

  • 每个 Thread 对象内部有一个 ThreadLocalMap(类似 HashMap)

  • ThreadLocal 作为 Key,存储的值作为 Value

     重点:   ThreadLocal 变量本身(即定义的那个ThreadLocal对象)是共享的被所有线程访问。但每个线程通过它获取到的值却是各自独立的。如下图也就是说线程Thread1和Thread2里面的ThreadLocalMap是不同的,ThreadLocalMap中以key-value的形式进行存储,其中ThreadLocal 作为 Key,存储的值作为 Value,而每个 Thread 对象内部有一个 ThreadLocalMap,所以根据线程找到对应的ThreadLocalMap,再根据ThreadLocal 作为 Key找到存储的Value的值

3.ThreadLocal的创建以及get解析

public class ThreadLocalTest {private List<String> messages = new ArrayList<>();public static final ThreadLocal<ThreadLocalTest> holder = ThreadLocal.withInitial(ThreadLocalTest::new);public static void add(String message) {holder.get().messages.add(message);}public static void main(String[] args) {Thread t = new Thread(() -> {ThreadLocalTest.add("hello");System.out.println(ThreadLocalTest.holder.get().messages);});ThreadLocalTest.add("你好");System.out.println(holder.get().messages);}
}

1.分析withInitial方法都做了什么

 public static final ThreadLocal<ThreadLocalTest> holder =         ThreadLocal.withInitial(ThreadLocalTest::new);

        1.点进withInitial方法我们可以看到

       2.再次点进SuppliedThreadLocal方法

                        

//验证要求不为空值 
public static <T> T requireNonNull(T obj) {if (obj == null)throw new NullPointerException();return obj;}

        我们可以看到上面代码就相当于将suppplier赋值了ThreadLocalTest::new,并返回了SuppliedThreadLocal类型的对象

这也就是 ThreadLocal.withInitial(ThreadLocalTest::new);的全过程

2.分析holder.get()方法都做了什么

     首先我们先了解Thread类中有个初始值为null的ThreadLocalMap对象

         还要了解ThreadLocal类中getMap方法是获取Thread类的ThreadLocalMap对象

     以及ThreadLocal类中createMap方法是设置当前线程[Thread类]中的threadLocals的值

    //t为传入的线程,firstValue为一个对象void createMap(Thread t, T firstValue) {//在当前例子中执行【get方法】//以key为holder对象,firstValue为initialValue方法返回的ThreadLocalTest的实例对象//给threadLocals赋值t.threadLocals = new ThreadLocalMap(this, firstValue);}

点进get方法

//ThreadLocal类中的 get方法public T get() {Thread t = Thread.currentThread(); //获取当前线程//获取当前线程的threadLocals属性的值,由于初次访问Thread中的threadLocals值为null//上边有提到过[ThreadLocalMap]threadLocals为nullThreadLocalMap map = getMap(t); if (map != null) {//如果不为null,根据当前对象作为key获取map的键值对并ThreadLocalMap.Entry e = map.getEntry(this);if (e != null) {@SuppressWarnings("unchecked")T result = (T)e.value;return result;}}//初次访问map肯定为null,所以走下面的代码return setInitialValue();}//ThreadLocal类中的 setInitialValue方法private T setInitialValue() {T value = initialValue();//获取ThreadLocalTest的实例对象Thread t = Thread.currentThread(); //获取当前线程ThreadLocalMap map = getMap(t); //初次get方法map肯定为null,使用get方法肯定不会走if (map != null)//因为如果map不为null,那么在上边的get方法就直接返回ThreadLocalTest的实例对象了,        //就不会进入setInitialValue方法了if (map != null)map.set(this, value);//必走这个elsecreateMap(t, value); //设置当前线程[Thread]中的threadLocals的值return value;}//ThreadLocal类中的 initialValue方法protected T initialValue() {return null;}//这个方法是SuppliedThreadLocal类中重写ThreadLocal类的initialValue方法
//至于为什么走SuppliedThreadLocal中的initialValue呢?
//因为在ThreadLocal<ThreadLocalTest> holder =         //ThreadLocal.withInitial(ThreadLocalTest::new)//ThreadLocal.withInitial(ThreadLocalTest::new)返回的其实是SuppliedThreadLocal类型//即上述代码为父类的引用指向子类的对象,所以调用的时候调用的是子类的initialValue方法@Overrideprotected T initialValue() {//supplier为第一步ThreadLocal.withInitial(ThreadLocalTest::new)过程中赋值的supplier//supplier的值为ThreadLocalTest::newreturn supplier.get();  //返回ThreadLocalTest的实例对象}}
http://www.dtcms.com/a/279937.html

相关文章:

  • http常见状态码
  • 苦练Python第18天:Python异常处理锦囊
  • 【论文阅读】Masked Autoencoders Are Effective Tokenizers for Diffusion Models
  • rsyslog简单应用
  • STM32F769I-DISCO 串口调试
  • Linux上基于C/C++头文件查找对应的依赖开发库
  • SAP B1认证资料-题目
  • 分布式系统中实现临时节点授权的高可用性与一致性
  • 哈希扩展 --- 海量数据处理
  • CISSP知识点汇总- 通信与网络安全
  • 15.Python 列表元素的偏移
  • Java学习————————ThreadLocal
  • python Gui界面小白入门学习二
  • python高阶调试技巧,替代print
  • 14.推荐使用 dict.get(key) 而不是 dict[key]
  • redis配置(Xshell连接centos7的基础上)
  • Modbus 开发工具实战:ModScan32 与 Wireshark 抓包分析(一
  • Python `WeakValueDictionary` 用法详解
  • 调用 System.runFinalizersOnExit() 的风险与解决方法
  • C语言基础5——控制语句2(循环)
  • TypeScript枚举类型应用:前后端状态码映射的最简方案
  • 深入学习前端 Proxy 和 Reflect:现代 JavaScript 元编程核心
  • Java并发编程之线程池详解
  • openGL学习(Shader)
  • 【面板数据】全国地级市逐日空气质量指数AQI数据集(2013-2024年)
  • 代码随想录算法训练营第四十九天|单调栈part2
  • Java强化:IO流
  • 正则表达式替换中使用 g<0> 引用整个匹配的内容
  • vim扩展与 neovim
  • IOS开发者账号如何添加 uuid 原创