一文带你理解Java中Lock的实现原理

转载自   一文带你理解Java中Lock的实现原理

当多个线程需要访问某个公共资源的时候,我们知道需要通过加锁来保证资源的访问不会出问题。java提供了两种方式来加锁,一种是关键字:synchronized,一种是concurrent包下的lock锁。synchronized是java底层支持的,而concurrent包则是jdk实现。关于synchronized的原理可以阅读再有人问你synchronized是什么,就把这篇文章发给他。

在这里,我会用尽可能少的代码,尽可能轻松的文字,尽可能多的图来看看lock的原理。

我们以ReentrantLock为例做分析,其他原理类似。

我把这个过程比喻成一个做菜的过程,有什么菜,做法如何?

我先列出lock实现过程中的几个关键词:计数值、双向链表、CAS+自旋

使用例子

import java.util.concurrent.locks.ReentrantLock;public class App {public static void main(String[] args) throws Exception {final int[] counter = {0};ReentrantLock lock = new ReentrantLock();for (int i= 0; i < 50; i++){new Thread(new Runnable() {@Overridepublic void run() {lock.lock();try {int a = counter[0];counter[0] = a + 1;}finally {lock.unlock();}}}).start();}// 主线程休眠,等待结果Thread.sleep(5000);System.out.println(counter[0]);}
}

在这个例子中,开50个线程同时更新counter。分成三块来看看源码(初始化、获取锁、释放锁)

 

实现原理

ReentrantLock() 干了啥

 /*** Creates an instance of {@code ReentrantLock}.* This is equivalent to using {@code ReentrantLock(false)}.*/public ReentrantLock() {sync = new NonfairSync();}

在lock的构造函数中,定义了一个NonFairSync,

static final class NonfairSync extends Sync 

NonfairSync 又是继承于Sync

abstract static class Sync extends AbstractQueuedSynchronizer

一步一步往上找,找到了
这个鬼AbstractQueuedSynchronizer(简称AQS),最后这个鬼,又是继承于AbstractOwnableSynchronizer(AOS),AOS主要是保存获取当前锁的线程对象,代码不多不再展开。
最后我们可以看到几个主要类的继承关系。

 

锁的类的继承关系

FairSync 与 NonfairSync的区别在于,是不是保证获取锁的公平性,因为默认是NonfairSync,我们以这个为例了解其背后的原理。

其他几个类代码不多,最后的主要代码都是在AQS中,我们先看看这个类的主体结构。

AbstractQueuedSynchronizer是个什么

再看看Node是什么?

看到这里的同学,是不是有种热泪盈眶的感觉,这尼玛,不就是双向链表么?我还记得第一次写这个数据结构的时候,发现居然还有这么神奇的一个东西。

最后我们可以发现锁的存储结构就两个东西:"双向链表" + "int类型状态"。
需要注意的是,他们的变量都被"transientvolatile修饰。

一个int值,一个双向链表是如何烹饪处理锁这道菜的呢,Doug Lea大神就是大神,我们接下来看看,如何获取锁?

lock.lock()怎么获取锁?

/*** Acquires the lock.*/
public void lock() {sync.lock();
}

可以看到调用的是,NonfairSync.lock()

看到这里,我们基本有了一个大概的了解,还记得之前AQS中的int类型的state值,这里就是通过CAS(乐观锁)去修改state的值。lock的基本操作还是通过乐观锁来实现的

获取锁通过CAS,那么没有获取到锁,等待获取锁是如何实现的?我们可以看一下else分支的逻辑,acquire方法:

public final void acquire(int arg) {if (!tryAcquire(arg) &&acquireQueued(addWaiter(Node.EXCLUSIVE), arg))selfInterrupt();
}

这里干了三件事情:

  • tryAcquire:会尝试再次通过CAS获取一次锁。

  • addWaiter:将当前线程加入上面锁的双向链表(等待队列)中

  • acquireQueued:通过自旋,判断当前队列节点是否可以获取锁。

addWaiter 添加当前线程到等待链表中

可以看到,通过CAS确保能够在线程安全的情况下,将当前线程加入到链表的尾部。
enq是个自旋+上述逻辑,有兴趣的可以翻翻源码。

acquireQueued

自旋+CAS尝试获取锁
可以看到,当当前线程到头部的时候,尝试CAS更新锁状态,如果更新成功表示该等待线程获取成功。从头部移除。

 

每一个线程都在自旋+CAS

最后简要概括一下,获取锁的一个流程

获取锁流程

lock.unlock() 释放锁

public void unlock() {sync.release(1);
}

可以看到调用的是,NonfairSync.release()

最后有调用了NonfairSync.tryRelease()

基本可以确认,释放锁就是对AQS中的状态值State进行修改。同时更新下一个链表中的线程等待节点。

 

总结

  • lock的存储结构:一个int类型状态值(用于锁的状态变更),一个双向链表(用于存储等待中的线程)

  • lock获取锁的过程:本质上是通过CAS来获取状态值修改,如果当场没获取到,会将该线程放在线程等待链表中。

  • lock释放锁的过程:修改状态值,调整等待链表。

  • 可以看到在整个实现过程中,lock大量使用CAS+自旋。因此根据CAS特性,lock建议使用在低锁冲突的情况下。目前java1.6以后,官方对synchronized做了大量的锁优化(偏向锁、自旋、轻量级锁)。因此在非必要的情况下,建议使用synchronized做同步操作。

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

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

相关文章

请19级的童鞋们接收一下

135编辑器1李磊&#xff1a;磊&#xff0c;假期过的可好&#xff1f;有没有人在写作业呀&#xff1f;通过这段时间的学习&#xff0c;可以看得出你对我们的课程兴趣浓厚&#xff0c;尤其是scratch&#xff0c;自己做了好多的案例&#xff0c;之前还以为你们都是从网上直接下载的…

Spring-boot IDEA使用注解@ConfigurationProperties时报错解决

使用注解ConfigurationProperties报错 使用ConfigurationProperties注解&#xff0c;以前用的挺好没出现问题&#xff0c;换了IDEA的版本使用&#xff0c;发现报错了&#xff0c;具体报错如下&#xff1a; Spring Boot Configuration Annotation Processor not found in class…

微软Build 2017首日主角AI 同时发布.NET Core 2.0 Preview 1

软公司一年一度的开发者大会&#xff0c;即“Microsoft Build 2017”在总部西雅图正式开幕。按照官方安排&#xff0c;本次大会将持续 3 天&#xff0c;主题围绕微软公司各项最新技术成果的展示和研讨&#xff0c;包括与微软相关的产业界人士的沟通和互动&#xff0c;以及对未来…

JS操作地址栏Location

<!DOCTYPE html> <html><head><meta charset"UTF-8"><title></title><script type"text/javascript">/** Location* - 该对象中封装了浏览器的地址栏的信息*/window.onload function(){//获取按钮对象var btn…

彻底理解HashMap的元素插入原理

转载自 彻底理解HashMap的元素插入原理 HashMap&#xff0c;是Java语言中比较基础也比较重要的一种数据结构&#xff0c;由于其用途广泛&#xff0c;所以&#xff0c;Java的工程师在设计HashMap的时候考虑了很多因素。 通过阅读HashMap的源码&#xff0c;可以学习到很多知识…

使用C#操作XML文件

今天更新一篇技术文章&#xff0c;使用C#实现对XML的操作&#xff1a;首先需要准备一个测试的XML文件&#xff0c;我这边命名为test.xml:文件内容为&#xff1a;<test><id>1</id><name>张三</name><age>18</age><id>2</id&…

Linux使用Jexus托管Asp.Net Core应用程序

第一步 安装.Net Core环境 安装 dotnet 环境参见官方网站 https://www.microsoft.com/net/core。 选择对应的系统版本进行安装。安装完成过后 输入命令查看版本&#xff0c;目前最新版为 1.04&#xff1a; dotnet --version 此时已经可以发布Asp.Net Core应用程序到Linux上…

C++字符串分割替换 ubuntu版本

#include <iostream> #include <string> #include <vector> using namespace std; vector<string> mySplit(const string& str,string sp_string) // split(),str 是要分割的string { vector<string> vecString; int sp_stringLen sp_st…

优秀学生专栏——董超

优秀学生--董超今天回访了下17级优秀学生董超同学&#xff0c;董超同学在校期间一直担任小组组长&#xff0c;平时学习刻苦认真&#xff0c;各个阶段的项目也做的非常优秀&#xff0c;今年5月份左右毕业&#xff0c;所在岗位是开发&#xff0c;目前的薪资在5000左右&#xff0c…

高级开发必须理解的Java中SPI机制

转载自 高级开发必须理解的Java中SPI机制 本文通过探析JDK提供的&#xff0c;在开源项目中比较常用的Java SPI机制&#xff0c;希望给大家在实际开发实践、学习开源项目提供参考。 SPI是什么 SPI全称Service Provider Interface&#xff0c;是Java提供的一套用来被第三方实…

JS中的延时调用

<!DOCTYPE html> <html><head><meta charset"UTF-8"><title></title><script type"text/javascript">var num 1;//开启一个定时器/*setInterval(function(){console.log(num);},3000);*//** 延时调用&#xff…

动态代理JDK于cglib

静态代理的缺点&#xff1a; 1、由于静态代理中的代理类是针对某一个类去做代理的&#xff0c;那么假设一个系统中有100个Service&#xff0c;则需要创建100个代理类 2、如果一个Service中有很多方法需要事务&#xff08;增强动作&#xff09;&#xff0c;发现代理对象的方法中…

以深圳.NET俱乐部名义 的技术交流会圆满成功

2017年5月13日的深圳下着暴雨&#xff0c;一场以深圳.NET俱乐部名义的.NET技术交流会在微软Build 2017刚闭幕时在罗湖布吉路与翠山路交界处富基PARK国际6F举办&#xff0c;这次交流以微软Build 2017 大会发布的.NET Standard 2.0 Preview1/.NET Core 2.0 Preview 1为契机&#…

C#中的序列化和反序列化

序列化&#xff1a;是将对象的状态存储到特定存储介质的过程&#xff0c;也可以说是将对象状态转换为可保持或传输的格式的过程。 上面的解释是官方定义&#xff0c;大白话解释就是&#xff0c;将对象以二进制的方式存储在文件中&#xff0c;如果简简单单的将一些数据或者内容存…

JS中的JSON

<!DOCTYPE html> <html><head><meta charset"UTF-8"><title></title><!--如果需要兼容IE7及以下的JSON操作&#xff0c;则可以通过引入一个外部的js文件来处理--><script type"text/javascript" src"js…

关于勒索病毒 Ransom:Win32.WannaCrypt 解决方案的最后一次说明

2017/5/12 晚&#xff0c;勒索软件 Ransom:Win32.WannaCrypt 大面积暴发。比病毒爆发更火的&#xff0c;则是各类关于此病毒的新闻、解决方法在朋友圈等社交媒体的爆发。 其中&#xff0c;有主观善意但客观一知半解的指导&#xff0c;更有夹带私货的安全软件商携各类工具的广告…

maven的三种packaging方式

pom是maven依赖文件 jar是java普通项目打包 war是java web项目打包 pom&#xff1a;打出来可以作为其他项目的maven依赖&#xff0c;在工程A中添加工程B的pom&#xff0c;A就可以使用B中的类。用在父级工程或聚合工程中。用来做jar包的版本控制。 jar包&#xff1a;通常是开发…

C#中的序列化和反序列化案例

序列化&#xff1a;是将对象的状态存储到特定存储介质的过程&#xff0c;也可以说是将对象状态转换为可保持或传输的格式的过程。上面的解释是官方定义&#xff0c;大白话解释就是&#xff0c;将对象以二进制的方式存储在文件中&#xff0c;如果简简单单的将一些数据或者内容存…

浅谈MySQL的B树索引与索引优化

转载自 浅谈MySQL的B树索引与索引优化 MySQL的MyISAM、InnoDB引擎默认均使用B树索引&#xff08;查询时都显示为“BTREE”&#xff09;&#xff0c;本文讨论两个问题&#xff1a; 为什么MySQL等主流数据库选择B树的索引结构&#xff1f; 如何基于索引结构&#xff0c;理解常…