【多线程】ThreadLocal 详解,举例说明

news2024/11/15 23:36:30

不理解多线程的同学可先了解多线程理论篇【多线程】线程是什么?多线程为什么?怎么做?通俗易懂讲解多线程
以及多线程进阶篇【多线程】多线程安全,为什么不安全,要怎么做保证其安全,实例

1、ThreadLocal是什么

ThreadLocal 是 Java 中的一个线程级别的变量,用于在多线程环境下保持变量的独立性。每个线程都可以独立地设置和获取 ThreadLocal 的值,而不会影响其他线程。通常情况下,ThreadLocal 被用来在方法或类之间传递变量。

在这里插入图片描述

如上图所示,每一个线程都拥有一个 ThreadLocalMap,下图是Thread.java源码 。ThreadLocalMap 中存放的是EntryEntryThreadLocalvalue 的映射。

在这里插入图片描述

ThreadLocal 的实现原理是通过维护一个 Map,其中键为线程 ID,值为变量的值。每个线程都有一个唯一的 ID,通过这个 ID 将变量与线程关联起来。当调用 ThreadLocalget 方法时,会根据当前线程的 ID 获取对应的值。当调用 set 方法时,会根据当前线程的 ID 设置对应的值。

  • Thread
    线程是Java程序中的基本执行单元。每个线程都有自己的执行栈和程序计数器,但它们之间共享堆内存。在多线程环境下,多个线程可能同时访问相同的变量,可能导致线程安全问题。
  • ThreadLocal
    ThreadLocal 提供了一种将变量与线程关联的机制。它使用 ThreadLocal对象来保存每个线程的变量副本。每个 ThreadLocal 对象都是线程私有的,不同线程之间互不影响。ThreadLocal 通常作为类的私有静态字段存在。
  • ThreadLocalMap
    ThreadLocalMapThreadLocal 内部使用的一个哈希表结构,用于存储每个 ThreadLocal 与其对应值的映射关系。每个 Thread 对象都有一个 ThreadLocalMap ,用于存储该线程所有 ThreadLocal 变量的值。
  • Entry
    Entry是 ThreadLocalMap内部的一个静态内部类,用于表示 ThreadLocal 与值的映射关系。每个 ThreadLocalMap 实际上是一个Entry数组,数组中的每个元素都是一个Entry对象,表示一个 ThreadLocal 与其对应值的映射关系。

在这里插入图片描述
如上图所示 ThreadLocalMap 是 ThreadLocal 的静态内部类,当线程第一次执行set时,ThreadLocal会创建一个ThreadLocalMap对象,设置给Thread的threadLocals变量。当前线程初始化 ThreadLocal 的时候,会将ThreadLocal 作为key值,放在 ThreadLocalMap 中。不同的线程访问的是同一个ThreadLocal,但是用相同的 ThreadLocal,去各自的ThreadLocalMap中找对应的值。这样就能保证该值为自己线程独有。

ThreadLocal的工作原理如下:
下图是 ThreadLocal.java 中的 get()set()方法。

  • 当通过 ThreadLocal 的 set 方法设置变量时,实际上是通过当前线程的ThreadLocalMapThreadLocal 与值关联起来。
  • 当通过 ThreadLocalget 方法获取变量时,实际上是通过当前线程的ThreadLocalMap 查找与之关联的值。
  • ThreadLocalMap 使用 ThreadLocal 的弱引用作为 key,以防止内存泄漏。当 ThreadLocal 被回收时,对应的映射关系也会被清理。

这种机制使得每个线程都可以拥有自己的变量副本,互不干扰。ThreadLocal通过这种方式解决了多线程环境下共享变量的线程安全问题。
在这里插入图片描述
在这里插入图片描述

2、为什么使用 ThreadLocal

  • 线程隔离ThreadLocal 提供了一种线程隔离的机制,使得每个线程都可以拥有自己的变量,互不干扰。
  • 避免参数传递: 在多线程环境下,为了传递变量,常常需要在方法之间传递参数。使用 ThreadLocal 可以避免参数传递的繁琐工作,提高代码的简洁性。
  • 线程上下文共享: 在某些情况下,需要在多个方法之间共享某个值,但又不希望使用全局变量。ThreadLocal 提供了一种线程级别的共享机制。

3、ThreadLocal使用方法:

public class Example {
    private static ThreadLocal<String> threadLocal = new ThreadLocal<>();

    public static void main(String[] args) {
        // 在线程中设置值
        threadLocal.set("Hello, ThreadLocal!");

        // 在不同的方法中获取值
        method1();
        method2();
    }

    public static void method1() {
        // 从当前线程获取值
        String value = threadLocal.get();
        System.out.println("Method 1: " + value);
    }

    public static void method2() {
        // 从当前线程获取值
        String value = threadLocal.get();
        System.out.println("Method 2: " + value);
    }
}

需要注意的是,在使用完 ThreadLocal 后,尤其是在线程池等场景,应该及时调用 remove 方法,以避免内存泄漏。可以使用 ThreadLocal.remove() 或者使用 try-with-resources 语句块。

public class Example {
    private static ThreadLocal<String> threadLocal = new ThreadLocal<>();

    public static void main(String[] args) {
        try {
            threadLocal.set("Hello, ThreadLocal!");

            // 在不同的方法中获取值
            method1();
            method2();
        } finally {
            // 及时清理 ThreadLocal,避免内存泄漏
            threadLocal.remove();
        }
    }

    // ...
}

在 Java 8 之后, ThreadLocal 还引入了 withInitial 方法,可以在创建 ThreadLocal 实例的同时初始化其值,进一步简化了使用。

3、实例

import java.util.concurrent.atomic.AtomicInteger;

public class ThreadLocalExample {

    private static final ThreadLocal<Integer> threadLocal1 = new ThreadLocal<>();
    private static final ThreadLocal<String> threadLocal2 = new ThreadLocal<>();
    private static final AtomicInteger counter = new AtomicInteger(0);

    public static void main(String[] args) {
        Thread thread1 = new Thread(() -> {
            int value = counter.incrementAndGet();
            threadLocal1.set(value);
            threadLocal2.set("Thread " + value);
            printValues("Thread 1");
        });

        Thread thread2 = new Thread(() -> {
            int value = counter.incrementAndGet();
            threadLocal1.set(value);
            threadLocal2.set("Thread " + value);
            printValues("Thread 2");
        });

        thread1.start();
        thread2.start();
    }

    private static void printValues(String threadName) {
        System.out.println(threadName + " - threadLocal1: " + threadLocal1.get());
        System.out.println(threadName + " - threadLocal2: " + threadLocal2.get());
        System.out.println("---");
    }
}

在这个例子中,两个线程分别递增 counter 并将其值设置到两个不同的 ThreadLocal 变量中。通过 printValues 方法打印每个线程的 ThreadLocal 变量值。由于每个线程有自己的 ThreadLocal 副本,它们之间不会互相干扰。
输出:
在这里插入图片描述

解释: 在这个代码中,有两个线程:thread1 和 thread2。它们共享一个 counter 变量,并使用 threadLocal1 和 threadLocal2 来存储线程本地的值。
.
thread1 启动,counter 的值为0,counter.incrementAndGet() 将 counter 的值增加为1,然后将1设置到 threadLocal1 和 threadLocal2 中。输出线程1的本地值。
.
thread2 启动,counter 的值为1,counter.incrementAndGet() 将 counter 的值增加为2,然后将2设置到 threadLocal1 和 threadLocal2 中。输出线程2的本地值。
.
因为 ThreadLocal 提供了线程本地的变量副本,所以每个线程都可以独立维护自己的值,互不干扰。这就是为什么输出结果中会有 Thread 1 - threadLocal1: 1 和 Thread 2 - threadLocal1: 2 的原因。
.
输出的顺序可能会有差异,因为线程调度的执行顺序不确定。但是每个线程内部的输出是一致的。

更多实践参考:【多线程】ThreadLocal 作为类的私有静态字段实践

持续更新中。。。

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/1410261.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

快速入门Playwright框架:从零到自动化测试的第一步

Playwright框架&#xff1a; 背景介绍&#xff1a; ​ Playwright 是微软开发的 Web应用 的 自动化测试框架 。selenium相对于Playwright慢很多&#xff0c;因为Playwright是异步实现的&#xff0c;但是selenium是同步的&#xff0c;就是后一个操作必须等待前一个操作。 sel…

Python添加、修改和删除列表元素

Python 是一种简洁而强大的编程语言&#xff0c;广泛用于不同领域的软件开发和数据分析中。在 Python 中&#xff0c;列表&#xff08;List&#xff09;是一种非常常用的数据类型&#xff0c;用于存储一组元素并按顺序访问。本文将讨论如何在 Python 中对列表进行添加、修改和删…

[极客大挑战 2019]Upload1

直接上传php一句话木马&#xff0c;提示要上传image 把文件名改成gif并加上gif文件头后&#xff0c;绕过了对image类型的检测&#xff0c;但是提示文件内含有<?&#xff0c;且bp抓包后改回php也会被检测 那我们考虑使用js执行php代码 <script languagephp>eval($_PO…

mysql生成最近24小时整点最近30天最近12个月时间临时表

文章目录 生成最近24小时整点生成最近30天生成最近12个月 在统计的时候需要按时间来展示&#xff0c;但是数据的时间不一定是连续的&#xff0c;那就需要在代码里面生成连续的时间&#xff0c;然后按时间匹配到对应的数据&#xff0c;这样比较麻烦&#xff0c;可以在sql中使用连…

Transfomer相关最新研究

文章目录 LogTrans * (有代码&#xff09;TFT &#xff08;有代码&#xff09;InfluTran &#xff08;有代码&#xff09;Informer *&#xff08;有代码&#xff09;&#xff08;长时间&#xff09;ProTranAutoformer ***&#xff08;有代码&#xff09;AliformerPyraformer &a…

[蓝桥学习] 前缀和与差分

前缀和原理 特点 求区间和 如果要实现一边修改一边查询&#xff0c;需要使用树状树组和线段树。 例题 题目很简单&#xff0c;但是代码实现惊艳到我了&#xff0c;是L就加1&#xff0c;是Q就减1&#xff0c;如果区间 [i,j] 是平衡子串的话&#xff0c;那它会在前缀prefix i …

自己本机Video retalking制作数字人

首先需要注意的是&#xff0c;这个要求你的笔记本显存和内存都比较大。我的电脑内存是64G&#xff0c;显卡是8G&#xff0c;操作系统是Windows 11&#xff0c;勉强能够运行出来&#xff0c;但是效果不是很好。 效果如下&#xff0c;无法上传视频&#xff0c;只能通过图片展示出…

C++是如何发展起来的?如何学习C++呢?

一、什么是C C语言是结构化和模块化的语言&#xff0c;适合处理较小规模的程序。对于复杂的问题&#xff0c;规模较大的程序&#xff0c;需要高度的抽象和建模时&#xff0c;C语言则不合适。为了解决软件危机&#xff0c; 20世纪80年代&#xff0c; 计算机界提出了OOP(object …

YOLO 自己训练一个模型

一、准备数据集 我的版本是yolov8 8.11 这个目录结构很重要 ultralytics-main | datasets|coco|train|val 二、训练 编写yaml 文件 # Train/val/test sets as 1) dir: path/to/imgs, 2) file: path/to/imgs.txt, or 3) list: [path/to/imgs1, path/to/imgs2, ..] path…

(超全七大错误)Invalid bound statement (not found): com.xxx.dao.xxxDao.add

1.确保你把dao和mapper都在applicationContext.xml中都扫描了 xml文件 <bean id"sqlSessionFactory" class"org.mybatis.spring.SqlSessionFactoryBean"><property name"dataSource" ref"dataSource"/><property nam…

机器学习算法(一)

一、线性回归 线性回归&#xff08;Linear Regression&#xff09;可能是最流行的机器学习算法。线性回归就是要找一条直线&#xff0c;并且让这条直线尽可能地拟合散点图中的数据点。它试图通过将直线方程与该数据拟合来表示自变量&#xff08;x 值&#xff09;和数值结果&am…

sql管理工具archery简介

在平时的工作过程中&#xff0c;我们肯定会遇到使用sql平台的场景&#xff0c;业内也有很多工具&#xff0c;类似阿里云的dms&#xff0c;但是这个是和云厂商绑定的&#xff0c;我们可能一般没有用到阿里云组件就比较困难了&#xff0c;那还有什么选项了&#xff0c;经过调研&a…

自学C语言-6

第6章 选择结构程序设计 顺序结构程序设计最简单&#xff0c;但通常无法解决生活中的选择性问题。选择结构程序设计需要用到一些条件判断语句&#xff0c;可实现的程序功能更加复杂&#xff0c;程序的逻辑性与灵活性也更加强大。 本章致力于使读者掌握使用if语句进行条件判断的…

14.点亮 LED 灯

14.点亮 LED 灯 1. 应用层操控硬件的两种方式1.1 sysfs 文件系统1.2 sysfs 与 /sys1.3 总结 2. LED 硬件控制方式3. 编写 LED 应用程序4. 在开发板上测试 1. 应用层操控硬件的两种方式 应用层如何操控底层硬件&#xff0c;同样也是通过文件 I/O 的方式来实现&#xff0c;设备文…

python基础——锁

进程锁 (互斥锁) 进程锁的引入&#xff1a; 模拟抢票程序&#xff1a; from multiprocessing import Process import json import time def show_ticket(i):with open("./tickets.txt",mode"r",encoding"utf-8") as file:ticket json.load(f…

2024.1.22力扣每日一题——最大交换

2024.1.22 题目来源我的题解方法一 暴力法方法一 哈希表贪心方法三 贪心 题目来源 力扣每日一题&#xff1b;题序&#xff1a;670 我的题解 方法一 暴力法 直接暴力对数字中的每两个位置进行交换&#xff0c;然后记录交换后生成数字的最大值 时间复杂度&#xff1a;O( log ⁡…

下拉回显问题案例大全

下拉回显问题案例大全 一、原生js案例 <!DOCTYPE html> <html lang"en"><head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>下拉框数据回…

13. 高级IO

13. 高级IO 1. 非阻塞 IO1.1 阻塞 IO 与非阻塞 IO 读文件 2. IO 多路复用2.1 何为 IO 多路复用2.2 select()2.3 poll()2.3.1 struct pollfd2.3.2 poll() 返回值2.3.3 示例 3. 异步 IO3.1 O_ASYNC3.2 设置异步 IO 事件的接收进程3.3 示例 4. 优化异步 IO4.1 使用实时信号替换默认…

android:persistent和android:priority的区别,对进程优先级有什么影响?

前言&#xff1a;写的apk因为系统busy给我kill了&#xff0c;(adj 900): kill all background&#xff0c;在AndroidManifest.xml添加android:persistent"true"后&#xff0c;被甲方要求不能这样做&#xff0c;还是得从adj改&#xff0c;把 priority改成1000 android…

ES6.8.6 为索引映射(Mapping)创建自定义分词器,测试分词匹配效果

文章目录 环境创建索引&#xff1a;配置自定义分词器、字段指定分词器自定义分词器参数说明创建索引&#xff1a;custom_analyzer_comment 使用索引中自定义的分词器进行分词分析自定义分词器my_custom_analyzer分词测试&#xff1a;测试中文停用词、英文字母转小写测试敏感词替…