深入了解ThreadLocal:避免内存泄漏的陷阱与最佳实践


多线程编程中,数据共享与隔离一直是开发者需要面对的挑战之一。而Java中的ThreadLocal提供了一种优雅的解决方案,允许每个线程都拥有自己独立的数据副本,从而避免了共享数据带来的线程安全问题。然而,正如事物总有两面性一样,ThreadLocal也存在一些潜在的陷阱,尤其是与内存泄漏相关的问题。

什么是ThreadLocal?

在深入讨论ThreadLocal的内存泄漏问题之前,我们先来了解一下ThreadLocal的基本概念。ThreadLocalJava中的一个工具类,提供了一种线程级别的数据隔离机制。通过ThreadLocal,我们可以在每个线程中存储自己的数据副本,互不影响,从而简化了多线程编程中的共享数据问题。

public class MyThreadLocal {private static final ThreadLocal<String> threadLocal = new ThreadLocal<>();public static void set(String value) {threadLocal.set(value);}public static String get() {return threadLocal.get();}
}

ThreadLocal应用场景

Web应用中的用户身份管理

在Web应用中,用户的身份信息是经常需要被访问的数据。使用ThreadLocal可以轻松地在用户登录后将用户信息存储在ThreadLocal中,这样在整个请求处理周期内都可以方便地获取到用户身份信息,而无需将用户信息作为参数传递到每个方法中。

public class UserContext {private static final ThreadLocal<User> userThreadLocal = new ThreadLocal<>();public static void setUser(User user) {userThreadLocal.set(user);}public static User getUser() {return userThreadLocal.get();}public static void clear() {userThreadLocal.remove();}
}

在用户登录时,可以通过UserContext.setUser(user) 将用户信息存储在ThreadLocal中。随后,在整个请求处理过程中,通过UserContext.getUser() 即可获取到用户信息,而无需一直传递User对象。

每个线程需要存储独立的对象副本

在我之前分享过的案例中,我使用了ThreadLocal来实现IP属地获取的功能,由于IP属地查询类(Searcher)需要在不同的线程中创建独立的对象,ThreadLocal提供了一种有效的解决方案。

原文链接:

利用Spring Boot实现客户端IP地理位置获取

    private static final Logger log = LogManager.getLogger(IPUtils.class);private static final String DB_PATH = "/root/home_place/ip2region.xdb";private static final ThreadLocal<Searcher> searcherThreadLocal = ThreadLocal.withInitial(() -> {try {return Searcher.newWithFileOnly(DB_PATH);} catch (Exception e) {log.error("初始化 IP 归属地查询失败: {}", e.getMessage());return null;}});

ThreadLocal内存泄漏的原因

ThreadLocal可能导致内存泄漏的主要原因在于,ThreadLocal在线程结束后,如果没有手动调用remove方法清理ThreadLocal中的数据,这些数据将会一直存在于线程的ThreadLocalMap中,而不会被垃圾回收。这是因为ThreadLocalMap中的Entry (键值对)保留了对ThreadLocal实例的强引用,而ThreadLocal实例又引用着对应的值。即使线程结束了,ThreadLocalMap中的引用关系依然存在,阻碍了相关对象的垃圾回收。

ThreadLocal源码说明内存泄漏的原因:

    /*** ThreadLocalMap is a customized hash map suitable only for* maintaining thread local values. No operations are exported* outside of the ThreadLocal class. The class is package private to* allow declaration of fields in class Thread.  To help deal with* very large and long-lived usages, the hash table entries use* WeakReferences for keys. However, since reference queues are not* used, stale entries are guaranteed to be removed only when* the table starts running out of space.*/static class ThreadLocalMap {/*** The entries in this hash map extend WeakReference, using* its main ref field as the key (which is always a* ThreadLocal object).  Note that null keys (i.e. entry.get()* == null) mean that the key is no longer referenced, so the* entry can be expunged from table.  Such entries are referred to* as "stale entries" in the code that follows.*/static class Entry extends WeakReference<ThreadLocal<?>> {/** The value associated with this ThreadLocal. */Object value;Entry(ThreadLocal<?> k, Object v) {super(k);value = v;}}/*** The initial capacity -- MUST be a power of two.*/private static final int INITIAL_CAPACITY = 16;

/**

  • The entries in this hash map extend WeakReference, using

  • its main ref field as the key (which is always a

  • ThreadLocal object). Note that null keys (i.e. entry.get()

  • == null) mean that the key is no longer referenced, so the

  • entry can be expunged from table. Such entries are referred to

  • as “stale entries” in the code that follows.

*/

此哈希映射中的条目扩展 WeakReference,使用其主 ref 字段作为键(始终是 ThreadLocal 对象)。请注意,空键(即 entry.get() == null)意味着不再引用该键,因此可以从表中删除该条目。此类条目在下面的代码中称为“过时条目”。

内存泄漏的防范使用方式

为了避免ThreadLocal导致的内存泄漏问题,开发者应该养成良好的使用习惯:

及时调用remove方法

在使用ThreadLocal的过程中,务必在合适的时机调用remove方法,手动清理ThreadLocalMap中的Entry。这样可以防止ThreadLocal对象和值的强引用一直存在,有助于相关对象的垃圾回收。

public class MyThreadLocal {private static final ThreadLocal<String> threadLocal = new ThreadLocal<>();public static void set(String value) {threadLocal.set(value);}public static String get() {return threadLocal.get();}public static void clear() {threadLocal.remove();}
}

使用try-finally块确保清理

在某些情况下,使用try-finally块可以确保在发生异常时也能够调用remove方法,避免遗漏清理的情况。在使用线程池等场景时,特别注意ThreadLocal的生命周期,避免长时间存在的线程携带着无用的ThreadLocal数据。

public class MyThreadLocal {private static final ThreadLocal<String> threadLocal = new ThreadLocal<>();public static void set(String value) {threadLocal.set(value);}public static String get() {return threadLocal.get();}public static void main(String[] args) {try {set("value");// 在使用完之后立即调用remove方法} finally {clear();}}
}

小心线程池中的使用

在使用线程池等场景时,特别要注意ThreadLocal的生命周期。线程池中的线程可能会被重用,如果不及时清理ThreadLocal,前一个任务中的ThreadLocal数据就会泄漏到下一个任务中。

4. 总结

ThreadLocal是一个强大的工具,能够在多线程环境中解决共享数据的问题。然而,开发者在使用ThreadLocal时应当小心,特别是在长时间存在的线程和线程池等场景下,要注意及时清理ThreadLocal,以避免内存泄漏的发生。通过正确的使用习惯和最佳实践,可以更好地发挥ThreadLocal的优势,确保多线程环境下的数据安全和性能。

后续内容文章持续更新中…

近期发布。


关于我

👋🏻你好,我是Debug.c。微信公众号:种棵代码技术树 的维护者,一个跨专业自学Java,对技术保持热爱的bug猿,同样也是在某二线城市打拼四年余的Java Coder。

🏆在掘金、CSDN、公众号我将分享我最近学习的内容、踩过的坑以及自己对技术的理解。

📞如果您对我感兴趣,请联系我。

若有收获,就点个赞吧,喜欢原图请私信我。

image.png

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

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

相关文章

Kimichat使用案例:将一大片无序文本内容整理成有序的Excel表格

Kimichat是一个国产的AI大模型应用。2024年10月9日&#xff0c;专注于通用人工智能领域的公司月之暗面&#xff08;Moonshot Al&#xff09;宣布在“长文本”领域实现了突破&#xff0c;推出了首个支持输入20万汉字的大模型moonshot&#xff0c;以及搭载该模型的智能助手产品Ki…

ORCLE APEX和EBS集成的2个小问题

from跳转后&#xff0c;没有跳转到指定页 从EBS菜单跳转登录后&#xff0c;没有跳转到APEX的指定页&#xff0c; 原因&#xff1a;再USER_INTERFACE定义的地方&#xff0c;HOME URL 被设置成了固定值 0&#xff0c;如上图 解决方法&#xff1a;定义APP级别的ITEM,在自动登录的…

使用Dockerfile Maven Plugin 将Docker镜像Push到AWS ECR (Elastic Container Registry)

文章目录 小结问题解决AWS ECR (Elastic Container Registry)的登录问题 pull access denied for jdk, repository does not exist问题 Could not acquire image ID or digest following builddockerfile-maven-plugin 使用 参考 小结 本文记录使用Dockerfile Maven Plugin 将…

通过一道CTF题目来认识一下Frida

本文作者&#xff1a;杉木涂鸦智能安全实验室 Frida https://github.com/frida/frida Frida是一个动态代码插入工具&#xff0c;可用于各种应用程序的调试和逆向工程。它提供了多种安装选项&#xff0c;包括Python和Node.js绑定&#xff0c;并提供了详细的命令行参数和选项。…

JVM虚拟机系统性学习-运行时数据区(虚拟机栈、本地方法栈)

虚拟机栈 虚拟机栈为每个线程所私有的&#xff0c;如下图&#xff1a; 栈帧是什么&#xff1f; 栈帧存储了方法的局部变量表、操作数栈、动态链接和方法返回地址等信息 栈内存为线程私有的空间&#xff0c;每个方法在执行时都会创建一个栈帧&#xff0c;执行该方法时&…

Java的NIO工作机制

文章目录 1. 问题引入2. NIO的工作方式3. Buffer的工作方式4. NIO数据访问方式 1. 问题引入 在网络通信中&#xff0c;当连接已经建立成功&#xff0c;服务端和客户端都会拥有一个Socket实例&#xff0c;每个Socket实例都有一个InputStream和OutputStream&#xff0c;并通过这…

选择法排序

本题要求将给定的n个整数从大到小排序后输出。 输入格式&#xff1a; 输入第一行给出一个不超过10的正整数n。第二行给出n个整数&#xff0c;其间以空格分隔。 输出格式&#xff1a; 在一行中输出从大到小有序的数列&#xff0c;相邻数字间有一个空格&#xff0c;行末不得有…

企业IT安全:内部威胁检测和缓解

什么是内部威胁 内部威胁是指由组织内部的某个人造成的威胁&#xff0c;他们可能会造成损害或窃取数据以谋取自己的经济利益&#xff0c;造成这种威胁的主要原因是心怀不满的员工。 任何内部人员&#xff0c;无论是员工、前雇员、承包商、第三方供应商还是业务合作伙伴&#…

SSL证书HTTPS保护服务

SSL证书属于数字证书的其中一种&#xff0c;广泛用于https协议&#xff0c;从而可以让数据传输在加密前提下完成&#xff0c;确保HTTPS网络安全是申请SSL证书必要工作。 SSL证书是主要用于https是一种加密协议&#xff0c;仔细观察网站地址会发现目前主流的网址前面都会有http…

【玩转TableAgent数据智能分析】利用TableAgent进行教育数据分析

文章目录 前言九章云极&#xff08;DataCanvas&#xff09;介绍前期准备样例数据集体验1. 样例数据集-Airbnb民宿价格&评价 体验1.1 体验一1.2 体验二 教育数据的分析&#xff08;TableAgent&ChatGLM对比&#xff09;1. 上传文件2. 数据分析与对比2.1 分析一2.1.1 Tabl…

web服务器之——建立两个基于ip地址访问的网站

目录 准备工作&#xff1a;web服务器搭建 第一步&#xff1a;挂载 第二步&#xff1a;编辑配置文件 第三步&#xff1a;安装软件包 第四步&#xff1a;启动httpd 查看配置文件&#xff1a; 第五步&#xff1a;设置防火墙状态&#xff1a; 重启服务: 查看状态&#xff1…

Leetcode—2961.双模幂运算【中等】

2023每日刷题&#xff08;五十六&#xff09; Leetcode—2961.双模幂运算 实现代码 class Solution { public:int func(int a, int b) {int ans 1;for(int i 0; i < b; i) {ans * a;ans % 10;}return ans;}int func2(int a, int b, int m) {int ans 1;for(int i 0; i …

评论送书:以企业架构为中心的SABOE数字化转型五环法

01 传统企业数字化转型面临诸多挑战 即将过去的2023年&#xff0c;chatGPT大模型、数据资产入表等事件的发生&#xff0c;标志着数字经济正在加速发展。数字经济是人类社会继农业经济、工业经济之后的第三种经济形态&#xff0c;将推动生产方式、生活方式和治理方式深刻变革&a…

2-Spring

2-Spring 文章目录 2-Spring项目源码地址Spring概述Spring特点&#xff08;优点&#xff09;Spring相关学习网站基于Maven的Spring框架导入Spring的组成及拓展 Spring-IOC--原型理解IOC-原型--示例开发示例-常规开发示例-Set函数&#xff08;IOC原型&#xff09;开发示例-对比思…

C++STL的list(超详解)

文章目录 前言构造函数capacitylist的访问insertswapsort 前言 看一下list, 在任意位置可以进行O(1)插入删除的操作。 它怎么实现这个东西&#xff1f;它其实就是一个带头双向循环链表。 #成员函数 构造函数 这里面的构造函数学完string和vector之后已经相当熟悉了。 capaci…

axios请求拦截和响应拦截

Axios的请求拦截器和响应拦截器都是非常有用的工具&#xff0c;它们可以在请求发送到服务器之前或响应返回到客户端之前进行干预。 请求拦截器&#xff1a; 请求拦截器是在发送请求之前执行的&#xff0c;可以在请求拦截器中对请求进行一些预处理&#xff0c;比如设置统一的请…

如何将用户有过行为的item用list形式记录下来,另外如何计算list里的个数

导语&#xff1a; 最近做项目&#xff0c;发现有些语法想一想是知道&#xff0c;但实际操作起来跟想的情况不一样哈哈。不是遇见bug就是输出的结果不是自己想要的&#xff0c;CSDN跟知乎找了很多没怎么解决&#xff0c;后面多摸索多实操终于解决&#xff01; test_data[item_…

数据结构-05-跳表SkipList

1-什么是跳表 跳表SkipList是一种随机化的数据结构&#xff0c;基于并联的链表&#xff0c;实现简单&#xff0c;插入、删除、查找的复杂度均为 O(logN)&#xff08;大多数情况下&#xff0c;因为是实现上是概率问题&#xff09;&#xff0c;因为其性能匹敌红黑树且实现较为简单…

msvcr110.dll丢失的解决方法有哪些-常见方法教程

我们在日常使用电脑中经常遇到各种问题&#xff0c;比如系统文件丢失是最常见的&#xff0c;其中msvcr110.dll丢失也是非常常见的问题&#xff0c;那么msvcr110.dll文件为什么会丢失&#xff0c;丢失对电脑有什么影响呢&#xff0c;丢失了有什么解决方法&#xff1f;今天小编就…

Synchronized 优化

目录 前言 重点 一、 轻量级锁 二、锁膨胀 三、重量锁 四、偏向锁 五、其他优化 我的其他博客 前言 Java synchronized 是一种机制&#xff0c;可以保证多个线程在访问共享资源时的同步性。synchronized 关键字可以用于方法或代码块上&#xff0c;当一个线程获取了这个对…