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

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.xdnf.cn/news/15383.html

相关文章:

  • 131. Java 泛型 - 目标类型与泛型推断
  • RNN(循环神经网络)
  • js与vue基础学习
  • Cesium源码打包
  • 从数据库到播放器:Java视频续播功能完整实现解析
  • Netty编程模型介绍
  • 聚宽sql数据库传递
  • 【WPF】WPF 自定义控件 实战详解,含命令实现
  • Node.js + Express的数据库AB View切换方案设计
  • 渗透笔记1-4
  • vim扩展
  • Spring Boot Cucumber 测试报告嵌入方法
  • Linux 基础命令详解:从入门到实践(1)
  • 微前端框架深度对决:qiankun、micro-app、wujie 技术内幕与架构选型指南
  • MFC UI表格制作从专家到入门
  • MyBatis 在执行 SQL 时找不到名为 name 的参数
  • Unsloth 实战:DeepSeek-R1 模型高效微调指南(下篇)
  • LeetCode 424.替换后的最长重复字符
  • Android展示加载PDF
  • 深入学习前端 Proxy 和 Reflect:现代 JavaScript 元编程核心
  • HarmonyOS应用无响应(AppFreeze)深度解析:从检测原理到问题定位
  • 深入理解Transformer:编码器与解码器的核心原理与实现
  • C++ STL算法
  • C++_编程提升_temaplate模板_案例
  • 传统机器学习在信用卡交易预测中的卓越表现:从R²=-0.0075到1.0000的华丽转身
  • 复习笔记 38
  • vue3+arcgisAPI4示例:自定义多个气泡窗口展示(附源码下载)
  • (三)OpenCV——图像形态学
  • 第8天:LSTM模型预测糖尿病(优化)
  • 2025年采购管理系统深度测评