深入理解Lock的底层实现原理
lock的实现完全是由java写的,和操作系统或者是JVM虚拟机没有任何关系。整体来看Lock主要是通过两个东西来实现的分别是CAS和ASQ(AbstractQueuedSynchronizer)。通过加锁和解锁的过程来分析锁的实现。
加锁
一、整体概述流程
1. 读取表示锁状态的变量
2. 如果表示状态的变量的值为0,那么当前线程尝试将变量值设置为1(通过CAS操作完成),当多个线程同时将表示状态的变量值由0设置成1时,仅一个线程能成功,其它线程都会失败。失败后进入队列自旋转并阻塞当前线程。
2.1 若成功,表示获取了锁,
2.1.1 如果该线程(或者说节点)已位于在队列中,则将其出列(并将下一个节点则变成了队列的头节点)
2.1.2 如果该线程未入列,则不用对队列进行维护
2.1.3 然后当前线程从lock方法中返回,对共享资源进行访问。
2.2 若失败,则当前线程将自身放入等待(锁的)队列中并阻塞自身,此时线程一直被阻塞在lock方法中,没有从该方法中返回(被唤醒后仍然在lock方法中,并从下一条语句继续执行,这里又会回到第1步重新开始)。
3. 如果表示状态的变量的值为1,那么将当前线程放入等待队列中,然后将自身阻塞
注意: 唤醒并不表示线程能立刻运行,而是表示线程处于就绪状态,仅仅是可以运行而已
二、具体的实现细节(非公平锁)
1、lock方法实现(公平锁与非公平锁的由来)
final void lock() {if (compareAndSetState(0, 1))setExclusiveOwnerThread(Thread.currentThread()); else acquire(1); }
对于刚来竞争的线程首先会通过CAS设置状态,如果设置成功那么直接获取锁,执行临界区的代码,反之调用acquire(1)进入同步队列中。如果已经存在Running线程,那么CAS肯定会失败,则新的竞争线程会通过CAS的方式被追加到队尾。
2、解析acquire(1)方法
public final void acquire(int arg) {if (!tryAcquire(arg) &&acquireQueued(addWaiter(Node.EXCLUSIVE), arg))selfInterrupt(); }
当CAS同步状态为1失败时才会执行上面的代码,上面的代码的作用是完成同步状态的获取,构造用于放入队列中的节点(可以理解为线程任务),加入到队列中,单个节点自己自旋用于检查目前队列中的状况以及当前节点或者是线程阻塞。该方法主要由以下几个方法构成 tryAcquire() addWaiter()和AcquireQueued()。
2.1 nonfairTryAcquire 获取同步状态
final boolean nonfairTryAcquire(int acquires) { final Thread current = Thread.currentThread(); int c = getState(); if (c == 0) {if (compareAndSetState(0, acquires)) {setExclusiveOwnerThread(current); return true; }}else if (current == getExclusiveOwnerThread()) {//说明有线程拥有了该锁,这个线程就是自己本身那么状态++ int nextc = c + acquires; if (nextc < 0) // overflow throw new Error("Maximum lock count exceeded"); setState(nextc); return true; }return false; }
1、 该方法会首先判断当前状态,如果c==0说明没有线程正在竞争该锁,如果不c !=0 说明有线程正拥有了该锁。
2.2 addWaiter 构建入队节点
private Node addWaiter(Node mode) {Node node = new Node(Thread.currentThread(), mode); // Try the fast path of enq; backup to full enq on failure Node pred = tail; if (pred != null) {node.prev = pred; if (compareAndSetTail(pred, node)) {pred.next = node; return node; }}enq(node); return node; }
addWaiter方法负责把当前无法获得锁的线程包装为一个Node添加到队尾。
1、如果当前队尾已经存在(tail!=null),则使用CAS把当前线程更新为Tail
下面是enq方法:
private Node enq(final Node node) {for (;;) {Node t = tail; if (t == null) { // Must initialize Node h = new Node(); // Dummy header h.next = node; node.prev = h; if (compareAndSetHead(h)) {tail = node; return h; }}else {node.prev = t; if (compareAndSetTail(t, node)) {t.next = node; return t; }}}}
final boolean acquireQueued(final Node node, int arg) {try {boolean interrupted = false; for (;;) { final Node p = node.predecessor(); if (p == head && tryAcquire(arg)) {//前驱节点等于头节点,尝试获取同步状态 setHead(node); p.next = null; // help GC return interrupted; }if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())interrupted = true; }} catch (RuntimeException ex) {cancelAcquire(node); throw ex; }}
2.3 acquireQueued 线程对外行为上阻塞,内部自旋
private final boolean parkAndCheckInterrupt() {LockSupport.park(this); return Thread.interrupted() }
解锁
请求锁不成功的线程会被挂起在acquireQueued方法的第12行,12行以后的代码必须等线程被解锁锁才能执行,假如被阻塞的线程得到解锁,则执行第13行,即设置interrupted = true,之后又进入无限循环。
从无限循环的代码可以看出,并不是得到释放锁的线程一定能获得锁,必须在第6行中调用tryAccquire重新竞争,因为锁是非公平的,有可能被新加入的线程获得,从而导致刚被唤醒的线程再次被阻塞,这个细节充分体现了“非公平”的精髓。通过之后将要介绍的解锁机制会可以发现,第一个释放的线程就是Head,因此p == head的判断基本都会成功。
解锁代码相对简单,主要体现在AbstractQueuedSynchronizer.release和Sync.tryRelease方法中class AbstractQueuedSynchronizer
public final boolean release(int arg) {if (tryRelease(arg)) {Node h = head; if (h != null && h.waitStatus != 0)unparkSuccessor(h); return true; }return false; }protected final boolean tryRelease(int releases) {int c = getState() - releases; if (Thread.currentThread() != getExclusiveOwnerThread())throw new IllegalMonitorStateException(); boolean free = false; if (c == 0) {free = true; setExclusiveOwnerThread(null); }setState(c); return free; }
tryRelease语义很明确:如果线程多次锁定,则进行多次释放,直至status==0则真正释放锁,所谓释放锁即设置status为0,因为无竞争所以没有使用CAS。 release的语义在于:如果可以释放锁,则唤醒队列第一个线程(Head),具体唤醒代码如下:
private void unparkSuccessor(Node node) {int ws = node.waitStatus; if (ws < 0)compareAndSetWaitStatus(node, ws, 0); Node s = node.next; if (s == null || s.waitStatus > 0) {s = null; for (Node t = tail; t != null && t != node; t = t.prev)if (t.waitStatus <= 0)s = t; }if (s != null)LockSupport.unpark(s.thread); }
这段代码的意思在于找出第一个可以unpark的线程,一般说来head.next == head,Head就是第一个线程。以上就是加锁解锁的全部过程,需要注意几点:
简述总结:
总体来讲线程获取锁要经历以下过程(非公平):
5、线程释放锁,唤醒队列第一个节点,参与竞争。重复上述。
转载自https://blog.csdn.net/liyantianmin/article/details/54673109
深入理解Lock的底层实现原理相关推荐
- java多线程:9、synchronized、Lock的底层实现原理以及和volatile、Lock、ReentrantLock的区别?
文章目录 0.1.线程中安全性问题的体现: 0.2.线程安全问题的解决办法 1.synchronized的底层实现原理分析 2.Lock的底层实现原理分析? 3.synchronized和volati ...
- 3层b+树索引访问磁盘次数_深入理解MySQL索引底层实现原理丨技术干货
一.索引的本质 MySQL官方对索引的定义为:索引(Index)是帮助MySQL高效获取数据的数据结构.提取句子主干,就可以得到索引的本质:索引是数据结构. 我们知道,数据库查询是数据库的最主要功能之 ...
- 【手写系列】理解数据库连接池底层原理之手写实现
前言 数据库连接池的基本思想是:为数据库连接建立一个"缓冲池",预先在池中放入一定数量的数据库连接管道,需要时,从池子中取出管道进行使用,操作完毕后,再将管道放入池子中,从而避免了 ...
- 分析Volatile的作用及底层实现原理,面试问一点都不慌!
文章简介 分析volatile的作用以及底层实现原理,这也是大公司喜欢问的问题 内容导航 volatile的作用 什么是可见性 volatile源码分析 01.volatile的作用 在多线程中,vo ...
- Java并发机制的底层实现原理
Java代码在编译后会变成Java字节码,字节码被类加载器加载到JVM里,JVM执行字节码,最终需要转化为汇编指令在CPU上执行,Java中所使用的并发机制依赖于JVM的实现和CPU的指令.本章我们将 ...
- Java多线程之线程池7大参数、底层工作原理、拒绝策略详解
Java多线程之线程池7大参数详解 目录 企业面试题 线程池7大参数源码 线程池7大参数详解 底层工作原理详解 线程池的4种拒绝策略理论简介 面试的坑:线程池实际中使用哪一个? 1. 企业面试题 蚂蚁 ...
- HashMap底层实现原理/HashMap与HashTable区别/HashMap与HashSet区别(转)
HashMap底层实现原理/HashMap与HashTable区别/HashMap与HashSet区别 文章来源:http://www.cnblogs.com/beatIteWeNerverGiveU ...
- hashmap 存取原理图_HashMap底层实现原理
HashMap底层原理总结,几个Hash集合之间的对比. HashMap底层存储结构 HashMap是一个用于存储Key-Value键值对的集合,每一个键值对也叫做一个Entry.这些Entry分散存 ...
- java 线程由浅入深_Java多线程:由浅入深看synchronized的底层实现原理
Java多线程:由浅入深看synchronized的底层实现原理-1.jpg (91.72 KB, 下载次数: 0) 2018-9-21 03:55 上传 前言 前俩篇文章,我们聊了聊线程/进程的概念 ...
最新文章
- python迭代器和生成器_python中迭代器和生成器。
- 排查链接是否失效_Linux服务器入侵检测排查方法
- php 正则 菜鸟,PHP正则表达式基础入门
- 个人成长:2021年中随想记
- java mysql dao_Java DAO 模式
- css中的单位换算_CSS单位px、em、rem及它们之间的换算关系
- 简单的Gradle Java插件自定义
- 【2017年第2期】专题:大数据管理与分析
- java6 3_2018.3.6 Java web notes:
- 小乌龟同步主支代码_《我的世界》游戏理论:人类,有没有可能就是一串“代码”?...
- java 文件去除扩展名_使用Java删除所有带扩展名的文件
- 三维平面叠加图_无人机倾斜摄影技术在三维实景GIS的应用
- win10今日热点弹窗怎么删除_“今日热点”怎么去掉,每次弹窗很烦!是哪个软件附带的,我想卸载了!谢谢有心人!~~...
- idea项目工具窗口
- yum执行出错,There are no enabled repos
- 深入理解栈(Stack)
- 【7gyy】密码丢了?揭秘你的密码是如何被偷走的
- 微信小程序如何保存图片到本地?
- 计算机主机电源接线,七个步骤教你主机电源如何接线
- C++Primer笔记——拷贝控制