深刻解析 volatile 关键字和线程本地存储ThreadLocal

1.volatile关键字在Java多线程编程中的重要性

在多线程编程中,volatile关键字扮演着至关重要的角色,它确保了变量在多个线程间的可见性,并且能防止指令重排序,从而达到线程安全的目的。

1.1 保证多线程环境下变量的可见性

在Java的并发编程中,线程间共享变量的更新可能不会立即对其他线程可见,这是因为线程可以把变量保留在局部内存中。而使用volatile声明的变量可以强制线程读写直接操作主内存,确保每个线程看到的变量是最新的值。

class SharedObject {volatile int sharedCounter;void increment() {sharedCounter++;}
}

1.2 禁止指令重排序

处理器为了提高程序运行效率,可能会对指令序进行优化,使得实际执行的顺序与代码编写的顺序不一致。对于单线程程序这通常不是问题,但在多线程中可能导致严重错误。volatile关键字可以禁止这种重排序,确保程序的执行顺序与代码的顺序一致。

1.3 volatile vs synchronized:使用场景与性能比较

volatile和synchronized都可以解决多线程中的数据同步问题,但volatile由于不会引起线程上下文的切换或调度,因此开销比synchronized小,适用于轻量级的同步需求,如状态标记。

class VolatileExample {volatile boolean isRunning = true;void run() {while (isRunning) {// ...}}
}

1.4 实例:使用volatile保证操作的原子性

虽然volatile可以保证变量的可见性,但它并不能保证复合操作(如i++)的原子性。在使用volatile时仍需注意,对于复合操作需要额外的同步策略。

2.在Java中实现线程间的数据共享

数据共享是多线程编程的核心问题之一,正确地在多个线程间共享数据是实现并发程序的关键步骤。

2.1 设计线程安全的共享数据类

线程安全的数据类通常包含了同步机制,以确保在任意时刻只有一个线程能够写入共享数据,同时可以由多个线程读取数据而不会发生冲突。

public class SafeSharedData {private int data;// 同步方法,保持方法原子性public synchronized void setData(int value) {this.data = value;}public synchronized int getData() {return data;}
}

2.2 通过内部类实现Runnable接口

您可以通过内部类来包装共享数据和它的操作,然后实现Runnable接口,使得线程能够操作同一个数据实例。

public class SharedDataWrapper implements Runnable {private SafeSharedData sharedData;public SharedDataWrapper(SafeSharedData data) {this.sharedData = data;}@Overridepublic void run() {// 使用sharedData的同步方法操作数据}
}

2.3 使用锁机制同步数据访问

ReentrantLock是一种广泛使用的锁机制,能够对数据访问进行精准的控制。这个锁支持锁重入,意味着可以在一个锁已经被获取的前提下,再次获取此锁不会产生死锁。

import java.util.concurrent.locks.ReentrantLock;
public class Counter {private final ReentrantLock lock = new ReentrantLock();private int count = 0;public void increment() {lock.lock(); // 获取锁try {count++;} finally {lock.unlock(); // 释放锁}}public int getCount() {lock.lock(); // 获取锁try {return count;} finally {lock.unlock(); // 释放锁}}
}

使用锁时,一定要在try-finally块中释放所持有的锁,以避免死锁或资源泄漏。

3.ThreadLocal的使用及其对多线程的影响

ThreadLocal是Java提供的一种线程局部存储机制,允许每个线程在其内部保存数据,而这些数据对其他线程是隔离的。

3.1 ThreadLocal简介及其工作原理

ThreadLocal通过提供线程内部的私有变量副本,来避免其它线程的干扰和冲突。

public class ThreadLocalExample {private ThreadLocal<Integer> threadLocalCount = new ThreadLocal<>();public void setThreadLocalCount(int value) {threadLocalCount.set(value);}public int getThreadLocalCount() {return threadLocalCount.get();}
}

3.1.1 ThreadLocal类与ThreadLocalMap关系

每个线程内部都有一个ThreadLocalMap,其键值对的键是ThreadLocal对象,而值则是线程内部想要存储的对象。

3.1.2 ThreadLocal与线程隔离性

ThreadLocal确保每一个线程都有一个独立的变量副本,它提供了一种将状态和数据从其它线程隔离开来的手段。

3.2 ThreadLocal在实际编程中的应用场景

ThreadLocal在很多编程场景中非常有用,尤其是与会话信息和用户身份认证有关的场景。

3.2.1 用户身份验证

在Web开发中,可以利用ThreadLocal存储用户登录信息,确保每个线程独立处理各自的用户数据。

3.2.2 数据库连接管理

ThreadLocal可以用于保持数据库连接,使得每个线程都拥有自己的数据库连接,从而提高数据库操作的效率。

3.2.3 会话信息控制

在HTTP服务中,ThreadLocal常用于存储会话信息,满足服务端处理需求。

3.3 实例:ThreadLocal在Web应用中的典型用法

以下是一个在Web应用中使用ThreadLocal来存储当前HTTP请求信息的例子。

public class WebUserContext {private static ThreadLocal<HttpServletRequest> userThreadLocal = new ThreadLocal<>();public static HttpServletRequest getRequest() {return userThreadLocal.get();}public static void setRequest(HttpServletRequest request) {userThreadLocal.set(request);}
}

在这个例子中,我们确保了每个线程只处理它自己的请求,通过存储在ThreadLocal变量中,可以在代码的任何部分方便地获取当前的HttpServletRequest对象,而不用担心其他线程的交叉访问问题。
在这样的用例中,可以在Web请求的初始处理阶段设置ThreadLocal,之后在整个请求处理过程中的任何地方获取这个信息。处理完请求后,很重要的一点是要清理掉ThreadLocal存储的数据,避免内存泄漏。
例如,在一个Servlet过滤器中设定和清除ThreadLocal:

public class UserContextFilter implements Filter {@Overridepublic void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {try {WebUserContext.setRequest((HttpServletRequest) request);chain.doFilter(request, response);} finally {WebUserContext.setRequest(null); // 清理ThreadLocal中的数据}}
}

这样的做法可以在每个请求结束时自动清除ThreadLocal中的数据,这是一个良好的实践,帮助避免内存泄漏。
结合前面的章节内容,我们有了对Java多线程中变量使用机制更深入的理解,包括volatile确保变量的可见性和禁止指令重排序,以及如何安全高效地在多线程中共享数据。还有ThreadLocal的使用,它提供了一种保持线程内数据隔离的高效方法,在多线程编程中非常有用,特别是在处理一些线程安全的临时状况或为每个线程维护一个私有的状态。

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

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

相关文章

CRLF注入漏洞

1.CRLF注入漏洞原理 Nginx会将 $uri进行解码&#xff0c;导致传入%0a%0d即可引入换行符&#xff0c;造成CRLF注入漏洞。 执行xss语句 2.漏洞扩展 CRLF 指的是回车符(CR&#xff0c;ASCII 13&#xff0c;\r&#xff0c;%0d) 和换行符(LF&#xff0c;ASCII 10&#xff0c;\n&am…

Java中的事件驱动编程:增强应用的互动性和响应性

事件驱动编程是一种编程范式&#xff0c;其中程序的流程由外部事件决定&#xff0c;如用户操作、系统消息或其他程序的输入。在Java中&#xff0c;事件驱动编程广泛应用于图形用户界面&#xff08;GUI&#xff09;开发、网络编程和组件交互。本文将探讨Java中的事件驱动编程基础…

FTP协议——LightFTP安装(Linux)

1、简介 LightFTP是一个轻量级的FTP&#xff08;File Transfer Protocol&#xff0c;文件传输协议&#xff09;客户端软件。FTP是一种用于在网络上传输文件的标准协议&#xff0c;允许用户通过TCP/IP网络&#xff08;如互联网&#xff09;在计算机之间进行文件传输。 2、步骤…

在ARM开发板上,栈大小设置为2MB(常用设置)里面存放的数据

系列文章目录 在ARM开发板上&#xff0c;栈大小设置为2MB&#xff08;常用设置&#xff09;里面存放的数据 在ARM开发板上&#xff0c;栈大小设置为2MB&#xff08;常用设置&#xff09;里面存放的数据 系列文章目录 在ARM开发板上&#xff0c;栈&#xff08;Stack&#xff09;…

Flutter 中的 LimitedBox 小部件:全面指南

Flutter 中的 LimitedBox 小部件&#xff1a;全面指南 Flutter 是一个功能强大的 UI 框架&#xff0c;它提供了大量的小部件来帮助开发者构建美观且响应式的用户界面。在 Flutter 的布局小部件中&#xff0c;LimitedBox 是一个不太常见但非常有用的组件&#xff0c;它可以用来…

Keras深度学习框架第二十五讲:使用KerasNLP预训练Transformer模型

1、KerasNPL预训练Transformer模型概念 使用KerasNLP来预训练一个Transformer模型涉及多个步骤。由于Keras本身并不直接提供NLP的预训练模型或工具集&#xff0c;我们通常需要结合像TensorFlow Hub、Hugging Face的Transformers库或自定义的Keras层来实现。 以下是一个简化的…

Thingsboard规则链:Message Type Filter节点详解

一、Message Type Filter节点概述 二、具体作用 三、使用教程 四、源码浅析 五、应用场景与案例 智能家居自动化 工业设备监控 智慧城市基础设施管理 六、结语 在物联网&#xff08;IoT&#xff09;领域&#xff0c;数据处理与自动化流程的实现是构建智能系统的关键。作…

创新实训2024.05.28日志:记忆化机制、基于MTPE与CoT技术的混合LLM对话机制

1. 带有记忆的会话 1.1. 查询会话历史记录 在利用大模型自身能力进行对话与解答时&#xff0c;最好对用户当前会话的历史记录进行还原&#xff0c;大模型能够更好地联系上下文进行解答。 在langchain chat chat的chat函数中&#xff0c;通过实现langchain框架提供的ChatMemo…

【设计模式】创建型-工厂方法模式

前言 工厂方法模式是一种经典的创建型设计模式&#xff0c;它提供了一种灵活的方式来创建对象实例。通过本文&#xff0c;我们将深入探讨工厂方法模式的概念、结构和应用。 一、什么是工厂方法模式 工厂方法模式是一种创建型设计模式&#xff0c;旨在解决对象的创建过程和客…

Spring MVC的请求流程

Spring MVC&#xff08;Model-View-Controller&#xff09;是一种基于Java的实现了MVC设计模式的轻量级Web框架。它通过一套注解&#xff0c;可以快速地搭建一个可扩展、易维护的Web应用程序。下面是Spring MVC处理请求的基本流程&#xff1a; 用户发起请求&#xff1a;用户通过…

Parquet使用指南:一个超越CSV、提升数据处理效率的存储格式

前言 在大数据时代&#xff0c;数据存储和处理的效率越来越重要。同时&#xff0c;我们在工作中处理的数据也越来越多&#xff0c;从excel格式到csv格式&#xff0c;从文件文档传输到直接从数据库提取&#xff0c;数据单位也从K到M再到G。 当数据量达到了G以上&#xff0c;几…

ROS | 自动导航

保存&加载地图&#xff1a; image:地图文件 resolution:地图分辨率&#xff08;珊格地图&#xff09; origin&#xff1a;地图左下标 第三个参数是偏转角度 加载创建好的yaml文件&#xff1a; 年轻人第一次导航&#xff1a; 全局规划器&#xff1a; 代价地图设置参数&#…

K-means聚类模型入门介绍

K-means聚类是一种无监督学习方法&#xff0c;广泛应用于数据挖掘、机器学习和模式识别等领域&#xff0c;用于将数据集划分为K个簇&#xff08;cluster&#xff09;&#xff0c;其中每个簇的数据具有相似的特征。其基本思想是通过迭代寻找使簇内点间距离平方和最小的簇划分方式…

纯命令行登录dlut-lingshui并实现断网重连

1 写在前面 本文章改写自《shell脚本登录dlut-lingshui并设置开机连网和断网重连》&#xff0c;旨在利用其脚本解决无图形界面情况下的校园网登录以及断网重连问题。本文仅作使用脚本的示范而不分析原理&#xff0c;若对脚本细节感兴趣可以查阅原文。 2 操作步骤 2.1 修改代…

【华为OD机试-C卷D卷-200分】运输时间(C++/Java/Python)

【华为OD机试】-(A卷+B卷+C卷+D卷)-2024真题合集目录 【华为OD机试】-(C卷+D卷)-2024最新真题目录 题目描述 M(1 ≤ M ≤ 20)辆车需要在一条不能超车的单行道到达终点,起点到终点的距离为 N(1 ≤ N ≤ 400)。速度快的车追上前车后,只能以前车的速度继续行驶,求最后一…

K8S-pod资源 探针

一.pod资源限制&#xff1a; 对pod资源限制原因&#xff1a;高并发占用所有的cpu资源、内存资源、会造成雪崩 当定义 Pod 时可以选择性地为每个容器设定所需要的资源数量。 最常见的可设定资源是 CPU 和内存大小&#xff0c;以及其他类型的资源。 方式&#xff1a; 对pod做…

UML-系统架构师(二)

1、UML&#xff08;Unified Modeling Language&#xff09;是面向对象设计的建设工具&#xff0c;独立于任何具体程序设计语言&#xff0c;以下&#xff08;&#xff09;不属于UML中的模型。 A用例图 B协作图 C活动图 DPAD图 解析&#xff1a; UML一共14种图 结构图&…

【蓝桥杯——物联网设计与开发】拓展模块2 - 电位器模块

一、电位器模块 &#xff08;1&#xff09;资源介绍 &#x1f505;原理图 蓝桥杯物联网竞赛实训平台提供了一个拓展接口 CN2&#xff0c;所有拓展模块均可直接安装在 Lora 终端上使用&#xff1b; 图1 拓展接口 电位器模块电路原理图如下所示&#xff1a; 图2 …

python数据分析——apply 2

参考资料&#xff1a;活用pandas库 1、向量化函数 使用apply时&#xff0c;可以按行或按列应用函数。如果想应用自定义的函数&#xff0c;必须重写它&#xff0c;因为整列或整行传递到了函数的第一个参数中。可以利用向量化函数和装饰器对所有函数进行向量化。对代码进行向量化…

Flutter 中的 CompositedTransformTarget 小部件:全面指南

Flutter 中的 CompositedTransformTarget 小部件&#xff1a;全面指南 在Flutter的动画和高级布局系统中&#xff0c;CompositedTransformTarget是一个与CompositedTransformFollower配合使用的组件&#xff0c;用于创建硬件加速的跟随动画和视差效果。这种类型的动画通常用于…