ThreadLocal 内存泄漏问题

news/2024/11/27 0:21:50/

1. 认识ThreadLocal

java中提高了threadlocal,为每个线程保存其独有的变量,threadlocal使用的一个小例子是:

public class ThreadLocalTest {public static void main(String[] args) {ThreadLocal<String> threadIds = new ThreadLocal<>();ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);for (int i = 0; i < 10; i++) {fixedThreadPool.execute(() -> {threadIds.set("" + Thread.currentThread().getId());System.out.println(Thread.currentThread().getName() + ", id:" + threadIds.get());});}}
}

输出结果:

Thread-0, id:12
Thread-3, id:15
Thread-2, id:14
Thread-5, id:17
Thread-1, id:13
Thread-6, id:18
Thread-4, id:16
Thread-7, id:19
Thread-9, id:21
Thread-8, id:20

可以看出,每个线程内部都保存了一个不同的threadId。

2. ThreadLocal实现原理

每个线程(Thread类的实例)都具有一个叫做threadLocalMap的变量,其是一个map类型的结构,其中每个key指向一个threadLocal实例,value存储当前线程在这个threadLocal中存储的值。举例来说,在上面的程序中我们创建了10个线程,每个线程内部的threadLocalMap都具有一个entry<threadIds, v>。因此,每个线程记录、更改threadLocal中的值实际上就是在自己的threadLocalMap中找到对应的entry,然后更新entry里面的值,从而实现线程隔离。

3. ThreadLocalMap中的key是软引用

我们知道,ThreadLocalMap中的key是对ThreadLocal的引用,那为什么搞成软引用呢,我的理解是这样的。
在这里插入图片描述
图片来自于zhihu java喵
看上图,实线代表强引用,虚线代表弱引用。
我们结合上面的代码来理解一下:
首先,我们需要知道线程的寿命是很长的,我们在线程池中创建的线程之后可能还会去运行其他的runnable对象,因此需要动态地清理其threadLocalMap中无用的entry。

  1. 当main方法被执行时,main方法被压入虚拟机栈,创建了10个线程,假设线程还没终止,那么此时threadIds对象具有1个强引用(来自于main线程的ThreadLocal threadIds = new ThreadLocal<>();这句)和10个弱引用(来自于10个线程的threadLocalMap中的key)。
  2. 当main方法运行之后,main方法被弹出栈,此时threadIds对象只具有10个弱引用(来自于10个线程的threadLocalMap中的key)。
  3. java gc线程发现threadIds对象只有弱引用,那么在gc时就会回收这个对象,之后每个线程的threadLocalMap中这个entry的key就变成了null。(此时entry是<null, v>)。
  4. 由于此时这条entry已经无用的,但是v还指向其引用的对象,那么v就无法被回收,造成了内存泄漏。
  5. 我刚看到这个问题时,想着解决办法也很简单,线程发现key是null之后,将v也置为null,等着gc回收v不久好了吗,实际上也确实可以这么做。

Q:为什么ThreadLocalMap的key是弱引用?
A:结合上面的流程就很简单了,如果key是弱引用,那么main方法都运行完了,threadIds都已经无用了,此时还有十个强引用指向它,这让gc怎么回收呢?

4. 内存泄漏解决方法

使用完threadLocal对象之后,调用remove方法,将其从线程的threadLocalMap中清理出去:

public class ThreadLocalTest {public static void main(String[] args) {ThreadLocal<String> threadIds = new ThreadLocal<>();ExecutorService fixedThreadPool = Executors.newFixedThreadPool(10);for (int i = 0; i < 10; i++) {fixedThreadPool.execute(() -> {threadIds.set("" + Thread.currentThread().getId());System.out.println(Thread.currentThread().getName() + ", id:" + threadIds.get());// removethreadIds.remove();});}}
}

http://www.ppmy.cn/news/26014.html

相关文章

【C语言进阶】你听说过柔性数组吗?

&#x1f466;个人主页&#xff1a;Weraphael ✍&#x1f3fb;作者简介&#xff1a;目前是C语言学习者 ✈️专栏&#xff1a;C语言航路 &#x1f40b; 希望大家多多支持&#xff0c;咱一起进步&#xff01;&#x1f601; 如果文章对你有帮助的话 欢迎 评论&#x1f4ac; 点赞&a…

下载网上压缩包(包含多行json)并将其转换为字典的解决方案

大家好,我是爱编程的喵喵。双985硕士毕业,现担任全栈工程师一职,热衷于将数据思维应用到工作与生活中。从事机器学习以及相关的前后端开发工作。曾在阿里云、科大讯飞、CCF等比赛获得多次Top名次。喜欢通过博客创作的方式对所学的知识进行总结与归纳,不仅形成深入且独到的理…

JavaScript Date(日期) 对象

JavaScript Date 对象是 JavaScript 中用于处理日期和时间的内置对象。它可以用于获取当前时间、设置日期和时间、计算日期和时间之间的差异、以及将日期和时间格式化为各种字符串格式。在本文中&#xff0c;我们将详细介绍 JavaScript Date 对象的作用和在实际工作中的用途。 …

Python 自己简单地造一个轮子.whl文件

造轮子引言准备文件原始文件打包轮子文件运行验证工程文件引言 平时使用的python第三方库很顺手&#xff0c;这第三方库一般都是大家一起努力的结果&#xff0c;那我们是不是也可以贡献一点力量呢&#xff1f;首先从造一个本地的.whl文件开始。 在python中&#xff0c;引用第…

15_FreeRtos计数信号量优先级翻转互斥信号量

目录 计数型信号量 计数型信号量相关API函数 计数型信号量实验源码 优先级翻转简介 优先级翻转实验源码 互斥信号量 互斥信号量相关API函数 互斥信号量实验源码 计数型信号量 计数型信号量相当于队列长度大于1的队列&#xff0c;因此计数型信号量能够容纳多个资源,这在…

实验10 拓扑排序与最短路径2022

A. DS图—图的最短路径&#xff08;无框架&#xff09;题目描述给出一个图的邻接矩阵&#xff0c;输入顶点v&#xff0c;用迪杰斯特拉算法求顶点v到其它顶点的最短路径。输入第一行输入t&#xff0c;表示有t个测试实例第二行输入顶点数n和n个顶点信息第三行起&#xff0c;每行输…

杭州电子科技大学2023年MBA招生考试成绩查询和复查申请的通知

根据往年的情况&#xff0c;2023杭州电子大学MBA考试初试成绩可能将于2月21日公布&#xff0c;最早于20号出来&#xff0c;为了广大考生可以及时查询到自己的分数&#xff0c;杭州达立易考教育为大家汇总了信息。根据教育部和浙江省教育考试院关于硕士研究生招生考试工作的统一…

JVM详解——类的加载

文章目录类的加载1、Java程序如何运行2、Java字节码文件3、类加载4、类加载的过程5、类加载器6、类的加载方式7、类的加载机制8、双亲委派机制9、破坏双亲委派机制类的加载 1、Java程序如何运行 首先通过Javac命令将.java文件编译生成.class字节码文件。 Javac是Java编译命令&a…