Java多线程(4):ThreadLocal

news2024/11/17 22:40:13

您好,我是湘王,这是我的CSDN博客,欢迎您来,欢迎您再来~

为了提高CPU的利用率,工程师们创造了多线程。但是线程们说:要有光!(为了减少线程创建(T1启动)和销毁(T3切换)的时间),于是工程师们又接着创造了线程池ThreadPool。就这样就可以了吗?——不,工程师们并不满足于此,他们不把自己创造出来的线程给扒个底朝天决不罢手。

有了线程关键字解决线程安全问题,有了线程池解决效率问题,那还有什么问题是可以需要被解决的呢?——还真被这帮疯子攻城狮给找到了!

当多个线程共享同一个资源的时候,为了保证线程安全,有时不得不给资源加锁,例如使用Synchronized关键字实现同步锁。这本质上其实是一种时间换空间的搞法——用单一资源让不同的线程依次访问,从而实现内容安全可控。就像这样:

但是,可以不可以反过来,将资源拷贝成多份副本的形式来同时访问,达到一种空间换时间的效果呢?当然可以,就像这样:

而这,就是ThreadLocal最核心的思想。

但这种方式在很多应用级开发的场景中用得真心不多,而且有些公司还禁止使用ThreadLocal,因为它搞不好还会带来一些负面影响。

其实,从拷贝若干副本这种功能来看,ThreadLocal是实现了在线程内部存储数据的能力的,而且相互之间还能通信。就像这样:

还是以代码的形式来解读一下ThreadLocal。有一个资源类Resource:

/**
 * 资源类
 *
 * @author 湘王
 */
public class Resource {
	private String name;
	private String value;

	public Resource(String name, String value) {
		super();
		this.name = name;
		this.value = value;
	}

	public String getName() {
		return name;
	}

	public void setName(String name) {
		this.name = name;
	}

	public String getValue() {
		return value;
	}

	public void setValue(String value) {
		this.value = value;
	}
}

分别有ResuorceUtils1、ResuorceUtils2和ResuorceUtils3分别以不同的方式来连接资源,那么看看效率如何。

/**
 * 连接资源工具类,通过静态方式获得连接
 *
 * @author 湘王
 */
public class ResourceUtils1 {
	// 定义一个静态连接资源
	private static Resource resource = null;
	// 获取连接资源
	public static Resource getResource() {
		if(resource == null) {
			resource = new Resource("xiangwang", "123456");
		}
		return resource;
	}

	// 关闭连接资源
	public static void closeResource() {
		if(resource != null) {
			resource = null;
		}
	}
}



/**
 * 连接资源工具类,通过实例化方式获得连接
 *
 * @author 湘王
 */
public class ResourceUtils2 {
	// 定义一个连接资源
	private Resource resource = null;
	// 获取连接资源
	public Resource getResource() {
		if(resource == null) {
			resource = new Resource("xiangwang", "123456");
		}
		return resource;
	}

	// 关闭连接资源
	public void closeResource() {
		if(resource != null) {
			resource = null;
		}
	}
}



/**
 * 连接资源工具类,通过线程中的static Connection的副本方式获得连接
 *
 * @author 湘王
 */
public class ResourceUtils3 {
	// 定义一个静态连接资源
	private static Resource resource = null;
	private static ThreadLocal<Resource> resourceContainer = new ThreadLocal<Resource>();
	// 获取连接资源
	public static Resource getResource() {
		synchronized(ResourceManager.class) {
			resource = resourceContainer.get();
			if(resource == null) {
				resource = new Resource("xiangwang", "123456");
				resourceContainer.set(resource);
			}
			return resource;
		}
	}

	// 关闭连接资源
	public static void closeResource() {
		if(resource != null) {
			resource = null;
			resourceContainer.remove();
		}
	}
}



/**
 * 连接资源管理类
 *
 * @author 湘王
 */
public class ResourceManager {
	public void insert() {
		// 获取连接
		// System.out.println("Dao.insert()-->" + Thread.currentThread().getName() + ResourceUtils1.getResource());
		// Resource resource = new ResourceUtils2().getResource();
		Resource resource = ResourceUtils3.getResource();
		System.out.println("Dao.insert()-->" + Thread.currentThread().getName() + resource);
	}

	public void delete() {
		// 获取连接
		// System.out.println("Dao.delete()-->" + Thread.currentThread().getName() + ResourceUtils1.getResource());
		// Resource resource = new ResourceUtils2().getResource();
		Resource resource = ResourceUtils3.getResource();
		System.out.println("Dao.delete()-->" + Thread.currentThread().getName() + resource);
	}

	public void update() {
		// 获取连接
		// System.out.println("Dao.update()-->" + Thread.currentThread().getName() + ResourceUtils1.getResource());
		// Resource resource = new ResourceUtils2().getResource();
		Resource resource = ResourceUtils3.getResource();
		System.out.println("Dao.update()-->" + Thread.currentThread().getName() + resource);
	}

	public void select() {
		// 获取连接
		// System.out.println("Dao.select()-->" + Thread.currentThread().getName() + ResourceUtils1.getResource());
		// Resource resource = new ResourceUtils2().getResource();
		Resource resource = ResourceUtils3.getResource();
		System.out.println("Dao.select()-->" + Thread.currentThread().getName() + resource);
	}

	public void close() {
		ResourceUtils3.closeResource();
	}

	public static void main(String[] args) {
		for (int i = 0; i < 3; i++) {
			new Thread(new Runnable() {
				ResourceManager rm = new ResourceManager();
				@Override
				public void run() {
					rm.insert();
					rm.delete();
					rm.update();
					rm.select();
					rm.close();
				}
			}).start();
		}
	}
}

执行ResourceManager类中的main()方法后,可以清楚地看到:

第一种静态方式:大部分资源都能复用,但毫无规律;

第二种实例方式:即使是同一个线程,资源实例也不一样;

第三种ThreadLocal静态方式:相同的线程有相同的实例。

结论是:ThreadLocal实现了线程的资源复用。

也可以通过画图的方式来看清楚三者之间的不同:

这是静态方式下的资源管理:

这是实例方式下的资源管理:

这是ThreadLocal静态方式下的资源管理:

理解了之后,再来看一个数据传递的例子,也就是ThreadLocal实现线程间通信的例子:

/**
 * 数据传递
 *
 * @author 湘王
 */
public class DataDeliver {
	static class Data1 {
		public void process() {
			Resource resource = new Resource("xiangwang", "123456");
			//将对象存储到ThreadLocal
			ResourceContextHolder.holder.set(resource);
			new Data2().process();
		}
	}

	static class Data2 {
		public void process() {
			Resource resource = ResourceContextHolder.holder.get();
			System.out.println("Data2拿到数据: " + resource.getName());
			new Data3().process();
		}
	}

	static class Data3 {
		public void process() {
			Resource resource = ResourceContextHolder.holder.get();
			System.out.println("Data3拿到数据: " + resource.getName());
		}
	}

	static class ResourceContextHolder {
		public static ThreadLocal<Resource> holder = new ThreadLocal<>();
	}

	public static void main(String[] args) {
		new Data1().process();
	}
}

运行代码之后,可以看到Data1的数据都被Data2和Data3拿到了,就像这样:

ThreadLocal在实际应用级开发中较少使用,因为容易造成OOM:

1、由于ThreadLocal是一个弱引用(WeakReference<ThreadLocal<?>>),因此会很容易被GC回收;

2、但ThreadLocalMap的生命周期和Thread相同,这就会造成当key=null时,value却还存在,造成内存泄漏。所以,使用完ThreadLocal后需要显式调用remove操作(但很多码农不知道这一点)。


感谢您的大驾光临!咨询技术、产品、运营和管理相关问题,请关注后留言。欢迎骚扰,不胜荣幸~

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

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

相关文章

Synchronized底层核心原理

前言&#xff1a;大家好&#xff0c;我是小威&#xff0c;24届毕业生&#xff0c;在一家满意的公司实习。本篇文章是关于并发编程中Synchronized锁的底层核心原理知识记录&#xff0c;由于篇幅原因&#xff0c;下篇文章将介绍各种锁的优化原理。 本篇文章记录的基础知识&#x…

vue3 异步组件

前端开发经常遇到异步的问题&#xff0c;请求函数&#xff0c;链接库&#xff0c;等&#xff0c;都有可能需要通过promise或者async await 来进行异步的一个封装。 异步组件也由此诞生&#xff0c;我用settimeout来模拟一个vue3的异步组件 异步的子组件 <template><…

spring框架源码十三、spring ioc高级特性-后置处理器

spring ioc高级特性-后置处理器BeanPostProcessor实例MyBeanPostProcessorapplication-context.xmlTestServiceImpl测试BeanFactoryPostProcessorspring提供了两种后置处理bean的扩展接口&#xff0c; 分别为BeanPostProcessor和BeanFactoryPostProcessor&#xff0c; BeanPos…

攻防世界WEB练习 | easyphp

目录 题目场景 代码分析 找到flag 题目场景 代码分析 if(isset($a) && intval($a) > 6000000 && strlen($a) < 3) isset&#xff1a;检查变量是否设置 intval&#xff1a;检查变量是否为int型 strlen&#xff1a;检查变量的长度 要求a存在且大于6…

Matlab之多平台雷达检测融合仿真(附源码)

此示例演示如何融合来自多平台雷达网络的雷达检测。该网络包括两个机载和一个地面远程雷达平台。中央跟踪器以固定的更新间隔处理来自所有平台的检测。这能够根据目标类型、平台机动以及平台配置和位置评估网络的性能。 一、定义中央跟踪器 将trackerGNN用作中央跟踪器&#…

云原生时代下,如何打造开源监控体系?宏时数据在GOPS与你相聚

相聚上海 宏时数据受邀出席2022 GOPS全球运维大会上海站&#xff0c;将分享演讲&#xff01; 时间&#xff1a;2022年10月28日15:20-15:40 AIOps最佳实践及解决方案专场 同时展位在301&#xff0c;现场有丰富礼品&#xff0c;快来做任务夺宝&#xff01; 还有Zabbix高级认…

【CSDN开发云】光速认识Cloud IDE

⌚️⌚️⌚️个人格言&#xff1a;时间是亳不留情的&#xff0c;它真使人在自己制造的镜子里照见自己的真相! &#x1f4d6;Git专栏&#xff1a;&#x1f4d1;Git篇&#x1f525;&#x1f525;&#x1f525; &#x1f449;&#x1f449;&#x1f449;你的一键三连是对我的最大支…

10.26 要尝试让自己安静下来,去做该做的事 而不是让内心烦躁,焦虑,毁掉你本就不多的热情和定力

要尝试让自己安静下来&#xff0c;去做该做的事 而不是让内心烦躁&#xff0c;焦虑&#xff0c;毁掉你本就不多的热情和定力 复习 import torch import torch.nn as nn import math from torch.autograd import Variable# 定义embedding类来实现文本嵌入层&#xff0c;这里的s…

C++多态详解及代码示例

多态 一、基本定义 顾名思义&#xff0c;多种形态。多态是C面向对象的三大特性之一&#xff08;封装、继承和多态&#xff09;。 多态分为两种&#xff1a; 静态多态&#xff1a;函数的重载、运算符的重载动态多态&#xff1a;派生类和虚函数实现运行时多态 区别&#xff…

基于javaweb的企业员工绩效工资管理系统(java+springboot+freemarker+mysql)

基于javaweb的企业员工绩效工资管理系统(javaspringbootfreemarkermysql) 运行环境 Java≥8、MySQL≥5.7 开发工具 eclipse/idea/myeclipse/sts等均可配置运行 适用 课程设计&#xff0c;大作业&#xff0c;毕业设计&#xff0c;项目练习&#xff0c;学习演示等 功能说明…

cadence SPB17.4 - allegro - DRC检查的细节

文章目录cadence SPB17.4 - allegro - DRC检查的细节概述笔记设置约束管理器设置modeDRC检查查看report查看status总结ENDcadence SPB17.4 - allegro - DRC检查的细节 概述 一个板子做完了, 打样回来, 找出一些小问题, 需要改下板子. 将铺铜拆了, 按照原理图补上元件. 将线都…

Qt实现桌面画线、标记,流畅绘制,支持鼠标和多点触控绘制

前言 经常会在网上直播讲课或者点评中看到可以在课件上或者桌面上进行画线标记划重点&#xff0c;其实实现并不难&#xff0c;原理就是在桌面上盖一个透明图层&#xff0c;然后根据鼠标点绘制曲线。 今天分享如何通过Qt的QGraphics体系来实现这个功能&#xff0c;以前的文章已…

23、STM32——CAN

1、CAN 协议简介 CAN 与 I2C、SPI 等具有时钟信号的同步通讯方式不同&#xff0c;CAN 通讯并不是以时钟信号来进行同步的&#xff0c;它是一种异步通讯&#xff0c;只具有 CAN_High 和 CAN_Low 两条信号线&#xff0c;共同构成一组差分信号线&#xff0c;以差分信号的形式进行通…

第31讲:MySQL事务的并发问题以及事务的隔离级别

文章目录1.事务的并发问题1.1.事务并发之脏读1.2.事务并发之不可重复读1.3.事务并发之幻读2.事务的隔离级别3.模拟事务并发问题的产生以及如何避免3.1.事务并发问题脏读的模拟以及避免3.1.1.模拟事务并发脏读的问题3.1.2.解决事务并发脏读的问题3.2.事务并发问题不可重复读的模…

MATLAB函数mesh与surf等绘制三维曲面入门

一、引言 三维曲面在实际应用中被广泛使用&#xff0c;能够更好的展示三维空间中曲面&#xff0c;以实现三维数据的可视化。 Matlab软件中可以使用mesh、fmesh、surf和fsurf等函数来实现三维曲面的绘图。其中mesh和fmesh用来绘制三维网格曲面图&#xff0c;surf和fsurf绘制三维…

使用OpenCV如何确定一个对象的方向

在本教程中&#xff0c;我们将构建一个程序&#xff0c;该程序可以使用流行的计算机视觉库 OpenCV 确定对象的方向&#xff08;即以度为单位的旋转角度&#xff09;。 最常见的现实世界用例之一是当您想要开发机械臂的取放系统时。确定一个物体在传送带上的方向是确定合适的抓…

Activiti工作流引擎中责任链模式的建立与应用原理

本文需要一定责任链模式的基础与Activiti工作流知识&#xff0c;主要分成三部分讲解&#xff1a; 一、简单理解责任链模式概念 网上关于责任链模式的介绍很多&#xff0c;菜鸟教程上是这样说的&#xff1a;责任链模式&#xff08;Chain of Responsibility Pattern&#xff09…

操作系统实验二 进程创建

百年传承的实验&#xff0c;看不懂题意就对啦 vim写C代码的时候&#xff0c;记得先insetr键&#xff0c;Esc键后:wq保存。 更改后记得gcc重新编译。 代码显示异常&#xff0c;看评论区。 《操作系统》实验报告 姓名 Rhyme_7 学号 1008611 实验序号 实验二 实验名称 实验…

概率论与数理统计学习:数字特征(一)——知识总结与C语言实现案例

hello&#xff0c;大家好 这里是第十期的概率论与数理统计的学习&#xff0c;我将用这篇博客去总结知识点和用C语言实现案例的过程。 本期知识点——期望 离散型随机变量的期望连续型随机变量的期望随机变量函数的期望期望的性质 &#x1f4a6; 期望的引入 随机变量的分布函…

基于正交对立学习的改进麻雀搜索算法-附代码

基于正交对立学习的改进麻雀搜索算法 文章目录基于正交对立学习的改进麻雀搜索算法1.麻雀优化算法2. 改进麻雀算法2.1 正态变异扰动2.2 对立学习2.3 正交对立学习3.实验结果4.参考文献5.Matlab代码6.Python代码摘要&#xff1a;针对麻雀搜索算法种群多样性少&#xff0c;局部搜…