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

Java-ThreadLocal

在并发编程里,有时候我们需要让每个线程保存自己的私有数据,不想被其他线程干扰,这时候,`ThreadLocal` 就派上用场了。ThreadLocal 不是线程,而是为线程准备的私有数据仓库。

一、ThreadLocal是什么?核心作用是什么?它是怎么解决多线程共享变量的冲突的?

用一句话解释:每个线程有自己的小抽屉,别人看不见。什么时候用?典型场景:用户上下文、数据库连接、日志 TraceId 等。

二、核心结构

Thread、ThreadLocalMap、ThreadLocal三者关系

[Thread] └─ ThreadLocalMap├─ (ThreadLocalA, valueA)├─ (ThreadLocalB, valueB)

ThreadLocalMap 挂在线程身上,不是 ThreadLocal 身上。ThreadLocal 自己只是钥匙,负责把值放到线程的小抽屉里。

三、源代码核心

get和set源码最关键的逻辑

public T get() {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);...
}
public void set(T value) {Thread t = Thread.currentThread();ThreadLocalMap map = getMap(t);...
}

Thread.currentThread() 找到自己。ThreadLocalMap 是真正存东西的地方。key 是 ThreadLocal 自己(this),value 是你要放入的值。

四、WeakReference与内存泄漏

  • 强引用:我们常常new出来的对象就是强引用类型,只要强引用存在,垃圾回收器将永远不会回收被引用的对象,哪怕内存不足的时候
  • 软引用:使用SoftReference修饰的对象被称为软引用,软引用指向的对象在内存要溢出的时候被回收
  • 弱引用:使用WeakReference修饰的对象被称为弱引用,只要发生垃圾回收,若这个对象只被弱引用指向,那么就会被回收
  • 虚引用:虚引用是最弱的引用,在 Java 中使用 PhantomReference 进行定义。虚引用中唯一的作用就是用队列接收对象即将死亡的通知

ThreadLocalMap 里 key 是弱引用

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

如果ThreadLocal没引用了,key会被GC回收,但value还在,形成泄漏,因此推荐remove(),用完手动清理。

五·一、小例子

示例一:一个线程写私有值,这是验证 ThreadLocal 是当前线程私有存取容器 的最小闭环。

ThreadLocal<String> tl = new ThreadLocal<>();//造钥匙,准备给某个线程存私货
tl.set("hello");//把值塞到当前main线程的ThreadLocalMap里
System.out.println(tl.get());  // 用同一把钥匙去翻找,能拿回“hello”

示例二:多个线程隔离示例

ThreadLocal<Integer> tl = new ThreadLocal<>();//造钥匙
//下边启动五个线程
for (int i = 0; i < 5; i++) {int num = i;new Thread(() -> {tl.set(num);//把自己的 num 值放到自己线程的小抽屉(ThreadLocalMap)里System.out.println(Thread.currentThread().getName() + " -> " + tl.get());}).start();
}

虽然 5 个线程都用的是 同一把 tl,但是它们访问的 ThreadLocalMap 是自己线程私有的,所以:线程1放0,线程2放1......线程5放4。每个线程对同一个 ThreadLocal 只能拿到自己放进去的值。

五·二、再来

注释都写在代码中,有些长拖着看

import java.util.ArrayList;
import java.util.List;public class ThreadLocalTest {private List<String> messages = new ArrayList<>();public static final ThreadLocal<ThreadLocalTest> holder = ThreadLocal.withInitial(ThreadLocalTest::new); // 定义了一个 ThreadLocal,类型是 ThreadLocal<ThreadLocalTest>,每个线程里面都有自己的一份 ThreadLocalTest 对象。public static void add(String msg) { // 这个对象里有个 List<String> messages,相当于:每个线程都有一份“自己的私有 List”。holder.get().messages.add(msg); // 找当前线程自己的 ThreadLocalTest 对象。messages.add(msg):把消息塞进去。}public static List<String> clear() { // 拿到当前线程的List然后打印一下size,remove():把这个线程的 ThreadLocal 清理掉,防止内存泄漏。List<String> messages = holder.get().messages;holder.remove();System.out.println("size is " + messages.size());return messages;}// 下边启动了 10 个线程,每个线程往自己的 ThreadLocalTest 的 messages 里加一条 "msgX",再把自己那份 messages 打印出来。public static void main(String[] args) {Thread[] threads = new Thread[10];for (int i = 0; i < 10; i++) {int j = i;threads[i] = new Thread(() -> {ThreadLocalTest.add("msg" + j);List<String> messages = holder.get().messages;System.out.println(messages);});threads[i].start();}}
}

ThreadLocal 保证了:每个线程有自己的 ThreadLocalTest1 对象,互不干扰;同一个静态 holder,放进去的却是每个线程自己的 ThreadLocalMap 里的一份,所以即使你写了 static,每个线程也完全隔离,这就是 ThreadLocal 的意义。

http://www.xdnf.cn/news/1123759.html

相关文章:

  • java基础(day07)
  • 打开xmind文件出现黑色
  • 【LeetCode 热题 100】94. 二叉树的中序遍历——DFS
  • 13.计算 Python 字符串的字节大小
  • SpringMVC2
  • 鸿蒙开发NDK之---- 如何将ArkTs的类型转化成C++对应的类型(基础类型,包含部分代码解释)
  • 修改主机名颜色脚本
  • 虚拟货币交易:游走在合法与犯罪的生死线
  • 在Adobe Substance 3D Painter中,已经有基础图层,如何新建一个图层A,clone基础图层的纹理和内容到A图层
  • Java:继承和多态(必会知识点整理)
  • 【React Natve】NetworkError 和 TouchableOpacity 组件
  • Python 基础语法2:组合数据类型、异常
  • 【深度学习框架终极PK】TensorFlow/PyTorch/MindSpore深度解析!选对框架效率翻倍
  • JavaScript中Object.defineProperty的作用和用法以及和proxy的区别
  • SSM框架学习——day1
  • Datawhale AI夏令营-基于带货视频评论的用户洞察挑战赛
  • AI Linux 运维笔记
  • Imx6ull用网线与电脑连接
  • 使用 pytest 测试框架构建自动化测试套件之一
  • ethers.js-5–和solidity的关系
  • pytorch学习1(DataSet+Transforms+TensorBoard)
  • LeetCode 692题解 | 前K个高频单词
  • 工业软件加密锁复制:一场技术与安全的博弈
  • Lovable - AI 驱动的全栈应用开发平台
  • PyTorch张量(Tensor)创建的方式汇总详解和代码示例
  • [笔记] 动态 SQL 查询技术解析:构建灵活高效的企业级数据访问层
  • Linux:1_Linux下基本指令
  • TCP心跳机制详解
  • 使用axios向服务器请求信息并渲染页面
  • 如何在服务器上运行一个github项目