【JAVAEE】使用synchronized关键字和volatile关键字解决线程安全问题中的原子性,内存可见性和有序性问题

news2024/11/18 17:43:23

目录

1.synchronized关键字---监视器锁monitor lock

1.1synchronized的特性

互斥

刷新内存

可重入

1.3synchronized使用注意事项

2.volatile关键字

2.1volatile保证内存可见性问题

 MESI缓存一致性协议

内存屏障

2.2volatile解决有序性问题

3.总结synchronized和volatile解决的问题


在上一篇文章中我们谈到了线程安全问题的原因主要是五个方面,想要了解详情的小伙伴可以参考如下链接。http://t.csdn.cn/uGnflhttp://t.csdn.cn/uGnfl

总结起来就是下面五句话:

1.多个线程修改了同一个共享变量

2.线程是抢占式执行的,CPU调度是随机的

3.指令执行时没有保证原子性

4.多线程环境中内存可见性问题

5.指令的有序性问题

对于第一个问题,在写程序时,大多数都是要修改同一个变量的,不能避免;对于第二个问题,CPU时硬件层面上的东西,我们也是没有办法处理的。而对于剩下三个问题,都有可能通过Java层面去处理,这里我们可以通过synchronized和volatile关键字来解决线程安全问题。

1.synchronized关键字---监视器锁monitor lock

1.1synchronized的特性

互斥

synchronized会起到互斥效果,某个线程执行到某个对象的synchronized中时,其它线程如果也执行到同一个对象的synchronized就会阻塞等待

进入synchronized修饰的代码块,相当于加锁

退出synchronized修饰的代码块,相当于解锁

例如下图:

 某一个线程要执行这个方法时,就先获取锁,获取到之后再去执行代码,另外的线程执行这个方法时,要要获取锁,但是当线程持有锁时她就要等待,等到上一个线程释放这把锁时才可以。

大家有没有发现,加入锁之后的方法,就变成了单线程

所以,在使用synchronized时,一定要分场景使用:

1.在获取数据时,可以用多线程来提高效率

2.修改数据时,用synchronized修饰来保证安全。

来看看两个图解,了解synchronized关键字需要注意的问题:

这里有t1,t2两个线程,t1先使用了这个方法,获取锁,释放锁之后,t2竞争到锁资源。

具体哪个线程会竞争到锁资源是不一定的,因为线程是抢占式执行的,CPU调度是随机的,并不是先阻塞等待的线程就一定要先拿到锁。

 在t1执行方法时,被CPU调度走之后,依然不会释放锁,其它线程依然要阻塞等待。

所以,通过对代码加锁,解决了原子性问题

刷新内存

synchronized的工作过程:

1.获得互斥锁

2.从主内存拷贝变量的最新副本到工作的内存

3.执行代码

4.将更改后的共享变量的值刷新到主内存

5.释放互斥锁

通过对代码加锁,保证一个线程执行完所有操作之后并释放锁,第二个线程才可以获取到锁,读到的肯定是第一个线程修改的最新结果,从而保证了可见性问题

可重入

理解“把自己锁死”。

一个线程没有释放锁,然后又尝试再次加锁:

// 第一次加锁, 加锁成功
lock();
// 第二次加锁, 锁已经被占用, 阻塞等待. 
lock();
按照之前对于锁的设定 , 第二次加锁的时候 , 就会阻塞等待 . 直到第一次的锁被释放 , 才能获取到第
二个锁 . 但是释放第一个锁也是由该线程来完成 , 结果这个线程已经躺平了 , 啥都不想干了 , 也就无
法进行解锁操作 . 这时候就会 死锁. 这样的锁称为 不可重入锁。

而Java中的synchronized是可重入锁,即一个线程可以对同一个锁对象加多次锁,因此没有上面的问题。

1.2synchronized的使用示例

synchronized本质上要修改指定对象的“对象头”。从使用角度看,synchronized也势必要搭配一个具体的对象来使用。

1.直接修饰普通方法:锁的synchronizedDemo对象

public class SynchronizedDemo {
    public synchronized void methond() {
   }
}

2.修饰静态方法:锁的synchronizedDemo对象

public class SynchronizedDemo {
    public synchronized static void method() {
    }
}

3.修饰代码块:明确指定锁哪个对象

public class SynchronizedDemo {
    public void method() {
        synchronized (this) {
            
        }
    }
}

4.锁类对象

public class SynchronizedDemo {
    public void method() {
        synchronized (SynchronizedDemo.class) {

           }
      }
}

1.3synchronized使用注意事项

锁对象,只要可以记录当前获取到的线程就可以了,锁对象,可以是Java中的任何对象。

在Java虚拟机中,对象在内存中的结构可以划分为4部分区域:

  • markword
  • 类型指针
  • 示例数据(类中的属性)
  • 对其填充

markword主要描述了当前是哪个线程获取到锁资源,记录的是线程对象信息,当线程释放锁资源的时候就会把线程对象信息清除掉,其它线程就可以继续获取锁资源。

2.volatile关键字

synchronized可以解决原子性,内存可见性问题,但不能解决有序性问题。这时候就需要用到另一个关键字---volatile。

2.1volatile保证内存可见性问题

volatile修饰的变量,能够保证“内存可见性”。

代码在写入volatile修饰的变量的时候

  • 改变线程工作内存中volatile变量副本的值
  • 将改变后的副本的值从工作内存刷新到主内存

代码在读取volatile修饰的变量的时候

  • 从主内存中读取volatile变量的最新值到线程的工作内存中
  • 从工作内存中读取volatile变量的副本

示例代码:

  • 创建两个线程 t1 t2
  • t1 中包含一个循环, 这个循环以 flag == 0 为循环条件.
  • t2 中从键盘读入一个整数, 并把这个整数赋值给 flag.
  • 预期当用户输入非 0 的值的时候, t1 线程结束.
package com.bitejiuyeke.lesson04;

import java.util.Scanner;
import java.util.concurrent.TimeUnit;

/**
 * 重现内存可见性问题
 * 创建两个线程 ,一个线程不行的循环判断标识决定是否退出
 * 第二个线程来来修改标识位
 *
 * @Author 比特就业课
 * @Date 2023-05-05
 */
public class Demo29_Volatile {

    private static int flag = 0;

    public static void main(String[] args) throws InterruptedException {
        // 定义第一个线程
        Thread t1 = new Thread(() -> {
            System.out.println("t1线程已启动.");
            // 循环判断标识位
            while (flag == 0) {
                // TODO :
                try {
                    Thread.sleep(1);
                } catch (InterruptedException e) {
                    e.printStackTrace();
                }
            }
            System.out.println("t1线程已退出.");
        });
        // 启动线程
        t1.start();

        // 定义第二个线程,来修改flag的值
        Thread t2 = new Thread(() -> {
            System.out.println("t2线程已启动");
            System.out.println("请输入一个整数:");
            Scanner scanner = new Scanner(System.in);
            // 接收用户输入并修改flag的值
            flag = scanner.nextInt();
            System.out.println("t2线程已退出");
        });
        // 确保让t1先启动
        TimeUnit.SECONDS.sleep(1);
        // 启动t2线程
        t2.start();


    }
}

运行结果:

原因:

1.线程1在执行过程中并没有对flag进行修改

2.在执行时,线程1先从主内存把flag加载到自己的工作内存中,也就是寄存器和缓存中

3.CPU对执行的过程有一定的优化:既然当前线程没有修改变量的值,而工作内存的读取速度是主内存的一万倍以上,那么每判断这个flag时从工作内存读取即可

4.目前线程2修改flag的值之后,并没有一种机制来通知线程1获取最新的值

为变量加入volatile之后:

    // 注意观察用volatile修饰后的现象
    private static volatile int flag = 0;

程序可以正常退出:

 MESI缓存一致性协议

缓存一致性协议:当某个线程修改了一个共享变量之后,通知其它CPU对该变量的缓存中置为失效状态。当其它CPU中执行的指令再需要获取缓存中变量的值时,发现这个值被置为失效状态,那么就需要从主内存中重新加载最新的值。

内存屏障

对加了volatile的变量,加入了以下的内存屏障,Load表示读,Store表示写。

当发送写操作之后就会通过缓存一致性协议来通知其它的CPU中的缓存值失效。

所以,volatile可以解决内存可见性问题

2.2volatile解决有序性问题

有序性指的是再保证程序执行结果正确的前提下,编译器,CPU对指令的优化过程。

volatile修饰的变量,就是要告诉编译器,不需要对这个变量所涉及操作进行优化从而实现有序性。

所以,volatile可以解决有序性问题

3.总结synchronized和volatile解决的问题

再代码中,对于共享变量最好加上volatile关键字。

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

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

相关文章

ELK -- kibana 用nginx代理后无法访问

背景: 本地搭建好elk后,一切正常,后面改成用nginx代理kibana的5601端口,发现代理后无法正常访问(未代理的地址可正常访问),花了很多时间去查问题,报错基本都是http://ip:port/spaces…

Leetcode刷题之复制带随机指针的链表

生命不是安排,而是追求,人生的意义也许永远没有答案,但也要尽情感受这种没有答案的人生。 --弗吉尼亚. 伍尔芙 目录 前言: 🌸一.复制带随机指针的链表 🌅1.复制结点链接到原本链表每一个结点的…

24个强大的HTML属性,每个资深Web工程师都应该掌握!

HTML 属性非常多,除了基本的一些属性外,还有很多很有用的功能性特别强大的属性; 本文将介绍24个强大的HTML属性,这些属性可以让你的网站更加动态和交互,让用户感到更加舒适和愉悦。 让我们一起来探索这24个强大的HTML…

进程优先级+环境变量++地址空间+虚拟地址空间

索引 一.进程优先级二.环境变量1.通过代码如何获取环境1.通过第三个命令行参数获得2.根据第三方变量environ获取3.通过系统调用获取环境变量 2.验证环境变量可以被子进程继承下去 三.验证地址空间1.验证程序地址空间2.证明地址空间不是物理地址 四.虚拟地址空间虚拟地址空间存在…

BI财务智能分析,让企业管理更上一层楼

智能财务建设既可以看作是财务管理工作在经济社会数字化转型的全面开启,也可以看作是财务职能在以数字化技术为支撑,形成对内提升单位管理水平和风险管控能力、对外服务财政管理和宏观经济治理的会计职能拓展,究其本质则是在财务数字化转型升…

简单介绍之隔离级别与分布式事务

一,分布式系统与环境问题 概念 系统可以笼统分为集中式系统和分布式系统。 集中式系统就是由一台或多台主计算机组成中心节点,系统所有功能均由其集中处理。 分布式系统是硬件和软件组件分布不同的网络计算机上,彼此之间仅仅通过消息传递进…

植被参数光学遥感反演方法(Python)及遥感与生态模型数据同化算法技术应用

传统的地面实测方法能够得到比较准确的植被参数(如叶面积指数、覆盖度、生物量、叶绿素、干物质、叶片含水量、FPAR等),但其获取信息有限,难以满足大范围提取植被参数的需求,尤其在异质地表区域。遥感技术的发展为植被…

C++学习day--07 字符串

1、黑客攻击系统-用户输入的优化 第 1 节 项目需求 1. 用户登录时&#xff0c;用户可能输入很长的用户名。 2. 使用 char 类型和 int 类型&#xff0c;表示用户名和密码&#xff0c;不安全。 第 2 节 项目实现 #include <iostream> #include <Windows.h> …

MacBook重置与推荐软件配置

Mac OS 12.6.5 前言重置初始化配置说明 GitJava 8 & Maven & MysqlJava 8mavenMySQL配置 MotrixDBeaver添加aliyun的maven至DBeaver添加MySQL VS CodeSteamTyporaiStas Menus 前言 用了一年的机械革命游戏本,机器加外设20斤的重量背过几次出门后就再也不想带出门了,运行…

PyYaml反序列化漏洞

0x01 HDCTF 遇到预期解是考的yaml了&#xff0c;前来学习下 语法 语法就不贴了&#xff0c;其他文章有介绍 语法和 yml配置文件的 语法差不多 就不一一介绍 漏洞成因与利用 PyYaml < 5.1 在python 中 pyyaml是提供 python 和Yaml 两种语言的转换&#xff0c;与pickle 类…

C++20协程

简介 ​ C20协程只是提供协程机制&#xff0c;而不是提供协程库。C20的协程是无栈协程&#xff0c;无栈协程是一个可以挂起/恢复的特殊函数&#xff0c;是函数调用的泛化&#xff0c;且只能被线程调用&#xff0c;本身并不抢占内核调度。 ​ C20 提供了三个新关键字(co_await…

【DRF配置管理】如何建立swagger风格api接口文档

原文作者&#xff1a;我辈李想 版权声明&#xff1a;文章原创&#xff0c;转载时请务必加上原文超链接、作者信息和本声明。 DRF应用和管理 【DRF配置管理】Django安装和使用DRF框架 【DRF配置管理】如何在视图函数配置参数(一) 【DRF配置管理】如何在视图函数配置参数(二) 【…

C. Enlarge GCD(内存的限制 + 数组的访问速度)

Problem - C - Codeforces Mr. F 有 n 个正整数 a1,a2,…,an。 他认为这些整数的最大公约数太小了。所以他想通过删除其中一些整数来扩大它。 但是这个问题对他来说太简单了&#xff0c;所以他不想自己做。如果你帮他解决这个问题&#xff0c;他会给你一些奖励分数。 你的任…

AntDB数据库携手金蝶Apusic应用服务器, 共促信创产业繁荣发展

日前&#xff0c;湖南亚信安慧科技有限公司&#xff08;简称&#xff1a;亚信安慧&#xff09;与深圳市金蝶天燕云计算股份有限公司&#xff08;简称&#xff1a;金蝶天燕&#xff09;完成AntDB数据库与金蝶Apusic服务器软件V9.0、V10产品的兼容互认&#xff0c;兼容性良好&…

不是吧,3 : 00 面试,还没10分钟就出来了,问的也太...

从外包出来&#xff0c;没想到死在另一家厂子 自从加入这家公司&#xff0c;每天都在加班&#xff0c;钱倒是给的不少&#xff0c;所以也就忍了。没想到2月一纸通知&#xff0c;所有人不许加班&#xff0c;薪资直降30%&#xff0c;顿时有吃不起饭的赶脚。 好在有个兄弟内推我去…

Android WebRtc+SRS/ZLM视频通话(3):安装ZLMediaKit

Android WebRtcSRS/ZLM视频通话&#xff08;3&#xff09;&#xff1a;安装ZLMediaKit 来自奔三人员的焦虑日志 接着上一章内容&#xff0c;继续来记录ZLMediaKit的安装&#xff0c;这里的ZLMediaKit实际上和SRS的功能差不多&#xff0c;都是国内流媒体服务框架使用人数比价多&…

【SpringBoot】MyBatis与MyBatis-Plus分页查询问题

笔者写这篇博客是因为近期遇到的关于两者之间的分页代码差距&#xff0c;其实之前也遇见过但是没有去整理这篇博客&#xff0c;但由于还是被困扰了小一会儿时间&#xff0c;所以还是需要加深记忆。其实会看前后端传参解决这个问题很快、不麻烦。关于这两个框架的分页代码问题主…

物联网|整体介绍|蓝牙4.0BLE信道分析与拓扑分析|物联网之蓝牙4.0 BLE基础-学习笔记(1)

文章目录 课程整体介绍1、蓝牙4.0自身的优点2、开设这门课的重要性3课程的总体规划4.课程目的5.培训对象 蓝牙4.0BLE信道分析与拓扑分析蓝牙4.OBLE信道分析柘扑分析星型拓扑结构:扮演角色广播结构;星型结构的建立过程: 课程整体介绍 为什么我们要开设这么课程呢? 1、蓝牙4.0…

JDK17新特性之--JDK9到JDK17 String 新增的新方法

JDK9之后对String底层存储数据结构进行了重大的修改1&#xff0c;同步也增加了许多新的方法&#xff0c;主要有Text Blocks、chars()、codePoints()、describeConstable()、formatted()、indent()、isBlank()、isEmpty()、lines()、repeat()、strip()、stripLeading()、stripIn…

判断大小端的错误做法

这里不详细讲解大小端的区别&#xff0c;只讲解判断大小端的方法。 1.大端&#xff0c;小端的区别 0x123456 在内存中的存储方式 大端是高字节存放到内存的低地址 小端是高字节存放到内存的高地址 2.大小端的判断 1.错误的做法 int main() {int a0x1234;char c(char)a;if(…