- ubuntu12.04环境下使用kvm ioctl接口实现最简单的虚拟机
- Ubuntu 通过无线网络安装Ubuntu Server启动系统后连接无线网络的方法
- 在Ubuntu上搭建网桥的方法
- ubuntu 虚拟机上网方式及相关配置详解
CFSDN坚持开源创造价值,我们致力于搭建一个资源共享平台,让每一个IT人在这里找到属于你的精彩世界.
这篇CFSDN的博客文章查漏补缺synchronized和ReentrantLock的基本原理由作者收集整理,如果你对这篇文章有兴趣,记得点赞哟.
1、java锁的类型 。
java的锁有这么几类.
乐观锁和悲观锁 。
可重入和不可重入 。
公平锁和非公平锁 。
排他锁和共享锁 。
2、synchronized 。
synchronized基本原理是通过CPU指令实现的。在jdk1.6之前是很重的锁。因为java的多线程与操作系统的线程是一一对应的。当java线程阻塞的时候需要切换到内核态的线程进行阻塞,唤醒的时候又要从内核态切换到用户态,进行了很重的上下文切换。那么能不能当一个线程获取不到锁的时候不阻塞呢?自旋可以吗?这样就有了synchronized的四种实现:无锁、偏向锁、轻量锁、重量锁.
synchronized锁的是java的对象头,再详细点是mark word.
无锁 。
这个没有什么好说的。没有将这个对象通过synchronized包括.
偏向锁 。
当只有一个线程在访问锁的时候,会在mark word中通过CAS的方式设置当前线程的threadId。如果成功的话,加锁成功(由于只有一个线程,肯定成功)。这样当这个线程再次请求锁的时候,看mark word的thread id和自己是否相同,如果相同加锁成功。注意,它是没有解锁操作的。如果是另一个线程也来了,由于上一个线程没有解锁操作,这个新线程的CAS肯定失败。这时当JVM没有字节码要执行的时候(全局安全点),会检查上一个线程有没有结束,如果结束,则通过CAS将mark word中的thread id字段更新为新线程的threadId。如果上一个线程没有结束,这就存在并发了。偏向锁无法完成使命,需要升级为轻量锁.
轻量锁 。
接着上面偏向锁的上一个线程A和新的线程B的例子。JVM此时进行一下线程A对mark word的操作。将mark word拷贝到当前线程的栈空间中,CAS操作mark word的指针指向这个栈空间的地址,CAS操作当前线程的栈空间再加一个指向mark word的指针,这两个操作成功后,其实第一个CAS成功就是成功,这样线程A就获得了锁,升级成为了轻量锁。线程B会自旋等待线程A的释放。线程A怎么释放锁呢?只要将第一个CAS操作的指针(mark word指向线程栈的指针)释放了就可以了,线程B自旋检测mark word的指向,去抢占锁。如果此时又来一个线程C呢?是不是也自旋?可以同时有几个线程自旋?线程B能自旋多少次?这些都是有JVM参数可配置的.
重量锁 。
这个其实也没什么好说的。存在并发访问时,直接将线程切换到内核态阻塞.
3、ReentrantLock 。
ReentrantLock是通过AQS(AbstractQueuedSynchronizer)实现的。需要解决的问题:
需要有个状态表示这个lock对象是不是被抢占了,如果可重入的话,被这个线程抢占了多少次。这个状态标识其实就是AQS的state成员变量。对state的操作肯定要线程安全。可以通过CAS解决.
protected final boolean tryAcquire(int acquires) { 。
final Thread current = Thread.currentThread(); 。
int c = getState(); 。
if (c == 0) { 。
// 这个是公平锁的实现。需要判断队列中有没有等待的线程, 。
// 如果没有才进行CAS抢占 。
if (!hasQueuedPredecessors() && 。
compareAndSetState(0, acquires)) { 。
setExclusiveOwnerThread(current); 。
return true; 。
} 。
} 。
// 这里就是可重入逻辑 。
else if (current == getExclusiveOwnerThread()) { 。
int nextc = c + acquires; 。
if (nextc < 0) 。
throw new Error("Maximum lock count exceeded"); 。
setState(nextc); 。
return true; 。
} 。
return false; 。
} 。
多个线程同时抢占lock,只有一个线程能成功,其他线程怎么排队呢?排队的线程怎么抢占锁呢?这就用到了一个队列。这个队列的插入是通过自旋和CAS实现的.
private Node addWaiter(Node mode) { 。
Node node = new Node(mode); 。
// 循环尝试 。
for (;;) { 。
Node oldTail = tail; 。
if (oldTail != null) { 。
// 无锁修改前驱指针 。
node.setPrevRelaxed(oldTail); 。
// CAS修改tail 。
if (compareAndSetTail(oldTail, node)) { 。
// 修改后续指针 。
oldTail.next = node; 。
return node; 。
} 。
} else { 。
initializeSyncQueue(); 。
} 。
} 。
} 。
排队的线程抢占lock呢?
final boolean acquireQueued(final Node node, int arg) { 。
boolean interrupted = false; 。
try { 。
for (;;) { 。
final Node p = node.predecessor(); 。
// 如果前驱节点是头节点,并且获取锁成功,直接返回。 。
// 但是大多数情况,可能运气没这么好 。
if (p == head && tryAcquire(arg)) { 。
setHead(node); 。
p.next = null; // help GC 。
return interrupted; 。
} 。
// 是否需要阻塞 。
if (shouldParkAfterFailedAcquire(p, node)) 。
// 这里阻塞 。
interrupted |= parkAndCheckInterrupt(); 。
} 。
} catch (Throwable t) { 。
cancelAcquire(node); 。
if (interrupted) 。
selfInterrupt(); 。
throw t; 。
} 。
} 。
怎么唤醒上面阻塞的线程呢?这就要看下释放逻辑.
public final boolean release(int arg) { 。
// 释放lock 。
if (tryRelease(arg)) { 。
Node h = head; 。
if (h != null && h.waitStatus != 0) 。
unparkSuccessor(h); // 唤醒头结点的后续节点。注意头结点是虚节点,没有实在意义 。
return true; 。
} 。
return false; 。
} 。
原文地址:https://www.toutiao.com/i6933840985927598600/ 。
最后此篇关于查漏补缺synchronized和ReentrantLock的基本原理的文章就讲到这里了,如果你想了解更多关于查漏补缺synchronized和ReentrantLock的基本原理的内容请搜索CFSDN的文章或继续浏览相关文章,希望大家以后支持我的博客! 。
本文全面深入地探讨了Docker容器通信技术,从基础概念、网络模型、核心组件到实战应用。详细介绍了不同网络模式及其实现,提供了容器通信的技术细节和实用案例,旨在为专业从业者提供深入的技术洞见和实
📒博客首页:崇尚学技术的科班人 🍣今天给大家带来的文章是《Dubbo快速上手 -- 带你了解Dubbo使用、原理》🍣 🍣希望各位小伙伴们能够耐心的读完这篇文章🍣 🙏博主也在学习阶段,如若发
一、写在前面 我们经常使用npm install ,但是你是否思考过它内部的原理是什么? 1、执行npm install 它背后帮助我们完成了什么操作? 2、我们会发现还有一个成为package-lo
Base64 Base64 是什么?是将字节流转换成可打印字符、将可打印字符转换为字节流的一种算法。Base64 使用 64 个可打印字符来表示转换后的数据。 准确的来说,Base64 不算
目录 协程定义 生成器和yield语义 Future类 IOLoop类 coroutine函数装饰器 总结 tornado中的
切片,这是一个在go语言中引入的新的理念。它有一些特征如下: 对数组抽象 数组长度不固定 可追加元素 切片容量可增大 容量大小成片增加 我们先把上面的理念整理在这
文章来源:https://sourl.cn/HpZHvy 引 言 本文主要论述的是“RPC 实现原理”,那么首先明确一个问题什么是 RPC 呢?RPC 是 Remote Procedure Call
源码地址(包含所有与springmvc相关的,静态文件路径设置,request请求入参接受,返回值处理converter设置等等): spring-framework/WebMvcConfigurat
请通过简单的java类向我展示一个依赖注入(inject)原理的小例子虽然我已经了解了spring,但是如果我需要用简单的java类术语来解释它,那么你能通过一个简单的例子向我展示一下吗?提前致谢。
1、背景 我们平常使用手机和电脑上网,需要访问公网上的网络资源,如逛淘宝和刷视频,那么手机和电脑是怎么知道去哪里去拿到这个网络资源来下载到本地的呢? 就比如我去食堂拿吃的,我需要
大家好,我是飞哥! 现在 iptables 这个工具的应用似乎是越来越广了。不仅仅是在传统的防火墙、NAT 等功能出现,在今天流行的的 Docker、Kubernets、Istio 项目中也经
本篇涉及到的所有接口在公开文档中均无,需要下载 GitHub 上的源码,自己创建私有类的文档。 npm run generateDocumentation -- --private yarn gene
我最近在很多代码中注意到人们将硬编码的配置(如端口号等)值放在类/方法的深处,使其难以找到,也无法配置。 这是否违反了 SOLID 原则?如果不是,我是否可以向我的团队成员引用另一个“原则”来说明为什
我是 C#、WPF 和 MVVM 模式的新手。很抱歉这篇很长的帖子,我试图设定我所有的理解点(或不理解点)。 在研究了很多关于 WPF 提供的命令机制和 MVVM 模式的文本之后,我在弄清楚如何使用这
可比较的 jQuery 函数 $.post("/example/handler", {foo: 1, bar: 2}); 将创建一个带有 post 参数 foo=1&bar=2 的请求。鉴于 $htt
如果Django不使用“延迟查询执行”原则,主要问题是什么? q = Entry.objects.filter(headline__startswith="What") q = q.filter(
我今天发现.NET框架在做计算时遵循BODMAS操作顺序。即计算按以下顺序进行: 括号 订单 部门 乘法 添加 减法 但是我四处搜索并找不到任何文档确认 .NET 绝对 遵循此原则,是否有此类文档?如
已结束。此问题不符合 Stack Overflow guidelines .它目前不接受答案。 我们不允许提出有关书籍、工具、软件库等方面的建议的问题。您可以编辑问题,以便用事实和引用来回答它。 关闭
API 回顾 在创建 Viewer 时可以直接指定 影像供给器(ImageryProvider),官方提供了一个非常简单的例子,即离屏例子(搜 offline): new Cesium.Viewer(
As it currently stands, this question is not a good fit for our Q&A format. We expect answers to be
我是一名优秀的程序员,十分优秀!