Java学习——AQS解析

2024-05-01 22:08
文章标签 java 学习 解析 aqs

本文主要是介绍Java学习——AQS解析,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

最近在学习JUC,发现里面大部分的并发组件都是基于AQS,因此研读了一下源码,在此做个笔记。

AQS(AbstractQueuedSynchronizer)翻译为抽象队列同步器,是除Synchronized关键字外java自带的锁机制。

AQS使用一个int类型变量state来表示线程要竞争的资源,state的值即为可获取的资源数,当一个线程尝试获取锁时,会使用CAS方式去尝试改变state的值,如果改变成功,即获取了锁。CAS的实现是使用了Unsafe类底下的一系列compareAndSet*方法,这些方法调用了JAVA的native方法,可以认为是系统底层支持的原子操作。

 private final boolean compareAndSetHead(Node update);private final boolean compareAndSetTail(Node expect, Node update);private static final boolean compareAndSetWaitStatus(Node node,int expect,int update) ;private static final boolean compareAndSetNext(Node node,Node expect,Node update)

当线程尝试获取锁时,AQS会将线程封装为一个节点,放入到一个等待队列中。这个等待队列是一个FIFO的双向队列,处于等待队列中的线程获取锁失败后,会调用LockSupport类中的park方法,使等待的线程放弃调度资格,进入time_waiting的状态。所以AQS的状态通常如下图所示。总是位于header的线程持有锁,处于running状态,剩余的等待线程处于time-waitting状态(此处以独占模式为例),当header的线程执行完,释放锁时,将优先唤醒header节点的下一节点的线程进行锁的申请。
在这里插入图片描述
如下代码是等待队列中的线程尝试获取锁的处理过程,可以看出,等待线程以自旋的方式,循环尝试获取锁。在header节点线程释放锁时,会优先唤醒header节点的下一节点,但是被唤醒的线程并不一定能获取锁,还是得进行获取锁的尝试,如果失败,会进入time-waiting状态,继续等待被唤醒。

final boolean acquireQueued(final Node node, int arg) {boolean failed = true;try {boolean interrupted = false;for (;;) {//获取当前节点的上一节点final Node p = node.predecessor();if (p == head && tryAcquire(arg)) {setHead(node);p.next = null; // help GCfailed = false;return interrupted;}if (shouldParkAfterFailedAcquire(p, node) &&parkAndCheckInterrupt())interrupted = true;}} finally {if (failed)cancelAcquire(node);}}

在文章开头,笔者说过,juc中有很多并发组件是利用AQS实现的,这里,我以ReenTrantLock为例,介绍一下java的并发组件是怎样以AQS为基础设计实现锁。
ReenTrantLock是使用AQS实现的一种独占锁,可以是非公平锁或者公平锁,我们以实现比较简单的的非公平锁为例,锁使用最基本的两个接口实现为Lock和unLock,分别表示申请锁和释放锁。
在这里插入图片描述
从流程图可以看出,AQS实现了一整套的线程阻塞等待、线程被唤醒时的组织机制,而ReentrantLock为了实现非公平锁,只需要重写tryAcquire和tryRelease方法,这两个方法分别表示非阻塞方式的尝试获取锁和非阻塞方式的释放锁。

 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) // overflowthrow new Error("Maximum lock count exceeded");setState(nextc);return true;}return false;}

ReenTrantLock的tryAcquire方法会调用nonfairTryAcquire方法,实现了非阻塞获取锁的处理逻辑,而且也实现了可重入机制,当获得锁的线程再次申请锁时,只是简单的对state值进行修改。

//in AQS
public final boolean release(int arg) {if (tryRelease(arg)) {Node h = head;if (h != null && h.waitStatus != 0)//释放header的下一节点unparkSuccessor(h);return true;}return false;}
//rewrite in ReentrantLock
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;}

ReenTrantLock的unlock方法会调用AQS的release方法,release方法定义了锁释放的一系列操作,包括下一节点的唤醒。这实际上是一种模板方法的设计模式,而ReenTrantLock重写的tryRelease方法只是简单的实现了锁的释放。

这篇关于Java学习——AQS解析的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/952780

相关文章

网页解析 lxml 库--实战

lxml库使用流程 lxml 是 Python 的第三方解析库,完全使用 Python 语言编写,它对 XPath表达式提供了良好的支 持,因此能够了高效地解析 HTML/XML 文档。本节讲解如何通过 lxml 库解析 HTML 文档。 pip install lxml lxm| 库提供了一个 etree 模块,该模块专门用来解析 HTML/XML 文档,下面来介绍一下 lxml 库

HarmonyOS学习(七)——UI(五)常用布局总结

自适应布局 1.1、线性布局(LinearLayout) 通过线性容器Row和Column实现线性布局。Column容器内的子组件按照垂直方向排列,Row组件中的子组件按照水平方向排列。 属性说明space通过space参数设置主轴上子组件的间距,达到各子组件在排列上的等间距效果alignItems设置子组件在交叉轴上的对齐方式,且在各类尺寸屏幕上表现一致,其中交叉轴为垂直时,取值为Vert

Ilya-AI分享的他在OpenAI学习到的15个提示工程技巧

Ilya(不是本人,claude AI)在社交媒体上分享了他在OpenAI学习到的15个Prompt撰写技巧。 以下是详细的内容: 提示精确化:在编写提示时,力求表达清晰准确。清楚地阐述任务需求和概念定义至关重要。例:不用"分析文本",而用"判断这段话的情感倾向:积极、消极还是中性"。 快速迭代:善于快速连续调整提示。熟练的提示工程师能够灵活地进行多轮优化。例:从"总结文章"到"用

JVM 的类初始化机制

前言 当你在 Java 程序中new对象时,有没有考虑过 JVM 是如何把静态的字节码(byte code)转化为运行时对象的呢,这个问题看似简单,但清楚的同学相信也不会太多,这篇文章首先介绍 JVM 类初始化的机制,然后给出几个易出错的实例来分析,帮助大家更好理解这个知识点。 JVM 将字节码转化为运行时对象分为三个阶段,分别是:loading 、Linking、initialization

Spring Security 基于表达式的权限控制

前言 spring security 3.0已经可以使用spring el表达式来控制授权,允许在表达式中使用复杂的布尔逻辑来控制访问的权限。 常见的表达式 Spring Security可用表达式对象的基类是SecurityExpressionRoot。 表达式描述hasRole([role])用户拥有制定的角色时返回true (Spring security默认会带有ROLE_前缀),去

浅析Spring Security认证过程

类图 为了方便理解Spring Security认证流程,特意画了如下的类图,包含相关的核心认证类 概述 核心验证器 AuthenticationManager 该对象提供了认证方法的入口,接收一个Authentiaton对象作为参数; public interface AuthenticationManager {Authentication authenticate(Authenti

Spring Security--Architecture Overview

1 核心组件 这一节主要介绍一些在Spring Security中常见且核心的Java类,它们之间的依赖,构建起了整个框架。想要理解整个架构,最起码得对这些类眼熟。 1.1 SecurityContextHolder SecurityContextHolder用于存储安全上下文(security context)的信息。当前操作的用户是谁,该用户是否已经被认证,他拥有哪些角色权限…这些都被保

Spring Security基于数据库验证流程详解

Spring Security 校验流程图 相关解释说明(认真看哦) AbstractAuthenticationProcessingFilter 抽象类 /*** 调用 #requiresAuthentication(HttpServletRequest, HttpServletResponse) 决定是否需要进行验证操作。* 如果需要验证,则会调用 #attemptAuthentica

Spring Security 从入门到进阶系列教程

Spring Security 入门系列 《保护 Web 应用的安全》 《Spring-Security-入门(一):登录与退出》 《Spring-Security-入门(二):基于数据库验证》 《Spring-Security-入门(三):密码加密》 《Spring-Security-入门(四):自定义-Filter》 《Spring-Security-入门(五):在 Sprin

Java架构师知识体认识

源码分析 常用设计模式 Proxy代理模式Factory工厂模式Singleton单例模式Delegate委派模式Strategy策略模式Prototype原型模式Template模板模式 Spring5 beans 接口实例化代理Bean操作 Context Ioc容器设计原理及高级特性Aop设计原理Factorybean与Beanfactory Transaction 声明式事物