ThreadLocal深度解析

简介

在并发编程中,导致并发bug的问题都会归结于对共享变量的操作不当。多个线程同时读写同一共享变量存在并发问题,我们可以利用写时复制、不变性来突破对原数据的写操作,没有写就没有并发问题,而本篇文章所介绍的技术是突破共享变量,没有共享变量也不会有并发问题。

Java中避免线程共享的一大利器就是ThreadLocal,我们本篇文章重点讲述它的底层原理、常见的一些用途、创建和使用等。

首先介绍一下它是什么:

  • ThreadLocal 是 Java 的一个类,位于 java.lang 包下。它为每一个线程提供了一个独立的变量副本,使得每个线程可以独立地改变自己的副本,而不会影响其他线程所对应的副本。

它的主要作用就是避免线程间共享,除此之外还能避免无必要的同步以及降低变量使用的复杂度:

  • 线程隔离:在多线程环境下,ThreadLocal 可以为每一个线程提供一个独立的变量实例。因此,每个线程都可以独立地操作该变量,而不需要考虑并发问题。这种特性使得 ThreadLocal 成为一个非常方便的保存线程状态或线程局部变量的工具。
  • 避免无必要的同步:由于每个线程都有其自己的变量副本,所以它们可以无需任何同步措施就可以访问这些变量,从而提高了程序的执行效率。
  • 降低复杂度:在某些场景下,如果需要通过参数传递线程局部变量,可能会使得方法签名和调用变得复杂。使用 ThreadLocal 可以避免这种复杂性,因为它允许我们在任何地方获取到线程相关的数据。

工作原理

我们在学习ThreadLocal的时候,如果不了解其底层实现的话,通常会进入一个误区:ThreadLocal类里面维护了一个Map,这个Map的key为线程引用,值为自己设置的值。其实Java真正的实现是ThreadLocal仅是一个工具类,提供线程对数据的访问,实际真正拥有这个数据的角色是线程自身(这也解释了简介中提到的每个线程都有针对某一变量的副本),如下图所示:

在这里插入图片描述

相信大家会有这样一个疑问:为什么Java没有按照我们预想的那样实现呢?其主要原因就是:不容易造成内存泄漏。假设Java按照我们预想的方案实现,我们分析下会造成什么样的问题:ThreadLocal 持有的 Map 会持有 Thread 对象的引用,这就意味着,只要 ThreadLocal 对象存在,那么 Map 中的 Thread 对象就永远不会被回收。ThreadLocal 的生命周期往往都比线程要长,所以这种设计方案很容易导致内存泄露。而 Java 的实现中 Thread 持有 ThreadLocalMap,而且 ThreadLocalMap 里对 ThreadLocal 的引用还是弱引用(WeakReference),所以只要 Thread 对象可以被回收,那么 ThreadLocalMap 就能被回收。Java 的这种实现方案虽然看上去复杂一些,但是更加安全。

另外这里面的关于Entry[]大小的问题有个讨论点:为什么ThreadLocalMap中的Entry[]大小一定是2的幂次方呢?

ThreadLocalMap大小

其主要原因如下:

  • 优化索引计算:当 table 大小为 2 的次幂时,计算索引位置可以通过简单的位操作实现,而不需要执行昂贵的除法操作。例如,如果 table 大小为 16,那么为了得到一个 key 对应的索引位置,只需要计算 key的hashCode & (table.length - 1)。这种位操作比标准的模运算(%)速度快得多。
  • 均匀分布:2 的次幂大小确保了哈希值在 table 中均匀分布,减少了哈希冲突的可能性。这是因为当我们使用 hashCode & (table.length - 1) 这种方式时,hash值的低位将被有效地使用来计算索引,这在大多数情况下可以确保数据在 table 中均匀分布。
  • 容易扩容:当 table 需要扩容时(例如,当存储的元素太多,达到了负载因子的限制),新的大小可以简单地翻倍,仍然保持为 2 的次幂。
  • 历史与一致性:Java 中的其他哈希结构,如 HashMap,也使用了类似的策略,因此保持这种做法在某种程度上也是为了一致性。

总的来说,选择 2 的次幂作为 table 大小是一个优化决策,旨在提高性能、减少哈希冲突并简化内部操作。

常见用途

  1. 数据库连接:使用 ThreadLocal 保存每个线程独立的数据库连接,确保在同一线程中共享同一个数据库连接,而不是频繁地创建和销毁。
  2. 日期格式化:SimpleDateFormat 不是线程安全的,但我们可以用 ThreadLocal 来为每个线程创建独立的 SimpleDateFormat 实例,避免并发问题。
  3. Web 会话管理:在 Web 应用中,可以使用 ThreadLocal 来保存当前请求的用户会话或其他会话相关的信息。
  4. 框架中的上下文信息:许多框架使用 ThreadLocal 来保存线程级别的上下文数据,例如 Spring 中的事务管理。

创建和使用

下面使用ThreadLocal演示一下为每一个线程分配一个线程ID的代码,不同线程拥有不同的线程ID。

package com.markus.concurrent;import java.util.concurrent.atomic.AtomicLong;/*** @author: markus* @date: 2023/8/20 4:16 PM* @Description:* @Blog: https://markuszhang.com* It's my honor to share what I've learned with you!*/
public class ThreadLocalDemo {static class ThreadID {static final AtomicLong nextId = new AtomicLong(0);static final ThreadLocal<Long> tl = ThreadLocal.withInitial(nextId::incrementAndGet);public static Long get() {return tl.get();}}static class GetThreadId implements Runnable {@Overridepublic void run() {for (int i = 0; i < 3; i++) {System.out.println("Thread [" + Thread.currentThread().getName() + "],its id is " + ThreadID.get());}}}public static void main(String[] args) {Thread t1 = new Thread(new GetThreadId(), "t1");Thread t2 = new Thread(new GetThreadId(), "t2");t1.start();t2.start();}
}

控制台打印:

控制台

优势、缺点与陷阱

在多线程编程中,ThreadLocal 是一个不可或缺的工具。其主要优势在于为每个线程提供了私有的、独立的变量副本,从而消除了多线程并发访问的问题。这种独立性确保了每个线程都可以无需同步就能访问其局部变量,大大提高了程序的并发性和效率。此外,它还能简化代码结构,避免了复杂的参数传递,为线程关联上下文信息提供了便捷手段,如日志记录中的会话ID。

但是,与其带来的好处相伴的是一些潜在的陷阱。最为严重的问题是与内存泄漏相关。因为ThreadLocal 使用弱引用来引用键,但其对应的值则是强引用。如果不适时地清理,尤其是在线程生命周期结束前不调用 remove() 方法,可能会造成内存泄漏。此外,过度或不适当地使用 ThreadLocal 可能导致代码结构混乱,并降低代码的可读性和维护性。

总之,当我们在项目中使用 ThreadLocal 时,应该始终注意其潜在的陷阱和限制。正确、合理地使用 ThreadLocal 可以为我们带来很多好处,但不恰当的使用可能会引发一系列问题。在使用前,充分了解其工作机制并持续关注是非常必要的。

InheritableThreadLocal

顾名思义,可继承的ThreadLocal。我们知道ThreadLocalMap是线程持有的,每个变量都在各自的线程中保存一个副本,每个线程都能拿到自己的值,但是如果父线程创建了一个子线程,那么这个子线程是无法拿到父线程中的ThreadLocalMap中的信息的。InheritableThreadLocal的出现就是解决这个问题的。它继承自ThreadLocal,相关用法与ThreadLocal一致,这里就不介绍了。

最佳实践

  • 限制使用范围:仅在确实需要线程局部变量来解决问题时使用 ThreadLocal。不应该过度使用或在不必要的场合使用它。

  • 及时清理:

    • 一定要在不再需要线程局部变量时调用 ThreadLocalremove() 方法,以释放资源并避免潜在的内存泄漏。
    • 在 Web 容器中,例如 Tomcat,确保在请求结束后清除 ThreadLocal,因为容器可能会重用线程。
  • 避免长时间存活的线程局部变量:如果一个线程预计会长时间存活而不释放(例如线程池中的线程),那么这种线程中的 ThreadLocal 变量也会长时间存活。在这种情况下,应该特别注意清理这些变量。

  • 不要存储大对象:为了避免内存消耗,不应该在 ThreadLocal 中存储大对象或那些你不打算很快释放的对象。、

  • 考虑使用 InheritableThreadLocal:当需要在一个线程及其所有子线程之间共享一个变量时,可以考虑使用 InheritableThreadLocal。但要注意,如果子线程修改了这个变量,它不会影响到父线程中的值。

  • 考虑线程安全性:虽然 ThreadLocal 变量不需要同步来保证线程安全,但存储在其中的对象仍然可能需要同步,尤其是当多个线程可能访问同一个 ThreadLocal 变量中的同一个实例时(例如,使用 InheritableThreadLocal)。

  • 优先使用库提供的线程局部功能:有些库或框架可能已经提供了其自己的线程局部功能,例如 Java EE 和 Spring。在这种情况下,优先使用库或框架提供的功能,除非有特定的需求使得必须使用原生的 ThreadLocal

  • 不要将 ThreadLocal 作为全局变量:尽量避免将 ThreadLocal 作为静态变量,除非你确实需要这样做。静态的 ThreadLocal 变量可能会导致预料之外的问题,尤其是当类被卸载时。

  • 不建议你在线程池中使用 InheritableThreadLocal,不仅仅是因为它具有 ThreadLocal 相同的缺点——可能导致内存泄露,更重要的原因是:线程池中线程的创建是动态的,很容易导致继承关系错乱,如果你的业务逻辑依赖 InheritableThreadLocal,那么很可能导致业务逻辑计算错误,而这个错误往往比内存泄露更要命

总之,ThreadLocal 是一个有用但需要小心使用的工具。确保了解其工作原理,并始终遵循上述的最佳实践,这样可以最大化其价值并避免潜在的问题。

总结

好了,简单总结一下我们本篇讲述的内容,首先讲述了ThreadLocal是什么以及它的作用是什么,并通过图片展示ThreadLocal模型,知道了ThreadLocal其实就是一个工具类,内部不保存数据,真正保存数据的地方是在Thread本身,也就是我们常说的每个Thread都有一个变量的副本。也介绍了ThreadLocalMap中的Entry[]数组为什么大小一定要限制为2的幂次方,后面通过一段代码简单演示了ThreadLocal的使用,并再次声明了它的优势和其缺点以及使用不到出现的陷阱。讲述过程中提到了父子线程不共享变量副本的问题,而Java提供了InheritableThreadLocal解决这一问题。最终我们罗列了ThreadLocal的最佳实践。

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

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

相关文章

完美版积分商城系统-奇偶商城系统源码+独立代理后台

奇偶商城系统源码 完美版独立代理后台 1.演示环境&#xff1a;Linux Centos7以上版本 宝塔 2.Nginx 1.18.0 PHP7.0 Mysql5.6 3.伪静态选择thinkphp 4./Application/Common/Conf 修改数据库信息 详细搭建教程附在压缩包内了,下载查看

Vue3.X 路由与导航栏、侧边栏(四)

我们接着上一节的 Vue3.x 生命周期&#xff08;三&#xff09; 的说明&#xff0c;我们这一节讲解了项目中路由的配置与导航栏、侧边栏的关系。 一、路由配置 vue项目中路由配置有一个固有文件夹&#xff0c;可以配置路由&#xff0c;这样的优点使项目更加清晰明了。 如图&a…

美创科技荣获“2023年网络安全优秀创新成果大赛—杭州分站赛”两项优胜奖

近日&#xff0c;由浙江省互联网信息办公室指导、中国网络安全产业联盟&#xff08;CCIA&#xff09;主办&#xff0c;浙江省网络空间安全协会承办的“2023年网络安全优秀创新成果大赛-杭州分站赛”正式公布评选结果。 经专家评审&#xff0c;美创科技报名参赛的解决方案—“医…

【Web开发指南】MyEclipse XML编辑器的高级功能简介

MyEclipse v2023.1.2离线版下载 1. 在MyEclipse中编辑XML 本文档介绍MyEclipse XML编辑器中的一些可用的函数&#xff0c;MyEclipse XML编辑器包括高级XML编辑&#xff0c;例如&#xff1a; 语法高亮显示标签和属性内容辅助实时验证(当您输入时)文档内容的源&#xff08;Sou…

基于QT4的GPX文件编辑器开发

GPX文件是记录地理点的文件,本质是一种xml文件。GPX文件目前没有很好的编辑器,因此作者决定开发一款无需安装的绿色编辑器。 在QT4开发中,XML可以用DOM来实现,但其逻辑并不是很清晰。使用模型视图反而会更加可读。因此在开发中,使用model-view模式来实现数据读写。 1 需…

游戏找不到msvcr100.dll解决方法,常见的三种解决方法

在计算机领域&#xff0c;msvcr100.dll是一个非常重要的动态链接库文件。它是Microsoft Visual C 2010 Redistributable的一部分&#xff0c;用于支持Visual Studio 2010的开发环境。然而&#xff0c;在某些情况下&#xff0c;msvcr100.dll可能会出现问题&#xff0c;导致程序无…

【Leetcode】104.二叉树的最大深度

一、题目 1、题目描述 给定一个二叉树 root ,返回其最大深度。 二叉树的 最大深度 是指从根节点到最远叶子节点的最长路径上的节点数。 示例1: 输入:root = [3,9,20,null,null,15,7] 输出:3示例2: 输入:root = [1,null,2] 输出:2提示: 树中节点的数量在 [0, 104…

嵌入式设备应用开发(qt界面开发)

【 声明:版权所有,欢迎转载,请勿用于商业用途。 联系信箱:feixiaoxing @163.com】 linux界面开发有很多的方案可以选。比如说lvgl、minigui、ftk之类的。但是,这么多年来,一直屹立不倒的还是qt。相比较其他几种方案,qt支持多个平台,这里面就包括了linux平台。此…

Spring Boot 集成 WebSocket 实现服务端推送消息到客户端

WebSocket 简介 WebSocket 协议是基于 TCP 的一种新的网络协议&#xff0c;它实现了浏览器与服务器全双工&#xff08;full-duplex&#xff09;通信—允许服务器主动发送信息给客户端&#xff0c;这样就可以实现从客户端发送消息到服务器&#xff0c;而服务器又可以转发消息到客…

【Django】Task3 外键的使用、Queryset和Instance

【Django】Task3 外键的使用、Queryset和Instance Task3主要理解数据库外键的使用场景&#xff0c;了解Queryset的功能&#xff0c;通过编写代码体验Queryset中对数据库实例的curd操作&#xff0c;同时了解到Instance的定义。 1.外键的使用 1.1什么是外键 数据表外键是数据…

智能在线客服系统,客户问题接待更及时

优质的客户服务可以提高客户的满意度和忠诚度&#xff0c;从而为企业带来更多的商业机会。智能在线客服系统&#xff0c;是指通过人工智能技术和自然语言处理技术&#xff0c;将客户的问题自动化地分配给相应的客服人员&#xff0c;从而实现客户问题的快速解答。相比传统的客服…

树结构使用实例---实现数组和树结构的转换

文章目录 一、为什么要用树结构&#xff1f;二、使用步骤 1.引入相关json2.树结构的转换总结 一、为什么要用树结构&#xff1f; 本文将讲述一个实例&#xff0c;构造一棵树来实现数组和tree的转换&#xff0c;这在前端树结构中是经常遇到的 后端返回树结构方便管理&#xff…

内核日志过滤

本操作以centos为例。 1、不想把日志存入到 /var/log/messages中&#xff0c;转存到其他文件 >1.1、修改配置文件 /etc/rsyslog.conf vim /etc/rsyslog.conf# 添加以下代码if $programname kernel and ($msg contains hexdump or $msg contains shentong_data_file) then …

防火墙firewall

一、什么是防火墙 二、iptables 1、iptables介绍 2、实验 138的已经被拒绝&#xff0c;1可以 三、firewalld 1、firewalld简介 关闭iptables&#xff0c;开启firewalld&#xff0c;curl不能使用&#xff0c;远程连接ssh可以使用 添加80端口 这样写也可以&#xff1a;添加http…

【服务器】Strace显示后台进程输出

今天有小朋友遇到一个问题 她想把2331509和2854637这两个进程调到前台来&#xff0c;以便于在当前shell查看这两个python进程的实时输出 我第一反应是用jobs -l然后fg &#xff08;参考这里&#xff09; 但是发现jobs -l根本没有输出&#xff1a; 原因是jobs看的是当前ses…

通过Matlab编程分析微分方程、SS模型、TF模型、ZPK模型的关系

微分方程、SS模型、TF模型、ZPK模型的关系 一、Matlab编程 微分方程、SS模型、TF模型、ZPK模型的关系二、对系统输出进行微分计算三、对系统输出进行积分计算四、总结五、系统的零点与极点的物理意义参考 &#xff1a;[https://www.zhihu.com/question/22031360/answer/3073452…

图像降采样的计算原理:F.interpolate INTER_AREA

一、F.interpolate——数组采样操作 torch.nn.functional.interpolate(input, size=None, scale_factor=None, mode=nearest, align_corners=None, recompute_scale_factor=None) 功能:利用插值方法,对输入的张量数组进行上\下采样操作,换句话说就是科学合理地改变数组的尺…

Kotlin协程runBlocking并发launch,Semaphore同步1个launch任务运行

Kotlin协程runBlocking并发launch&#xff0c;Semaphore同步1个launch任务运行 <dependency><groupId>org.jetbrains.kotlinx</groupId><artifactId>kotlinx-coroutines-core</artifactId><version>1.7.3</version><type>pom&…

C++初阶语法——new,delete开辟/销毁动态内存空间

前言&#xff1a;在C语言中&#xff0c;有malloc&#xff0c;realloc&#xff0c;calloc开辟动态内存空间&#xff0c;free销毁动态内存空间。而在C中&#xff0c;使用new开辟动态内存空间&#xff0c;delete销毁动态内存空间。不仅简化了操作&#xff0c;更为重要的是&#xf…