技术标签: java
这篇文章深入浅出理解Java并发AQS的独占锁模式讲解了AQS的独占锁实现原理,那么本篇文章在阐述AQS另外一个重要模式,共享锁模式,那什么是共享锁呢?
共享锁可以由多个线程同时获取, 比较典型的就是读锁,读操作并不会产生副作用,所以可以允许多个线程同时对数据进行读操作而不会有线程安全问题,jdk中的很多并发工具比如ReadWriteLock和CountdownLatch就是依赖AQS的共享锁实现的。
本文重点讲解下AQS是如何实现共享锁的。
首先我们通过AQS实现一个非常最最最轻量简单的共享锁例子,帮助大家对共享锁有一个整体的感知。
@Slf4j
public class ShareLock {
/**
* 共享锁帮助类
*/
private static class ShareSync extends AbstractQueuedSynchronizer {
private int lockCount;
/**
* 创建共享锁帮助类,最多有count把共享锁,超过了则阻塞
*
* @param count 共享锁数量
*/
public ShareSync(int count) {
this.lockCount = count;
}
/**
* 尝试获取共享锁
*
* @param arg 每次获取锁的数量
* @return 返回正数,表示后续其他线程获取共享锁可能成功; 返回0,表示后续其他线程无法获取共享锁;返回负数,表示当前线程获取共享锁失败
*/
@Override
protected int tryAcquireShared(int arg) {
// 自旋
for (;;) {
int c = getState();
// 如果持有锁的数量大于指定数量,返回-1,线程进入阻塞
if(c >= lockCount) {
return -1;
}
int nextc = c + 1;
// cas设置成功,返回1,获取到共享锁
if (compareAndSetState(c, nextc)) {
return 1;
}
}
}
/**
* 尝试释放共享锁
*
* @param arg 释放锁的数量
* @return 如果释放后允许唤醒后续等待结点返回true,否则返回false
*/
@Override
protected boolean tryReleaseShared(int arg) {
// 自旋操作
for (; ; ) {
int c = getState();
// 如果没有锁了
if (c == 0) {
return false;
}
// 否则锁量-1
int nextc = c - 1;
// cas修改状态
if (compareAndSetState(c, nextc)) {
return true;
}
}
}
}
private final ShareSync sync;
public ShareLock(int count) {
this.sync = new ShareSync(count);
}
/**
* 加共享锁
*/
public void lockShare() {
sync.acquireShared(1);
}
/**
* 释放共享锁
*/
public void releaseShare() {
sync.releaseShared(1);
}
}
复制代码
ShareSync
类,继承自AbstractQueuedSynchronizer
类,实现了共享锁相关的方法tryAcquireShared()
和tryReleaseShared()
。ShareLock
,提供了lockShare()
加锁和releaseShare()
两个API。验证:
public static void main(String[] args) throws InterruptedException {
ShareLock shareLock = new ShareLock(3);
for (int i = 0; i < 5; i++) {
new Thread(() -> {
shareLock.lockShare();
try {
log.info("lock success");
Thread.sleep(1000);
} catch (InterruptedException e) {
e.printStackTrace();
} finally {
shareLock.releaseShare();
log.info("release success");
}
}, "thread-" + i).start();
}
Thread.sleep(10000);
}
复制代码
运行结果:
lock success
,说明同时只有3个线程共享。下面对它的实现原理一探究竟。
共享模式也是由AQS提供的,首先我们关注下AQS的数据结构。
AQS内部维护了一个volatile int state(代表共享资源)和一个FIFO线程等待队列(多线程争用资源被阻塞时会进入此队列)。
AQS作为一个抽象方法,提供了加锁、和释放锁的框架,这里采用的模板方模式,在上面中提到的tryAcquireShared
、tryReleaseShared
就是和共享模式相关的模板方法。
方法名 | 描述 |
---|---|
protected int tryAcquireShared(int arg) | 共享方式。arg为获取锁的次数,尝试获取资源。负数表示失败;0表示成功,但没有剩余可用资源;正数表示成功,且有剩余资源。 |
protected boolean tryReleaseShared(int arg) | 共享方式。arg为释放锁的次数,尝试释放资源,如果释放后允许唤醒后续等待结点返回True,否则返回False。 |
共享模式的入口方法如下:
方法名 | 描述 |
---|---|
void acquireShared(int arg) | 共享模式获取锁,不响应中断。 |
void acquireSharedInterruptibly(int arg) | 共享模式获取锁,响应中断。 |
tryAcquireSharedNanos(int arg, long nanosTimeout) | 尝试在共享模式下获取锁,如果中断则中止,如果超过给定超时则失败。 |
boolean releaseShared(int arg) | 共享模式下释放锁。 |
上图是AQS的类结构图,其中标红部分是组成AQS的重要成员变量。
AQS中里一个很重要的字段state,表示同步状态,是由volatile修饰的,用于展示当前临界资源的获锁情况。通过getState(),setState(),compareAndSetState()三个方法进行维护。
关于state的几个要点:
AQS里另一个重要的概念就是CLH队列,它是一个双向链表队列,其内部由head和tail分别记录头结点和尾结点,队列的元素类型是Node。
private transient volatile Node head;
private transient volatile Node tail;
复制代码
Node的结构如下:
static final class Node {
//共享模式下的等待标记
static final Node SHARED = new Node();
//独占模式下的等待标记
static final Node EXCLUSIVE = null;
//表示当前结点已取消调度。当timeout或被中断(响应中断的情况下),会触发变更为此状态,进入该状态后的结点将不会再变化。
static final int CANCELLED = 1;
//表示后继结点在等待当前结点唤醒。后继结点入队时,会将前继结点的状态更新为SIGNAL。
static final int SIGNAL = -1;
//表示结点等待在Condition上,当其他线程调用了Condition的signal()方法后,CONDITION状态的结点将从等待队列转移到同步队列中,等待获取同步锁。
static final int CONDITION = -2;
//共享模式下,前继结点不仅会唤醒其后继结点,同时也可能会唤醒后继的后继结点。
static final int PROPAGATE = -3;
//状态,包括上面的四种状态值,初始值为0,一般是节点的初始状态
volatile int waitStatus;
//上一个节点的引用
volatile Node prev;
//下一个节点的引用
volatile Node next;
//保存在当前节点的线程引用
volatile Thread thread;
//condition队列的后续节点
Node nextWaiter;
}
复制代码
注意,waitSstatus负值表示结点处于有效等待状态,而正值表示结点已被取消。所以源码中很多地方用>0、<0来判断结点的状态是否正常。
AQS通过继承AbstractOwnableSynchronizer类,拥有的属性。表示独占模式下同步器持有的线程。
acquireShared(int)是共享锁模式下线程获取共享资源的入口方法,它会获取指定量的资源,获取成功则直接返回,获取失败则进入等待队列,直到获取到资源为止,整个过程无法响应中断。
public final void acquireShared(int arg) {
if (tryAcquireShared(arg) < 0)
doAcquireShared(arg);
}
复制代码
方法的整体流程如下:
doAcquireShared(int)
此方法用于将当前线程加入等待队列尾部休息,直到其他线程释放资源唤醒自己,自己成功拿到相应量的资源后才返回。
private void doAcquireShared(int arg) {
//封装线程为共享Node 加入队列尾部
final Node node = addWaiter(Node.SHARED);
//是否成功标志
boolean failed = true;
try {
//等待过程中是否被中断过的标志
boolean interrupted = false;
// 自旋操作
for (;;) {
// 获取前驱节点
final Node p = node.predecessor();
//如果到head的下一个,因为head是拿到资源的线程,此时node被唤醒,很可能是head用完资源来唤醒自己的
if (p == head) {
//尝试获取资源
int r = tryAcquireShared(arg);
//成功
if (r >= 0) {
//将head指向自己,还有剩余资源可以再唤醒之后的线程
setHeadAndPropagate(node, r);
p.next = null; // help GC
//如果等待过程中被打断过,此时将中断补上。
if (interrupted)
selfInterrupt();
failed = false;
return;
}
}
//判断状态,寻找安全点,进入waiting状态,等着被unpark()或interrupt()
if (shouldParkAfterFailedAcquire(p, node) &&
parkAndCheckInterrupt())
interrupted = true;
}
} finally {
if (failed)
cancelAcquire(node);
}
}
复制代码
doAcquireShared
方法的实现和获取独占锁中的acquireQueued
方法很类似,但是主要有一点不同,那就是线程在被唤醒后,若成功获取到了共享锁,还需要判断共享锁是否还能被其他线程获取,若可以,则继续向后唤醒它的下一个节点对应的线程。
setHeadAndPropagate(Node, int)
该方法主要将当前节点设置为头节点,同时判断条件是否符合(比如还有剩余资源),还会去唤醒后继结点,毕竟是共享模式。
private void setHeadAndPropagate(Node node, int propagate) {
Node h = head;
//head指向自己
setHead(node);
//如果还有剩余量,继续唤醒下一个邻居线程
if (propagate > 0 || h == null || h.waitStatus < 0) {
Node s = node.next;
if (s == null || s.isShared())
// 唤醒操作
doReleaseShared();
}
}
复制代码
releaseShared(int)
是共享模式下线程释放共享资源的入口,它会释放指定量的资源,如果成功释放且允许唤醒等待线程,它会唤醒等待队列里的其他线程来获取资源。
public final boolean releaseShared(int arg) {
//尝试释放资源
if (tryReleaseShared(arg)) {
//唤醒后继结点
doReleaseShared();
return true;
}
return false;
}
复制代码
方法的整体流程如下:
doReleaseShared()
此方法主要用于唤醒队列中等待的共享节点。
private void doReleaseShared() {
// 自旋操作
for (;;) {
// 获取头节点
Node h = head;
if (h != null && h != tail) {
// 获取节点的等待状态
int ws = h.waitStatus;
// 如果节点等待状态是-1, -1表示有责任唤醒后续节点的状态
if (ws == Node.SIGNAL) {
// cas修改当前节点的等待状态为0
if (!compareAndSetWaitStatus(h, Node.SIGNAL, 0))
continue;
//唤醒后续节点
unparkSuccessor(h);
}
else if (ws == 0 &&
!compareAndSetWaitStatus(h, 0, Node.PROPAGATE))
continue;
}
if (h == head)// head发生变化
break;
}
}
复制代码
if(h == head) break;
,这样,循环检测到head没有变化时就会退出循环。注意,head变化一定是因为:acquire thread被唤醒,之后它成功获取锁,然后setHead设置了新head。而且注意,只有通过if(h == head) break;
即head不变才能退出循环,不然会执行多次循环。if (h != null && h != tail)
判断队列是否至少有两个node,如果队列从来没有初始化过(head为null),或者head就是tail,那么中间逻辑直接不走,直接判断head是否变化了。compareAndSetWaitStatus(h, Node.SIGNAL, 0)
和unparkSuccessor(h)
绑定在了一起。说明了只要head成功得从SIGNAL修改为0,那么head的后继的代表线程肯定会被唤醒了。本文主要讲解了AQS的共享模式,通过一个自定义简单的demo帮助大家深入浅出的理解,同时深入分析了源码实现,希望对大家有帮助。
文章浏览阅读1k次。通过使用ajax方法跨域请求是浏览器所不允许的,浏览器出于安全考虑是禁止的。警告信息如下:不过jQuery对跨域问题也有解决方案,使用jsonp的方式解决,方法如下:$.ajax({ async:false, url: 'http://www.mysite.com/demo.do', // 跨域URL ty..._nginx不停的xhr
文章浏览阅读2k次。关于在 Oracle 中配置 extproc 以访问 ST_Geometry,也就是我们所说的 使用空间SQL 的方法,官方文档链接如下。http://desktop.arcgis.com/zh-cn/arcmap/latest/manage-data/gdbs-in-oracle/configure-oracle-extproc.htm其实简单总结一下,主要就分为以下几个步骤。..._extproc
文章浏览阅读1.5w次。linux下没有上面的两个函数,需要使用函数 mbstowcs和wcstombsmbstowcs将多字节编码转换为宽字节编码wcstombs将宽字节编码转换为多字节编码这两个函数,转换过程中受到系统编码类型的影响,需要通过设置来设定转换前和转换后的编码类型。通过函数setlocale进行系统编码的设置。linux下输入命名locale -a查看系统支持的编码_linux c++ gbk->utf8
文章浏览阅读750次。今天准备从生产库向测试库进行数据导入,结果在imp导入的时候遇到“ IMP-00009:导出文件异常结束” 错误,google一下,发现可能有如下原因导致imp的数据太大,没有写buffer和commit两个数据库字符集不同从低版本exp的dmp文件,向高版本imp导出的dmp文件出错传输dmp文件时,文件损坏解决办法:imp时指定..._imp-00009导出文件异常结束
文章浏览阅读143次。当下是一个大数据的时代,各个行业都离不开数据的支持。因此,网络爬虫就应运而生。网络爬虫当下最为火热的是Python,Python开发爬虫相对简单,而且功能库相当完善,力压众多开发语言。本次教程我们爬取前程无忧的招聘信息来分析Python程序员需要掌握那些编程技术。首先在谷歌浏览器打开前程无忧的首页,按F12打开浏览器的开发者工具。浏览器开发者工具是用于捕捉网站的请求信息,通过分析请求信息可以了解请..._初级python程序员能力要求
文章浏览阅读7.6k次,点赞2次,收藏6次。@Service标注的bean,类名:ABDemoService查看源码后发现,原来是经过一个特殊处理:当类的名字是以两个或以上的大写字母开头的话,bean的名字会与类名保持一致public class AnnotationBeanNameGenerator implements BeanNameGenerator { private static final String C..._@service beanname
文章浏览阅读6.9w次,点赞73次,收藏463次。1.前序创建#include<stdio.h>#include<string.h>#include<stdlib.h>#include<malloc.h>#include<iostream>#include<stack>#include<queue>using namespace std;typed_二叉树的建立
文章浏览阅读7.1k次。在Asp.net上使用Excel导出功能,如果文件名出现中文,便会以乱码视之。 解决方法: fileName = HttpUtility.UrlEncode(fileName, System.Text.Encoding.UTF8);_asp.net utf8 导出中文字符乱码
文章浏览阅读2.1k次,点赞4次,收藏23次。第一次实验 词法分析实验报告设计思想词法分析的主要任务是根据文法的词汇表以及对应约定的编码进行一定的识别,找出文件中所有的合法的单词,并给出一定的信息作为最后的结果,用于后续语法分析程序的使用;本实验针对 PL/0 语言 的文法、词汇表编写一个词法分析程序,对于每个单词根据词汇表输出: (单词种类, 单词的值) 二元对。词汇表:种别编码单词符号助记符0beginb..._对pl/0作以下修改扩充。增加单词
文章浏览阅读773次。我在使用adb.exe时遇到了麻烦.我想使用与bash相同的adb.exe shell提示符,所以我决定更改默认的bash二进制文件(当然二进制文件是交叉编译的,一切都很完美)更改bash二进制文件遵循以下顺序> adb remount> adb push bash / system / bin /> adb shell> cd / system / bin> chm..._adb shell mv 权限
文章浏览阅读6.8k次,点赞12次,收藏125次。1. 单目相机标定引言相机标定已经研究多年,标定的算法可以分为基于摄影测量的标定和自标定。其中,应用最为广泛的还是张正友标定法。这是一种简单灵活、高鲁棒性、低成本的相机标定算法。仅需要一台相机和一块平面标定板构建相机标定系统,在标定过程中,相机拍摄多个角度下(至少两个角度,推荐10~20个角度)的标定板图像(相机和标定板都可以移动),即可对相机的内外参数进行标定。下面介绍张氏标定法(以下也这么称呼)的原理。原理相机模型和单应矩阵相机标定,就是对相机的内外参数进行计算的过程,从而得到物体到图像的投影_相机-投影仪标定
文章浏览阅读2.2k次。文章目录Wayland 架构Wayland 渲染Wayland的 硬件支持简 述: 翻译一篇关于和 wayland 有关的技术文章, 其英文标题为Wayland Architecture .Wayland 架构若是想要更好的理解 Wayland 架构及其与 X (X11 or X Window System) 结构;一种很好的方法是将事件从输入设备就开始跟踪, 查看期间所有的屏幕上出现的变化。这就是我们现在对 X 的理解。 内核是从一个输入设备中获取一个事件,并通过 evdev 输入_wayland