当前位置: 首页 > news >正文

【并发编程】synchornized原理

       📝个人主页:五敷有你      
 🔥
系列专栏:并发编程
⛺️稳重求进,晒太阳


 

目录

Monitor概念

Java对象头

普通对象

数组对象

Monitor(锁)

Monitor结构如下:

注意:

原理之synchornized

        轻量级锁

锁膨胀(重量级锁)

自旋优化

偏向锁

示例

 轻量级锁与偏向锁加锁的对比

偏向状态

一个对象创建时:

撤销-调用对象hashCode

撤销-其他线程使用对象

批量重定向

批量撤销

锁消除


Monitor概念

Java对象头

以32位机的机器为例

普通对象

数组对象

其中Mark Word结构为

Monitor(锁)

Monitor被翻译为监视器或管程

每个Java对象都可以关联一个Monitor对象,如果使用synchronized给对象上锁(重量级)之后,该对象头的Mark Word中就被设置指向Monitor对象的指针。

Monitor结构如下:

  • 刚开始Monitor中Owner为null
  • 当Thread-2执行synchronized(obj) 就会将Monitor 的所有者Owner设置为Thread-2,Monitor中只能有一个Owner.
  • 在Thread-2上锁的过程中,如果Thread-3,Thread-4也来执行synchronized(obj) 就会进入EntryList BLOCKED阻塞队列
  • Thread-2执行完同步代码块的内容,然后唤醒EntryList 中等待的线程来竞争锁,竞争的锁是非公平的。
  • 图中WaitSet中的Thread-0,Thread-1 是之前获得过锁,但条件不满足进入WAITING 状态的线程。后面会将wait-notify

注意:

  • synchronized 必须是进入同一个对象的monitor才有上述的效果
  • 不加synchronized 的对象不会关联监视器,不遵从以上规则

原理之synchornized

        轻量级锁

        轻量级锁的使用场景:如果一个对象虽然有多线程访问,但多线程访问的时间是错开的(也就是没有竞争)。那么就可以使用轻量级锁优化

        轻量级锁对使用者是透明的,即语法仍然是synchronized

        假设有两个同步块,利用同一个对象加锁。

static final Object obj=new Object();
public static void method1(){synchornized(obj){//同步块 Amethod2();}
}
public static void method2(){synchronized(obj){//同步块b    }
}
  • 创建锁对象,每个线程的栈帧会包含一个锁记录的结构,内部可以存储锁定对象的Mark Word

  • 让锁记录中的Object reference指向锁对象,并尝试使用CAS替换Object的Mark Word,将Mark Word的值存入锁记录

  • 如果CAS替换成功,对象头中存储了锁记录地址和状态,表示由该线程给对象加锁,这时图示如下:

  • 如果cas失败:
    • 如果是其他线程已经持有了该Object的轻量级锁,这时候表面有竞争,进入锁膨胀过程。
    • 如果是自己执行了synchronized 锁重入,那么再添加一条Lock Record 作为重入的计数

  • 当退出synchronized 代码块(解锁时) 如果有取值为null 的记录,表示有重入,这时重置锁记录,表示重入计数-1

  • 当退出synchronized 代码块(解锁时)锁记录的值不为null ,这时使用cas将Mark Word的值恢复给对象头

成功:解锁成功

失败: 说明轻量级锁进行了锁膨胀或已经升级为重量级锁。进入重量级锁解锁流程

锁膨胀(重量级锁)

如果在尝试加轻量级锁的过程中,CAS操作无法成功,这时一种情况就是有其他线程为此对象加上了轻量级锁(有竞争),这时需要进行锁膨胀,将轻量级锁变为重量级锁。

当Thread -1进行轻量级加锁时,Thread-0已经对该对象加了轻量级锁

这时候Thread-1加锁失败,进入锁膨胀流程。

  • 即为Object对象申请Monitor锁,让Object指向重量级锁地址
  • 然后自己进入Monitor的EntryList BLOCKED

  • 当Thread-0 退出同步代码块时,使用CAS将MarkWord 的值恢复给对象头,失败,这时候会进入重量级解锁流程,按照Monitor地址找到Monitor对象,设置Owner为null, 唤醒EntryList 中的BLOCKED
自旋优化

自选在多核CPU下才有意义

重量级锁竞争的时候,还可以使用自旋来进行优化,如果当前线程自选成功(即这时候锁线程已经退出了同步块,释放了锁)),

这时当前线程就可以避免阻塞。

偏向锁

        轻量级锁在没有竞争时(就自己这个线程),每次重入都需要进行CAS操作。

        Java6 引入了偏向锁来进一步优化,只有第一次使用CAS将线程ID设置到对象的Mark Word头,之后发现这个线程ID是自己的就表示没有竞争,不需要重新CAS,以后只要不发生竞争,这个对象就归线程所有。

示例
static final Object obj=new Object();
public static void m1(){synchronized(obj){//同步代码块Am2();    }
}
public static void m2(){synchronized(obj){//同步代码块Bm3();    }
}
public static void m3(){synchronized(obj){//同步块C    }
}
 轻量级锁与偏向锁加锁的对比

偏向状态

回忆一下对象头格式

一个对象创建时:

        如果开启了偏向锁,那么对象创建后,markword值为0x05即最后三位为101(表示可以偏向的状态),这时它的thread epoch age都为0

        偏向锁是默认是延迟的,不会在程序启动后立刻生效。如果想要避免延迟,可以加VM参数:xx:BiasedLockingstartupDalay=0来禁止延迟

        如果没有开启偏向锁,那么对象创建后,markword值为0x01,即后三位为001,这时它的hashcode 、age都为0,第一次用到hashcode时才会赋值。

(调用了hashcode会让偏向状态禁用,让他变为不可偏向的对象)

撤销-调用对象hashCode

调用了对象的hashCode,但偏向锁的对象MarkWord中存储的是线程id,如果调用hashCode会导致偏向锁被撤销

  • 轻量级锁会在锁记录中记录hashCode
  • 重量级锁会在Monitor中纪录hashCode

在调用hashCode后使用偏向锁,记得去掉-xx:UseBiassedLocking

输出

撤销-其他线程使用对象

        当有其他线程使用偏向锁时,会偏向锁升级为轻量级锁

批量重定向

        如果对象虽然被多个线程访问,但没有竞争,这时候偏向了线程T1的对象仍有机会重新偏向T2,重偏向会重置对象的ThreadID,

        当撤销偏向锁阈值超过20次后,jvm会认为,我是不是偏向错了,于是会在这些对象加锁时重新偏向加锁线程。

详解:

    我们知道,当我们使用synchronized关键字的时候,一个对象a只被一个对象访问的时候,对对象加的锁偏向锁,如果之后出现第二个线程访问a的时候(这里只考虑线程交替执行的情况,不存在竞争),不管线程1是已死亡还是运行状态,此时锁都会升级为轻量锁,并且锁升级过程不可逆。

    但是如果有很多对象,这些对象同属于一个类(假设是类A)被线程1访问并加偏向锁,之后线上2来访问这些对象(不考虑竞争情况),在通过CAS操作把这些锁升级为轻量锁,会是一个很耗时的操作。

JVM对此作了优化:

    当对象数量超过某个阈值时(默认20, jvm启动时加参数-XX:+PrintFlagsFinal可以打印这个阈值 ),Java会对超过的对象作批量重偏向线程2,此时前20个对象是轻量锁,后面的对象都是偏向锁,且偏向线程2。

批量撤销

当撤销偏向锁阈值超过40次后,jvm会这样觉得,我们确实偏向错了,根本就不该偏向,于是整个类的所有对象都会变为不可偏向的,新建的对象也是不可偏向的

锁消除

相关文章:

【并发编程】synchornized原理

📝个人主页:五敷有你 🔥系列专栏:并发编程 ⛺️稳重求进,晒太阳 目录 Monitor概念 Java对象头 普通对象 数组对象 Monitor(锁) Monitor结构如下: 注意: 原理之synchornized 轻量…...

计算机网络-ACL访问控制列表

上一篇介绍NAT时候就看到了ACL这个东西了,这个是什么意思?有什么作用呢? 一、ACL访问控制列表 访问控制列表 (ACL, Access Control List)是由一系列permit或deny语句组成的、有序规则的列表。ACL是一个匹配工具,能够对报文进行匹配…...

论文学习记录之SeisInvNet(Deep-Learning Inversion of Seismic Data)

目录 1 INTRODUCTION—介绍 2 RELATED WORKS—相关作品 3 METHODOLOGY AND IMPLEMENTATION—方法和执行 3.1 方法 3.2 执行 4 EXPERIMENTS—实验 4.1 数据集准备 4.2 实验设置 4.3 基线模型 4.4 定向比较 4.5 定量比较 4.6 机理研究 5 CONCLUSION—结论 1 INTRODU…...

深度学习中的优化方法

深度学习中的优化问题通常指的是:寻找神经网络上的一组参数 θ \theta θ,它能显著地降低代价函数 J ( θ ) J(\theta) J(θ...

【设计模式之美】重构(三)之解耦方法论:如何通过封装、抽象、模块化、中间层等解耦代码?

文章目录 一. “解耦”概述二. 如何给代码“解耦”?1. 封装与抽象2. 中间层2.1. 引入中间层能**简化模块或类之间的依赖关系**。2.2. 引入中间层可以起到过渡的作用,能够让开发和重构同步进行,不互相干扰。 3. 模块化4. 其他设计思想和原则4.…...

Spring MVC学习之——Controller类中方法的返回值

Controller类中方法的返回值 1.返回ModelAndView RequestMapping("/hello")public ModelAndView hello(){//封装了页面和数据ModelAndView view new ModelAndView();//对这个请求的页面添加属性(数据)view.addObject("hello",&quo…...

IDEA中启动项目报堆内存溢出或者没有足够内存的错误

1.报错现象 java.lang.OutOfMemoryError: Java heap space 或者 Could not reserve enough space for object heap 2.解决办法 在运行配置中VM选项后加下面的配置: -server -XX:MaxHeapSize256m -Xms512m -Xmx512m -XX:PermSize128M -XX:MaxPermSize256m 3.JVM虚…...

Angular: DOCUMENT

不用原生的 document,是因为不利于后端渲染,所以避免使用原生浏览器的对象 import { DOCUMENT } from angular/common; import { Directive, Inject, Input, OnChanges, Output, Renderer2, SimpleChanges } from angular/core;Directive({selector: [a…...

mybatis-plus批量保存异常及效率优化

最近基于自己公司内部服务维护,发现其中调度中心近期出现不少错误日志,但是该任务却是正常执行,生成的报表数据也是正常的,所以很多天没有发现问题 这就匪夷所思了, 经仔细排查发现,是触发了feign超时hyst…...

查找局域网树莓派raspberry的mac地址和ip

依赖python库: pip install socket pip install scapy运行代码: import socket from scapy.layers.l2 import ARP, Ether, srpdef get_hostname(ip_address):try:return socket.gethostbyaddr(ip_address)[0]except socket.herror:# 未能解析主机名ret…...

乐观锁与悲观锁:高并发场景下的选择

😄 19年之后由于某些原因断更了三年,23年重新扬帆起航,推出更多优质博文,希望大家多多支持~ 🌷 古之立大事者,不惟有超世之才,亦必有坚忍不拔之志 🎐 个人CSND主页——Mi…...

vue2 省市区联动组件封装

在element ui中有级联选择器el-cascader,其实已经够用了,但是在实际需求中,发现el-cascader如果有三级,数据数组必须得三个才能完全展示,所以不符合实际需求,还是自定义封装吧 需求:省市区联动数组,有多少个显示多少个 这里使用element ui得el-select组件,思路是使用…...

VScode远程开发

VScode远程开发 在SSH远程连接一文中,我么介绍了如何使用ssh远程连接Jetson nano端,但是也存在诸多不便,比如:编辑文件内容时,需要使用vi编辑器,且在一个终端内,无法同时编辑多个文件。本节将介绍一较为实用…...

芯片设计重要工具—— IBM LSF 分布式高性能计算调度平台

IBM Spectrum LSF Suites 是面向分布式高性能计算 (HPC) 的工作负载管理平台和作业调度程序。基于 Terraform 的自动化现已可用,该功能可在 IBM Cloud 上为基于 IBM Spectrum LSF 的集群供应和配置资源。 借助我们针对任务关键型 HPC 环境的集成解决方案&#xff0…...

RDMA Scatter Gather List详解

1. 前言 在使用RDMA操作之前,我们需要了解一些RDMA API中的一些需要的值。其中在ibv_send_wr我们需要一个sg_list的数组,sg_list是用来存放ibv_sge元素,那么什么是SGL以及什么是sge呢?对于一个使用RDMA进行开发的程序员来说&#…...

【动态规划】24子数组系列_最长湍流子数组_C++

题目链接:最长湍流子数组 目录 题目解析: 算法原理 1.状态表示 2.状态转移方程 3.初始化 4.填表顺序 5.返回值 编写代码 题目解析: 题目让我们求返回 arr 的 最大湍流子数组的长度 由题可得: 如果比较符号在子数组中的…...

fastJson和jackson的日期数据处理

目录 1.jackson 2.fastjson 3.总结 1.jackson jackson是spring mvc默认的JSON解析方法,前端的数据序列化处理之后,后端经过反序列化处理可以直接使用实体对象进行接收。后端接口返回实体对象,经过序列化处理后前端可以接收并进行处理。 …...

书生·浦语大模型实战营第五节课笔记及作业

LMDeploy 大模型量化部署实践 1 大模型部署背景 1.1 模型部署及大模型特点 1.2 大模型部署挑战及方案 2 LMDeploy简介 2.1 核心功能-量化 2.2 核心功能-推理引擎TurboMind 2.1 核心功能-推理服务api server 3 动手实践及作业 按照文档LMDeploy 的量化和部署中的步骤在Intern…...

如何在CentOS 7 中基于OpenSSL 3.0 搭建Python 3.0 环境

1、OpenSSL 1.1 原因 [rootlocalhost ~]# openssl version OpenSSL 1.0.2k-fips 26 Jan 2017 [rootlocalhost ~]#通过执行openssl version可知Linux系统已经安装了OpenSSL,但该版本较低;Python 3 要求 OpenSSL版本不能低于1.1.1,否则安装P…...

爬虫接口获取外汇数据(汇率,外汇储备,贸易顺差,美国CPI,M2,国债利率)

akshare是一个很好用的财经数据api接口,完全免费!!和Tushare不一样。 除了我标题显示的数据外,他还提供各种股票数据,债券数据,外汇,期货,宏观经济,基金,银行…...

多模态2025:技术路线“神仙打架”,视频生成冲上云霄

文|魏琳华 编|王一粟 一场大会,聚集了中国多模态大模型的“半壁江山”。 智源大会2025为期两天的论坛中,汇集了学界、创业公司和大厂等三方的热门选手,关于多模态的集中讨论达到了前所未有的热度。其中,…...

iOS 26 携众系统重磅更新,但“苹果智能”仍与国行无缘

美国西海岸的夏天,再次被苹果点燃。一年一度的全球开发者大会 WWDC25 如期而至,这不仅是开发者的盛宴,更是全球数亿苹果用户翘首以盼的科技春晚。今年,苹果依旧为我们带来了全家桶式的系统更新,包括 iOS 26、iPadOS 26…...

CVPR 2025 MIMO: 支持视觉指代和像素grounding 的医学视觉语言模型

CVPR 2025 | MIMO:支持视觉指代和像素对齐的医学视觉语言模型 论文信息 标题:MIMO: A medical vision language model with visual referring multimodal input and pixel grounding multimodal output作者:Yanyuan Chen, Dexuan Xu, Yu Hu…...

python打卡day49

知识点回顾: 通道注意力模块复习空间注意力模块CBAM的定义 作业:尝试对今天的模型检查参数数目,并用tensorboard查看训练过程 import torch import torch.nn as nn# 定义通道注意力 class ChannelAttention(nn.Module):def __init__(self,…...

基于距离变化能量开销动态调整的WSN低功耗拓扑控制开销算法matlab仿真

目录 1.程序功能描述 2.测试软件版本以及运行结果展示 3.核心程序 4.算法仿真参数 5.算法理论概述 6.参考文献 7.完整程序 1.程序功能描述 通过动态调整节点通信的能量开销,平衡网络负载,延长WSN生命周期。具体通过建立基于距离的能量消耗模型&am…...

线程同步:确保多线程程序的安全与高效!

全文目录: 开篇语前序前言第一部分:线程同步的概念与问题1.1 线程同步的概念1.2 线程同步的问题1.3 线程同步的解决方案 第二部分:synchronized关键字的使用2.1 使用 synchronized修饰方法2.2 使用 synchronized修饰代码块 第三部分&#xff…...

理解 MCP 工作流:使用 Ollama 和 LangChain 构建本地 MCP 客户端

🌟 什么是 MCP? 模型控制协议 (MCP) 是一种创新的协议,旨在无缝连接 AI 模型与应用程序。 MCP 是一个开源协议,它标准化了我们的 LLM 应用程序连接所需工具和数据源并与之协作的方式。 可以把它想象成你的 AI 模型 和想要使用它…...

pam_env.so模块配置解析

在PAM(Pluggable Authentication Modules)配置中, /etc/pam.d/su 文件相关配置含义如下: 配置解析 auth required pam_env.so1. 字段分解 字段值说明模块类型auth认证类模块,负责验证用户身份&am…...

【大模型RAG】Docker 一键部署 Milvus 完整攻略

本文概要 Milvus 2.5 Stand-alone 版可通过 Docker 在几分钟内完成安装;只需暴露 19530(gRPC)与 9091(HTTP/WebUI)两个端口,即可让本地电脑通过 PyMilvus 或浏览器访问远程 Linux 服务器上的 Milvus。下面…...

Golang dig框架与GraphQL的完美结合

将 Go 的 Dig 依赖注入框架与 GraphQL 结合使用,可以显著提升应用程序的可维护性、可测试性以及灵活性。 Dig 是一个强大的依赖注入容器,能够帮助开发者更好地管理复杂的依赖关系,而 GraphQL 则是一种用于 API 的查询语言,能够提…...