JAVA并发编程AQS原理剖析

本文涉及的产品
服务治理 MSE Sentinel/OpenSergo,Agent数量 不受限
注册配置 MSE Nacos/ZooKeeper,118元/月
云原生网关 MSE Higress,422元/月
简介: 很多小朋友面试时候,面试官考察并发编程部分,都会被问:说一下AQS原理。面对并发编程基础和面试经验,专栏采用通俗简洁无废话无八股文方式,已陆续梳理分享了《一文看懂全部锁机制》、《JUC包之CAS原理》、《volatile核心原理》、《synchronized全能王的原理》,希望可以帮到大家巩固相关核心技术原理。今天我们聊聊AQS....

很多小朋友面试时候,面试官考察并发编程部分,都会被问:说一下AQS原理。面对并发编程基础和面试经验,专栏采用通俗简洁无废话无八股文方式,已陆续梳理分享了《一文看懂全部锁机制》《JUC包之CAS原理》《volatile核心原理》《synchronized全能王的原理》,希望可以帮到大家巩固相关核心技术原理。今天我们聊聊AQS....

一、AQS是什么,有什么用

     AQS全称是:AbstractQueuedSynchronizer,队列同步器。这个类在JUC包java.util.concurrent.locks下面。


一句话总结:AQS是FIFO先进先出双向队列,队列里存的是线程Thread。


      说到双向链表,这回大家就不陌生了。通过head、tail节点来记录队列的头和尾。每个Node节点都有next、pre来串联前后节点组成双向链表。

         AQS同步队列,就是通过在FIFO队列里存储线程的状态,实现类只需要extend abstractQueuedSynchronizer,并实现里面的方法,就可以自定义自己同步机制。为什么面试官喜欢问AQS,因为AQS队列同步器在JUC包里应用太广泛了,你所熟悉的ReentrantLock、Semaphore信号量、FutureTask,CountDownLatch,你翻一番源码,都是extend abstractQueuedSynchronizer去实现的。等你说完AQS原理,就可以继续问它的实现...面试官考察套路太深。


一句话总结:AQS可以用来实现线程同步机制。在JUC包里有广泛应用。可以说AQS就是JUC的灵魂。


二、AQS的原理

    我们直接看源码说原理,AQS队列同步器核心三个变量:head节点、tail节点、state状态码。



核心原理:队列中的每个节点对应一个线程。线程通过判断state字段进行抢占资源,如果获取资源成功,则把当前线程设置为有效工作线程,并且修改state值。其他竞争失败线程,就阻塞进入FIFO队列,等待持有锁线程按顺序唤醒。


这个原理,不同锁实现会有些区别,具体AQS原理等我们在ReentrantLock,semaphore信号量,FutureTask专文再详细分析。

2.1 AQS Node节点分析

   AQS核心原理说过,AQS只有三个核心变量:head节点、tail节点、int state变量。state已经说过是volatile修饰,多线程入队前竞争锁的共享资源。队列里的Node,我们重点说说。先看源码截图,只看核心几个变量:

        首先看看Node类型字段的有:excusive,share,next,pre,nextWaiter。


exclusive:表示独占锁,只有一个线程可以获得锁。也就是我们在《一文看懂全部锁机制》说过独享锁、排它锁。比如ReentrantLock里面就是独占锁。FIFO里面的每个Node 都是exclusive 节点。


share:共享锁,多个线程可以共享锁。ReentrantReadWriteLock里面的read锁就是共享锁。


pre和 next 就是表示当前Node节点前、后节点引用。 thread: 就是对应线程引用。


waitSatus: 就是当前线程节点等待状态,0就是默认值。它的值有:

      CANCELLED:节点在等待过程被打断或超时,被标记为取消状态。

      SIGNAL:线程等待被唤醒。

      CONDITION:在条件队列中等待。

     PROPAGATE: 释放共享锁时,如果头结点的状态是PROPAGATE状态,就广播我释放锁了,等待锁的线程,都可以去尝试获取锁。


AQS因为不涉及具体实现,简单说这么多,下一篇,我们将分享具体AQS实现的庖丁解牛。比如ReentrantLock,信号量。

相关文章
|
2天前
|
弹性计算 人工智能 架构师
阿里云携手Altair共拓云上工业仿真新机遇
2024年9月12日,「2024 Altair 技术大会杭州站」成功召开,阿里云弹性计算产品运营与生态负责人何川,与Altair中国技术总监赵阳在会上联合发布了最新的“云上CAE一体机”。
阿里云携手Altair共拓云上工业仿真新机遇
|
28天前
|
运维 Cloud Native Devops
一线实战:运维人少,我们从 0 到 1 实践 DevOps 和云原生
上海经证科技有限公司为有效推进软件项目管理和开发工作,选择了阿里云云效作为 DevOps 解决方案。通过云效,实现了从 0 开始,到现在近百个微服务、数百条流水线与应用交付的全面覆盖,有效支撑了敏捷开发流程。
19257 29
|
29天前
|
人工智能 自然语言处理 搜索推荐
阿里云Elasticsearch AI搜索实践
本文介绍了阿里云 Elasticsearch 在AI 搜索方面的技术实践与探索。
18797 20
|
28天前
|
Rust Apache 对象存储
Apache Paimon V0.9最新进展
Apache Paimon V0.9 版本即将发布,此版本带来了多项新特性并解决了关键挑战。Paimon自2022年从Flink社区诞生以来迅速成长,已成为Apache顶级项目,并广泛应用于阿里集团内外的多家企业。
17504 13
Apache Paimon V0.9最新进展
|
30天前
|
存储 人工智能 前端开发
AI 网关零代码解决 AI 幻觉问题
本文主要介绍了 AI Agent 的背景,概念,探讨了 AI Agent 网关插件的使用方法,效果以及实现原理。
18692 15
|
28天前
|
人工智能 自然语言处理 搜索推荐
评测:AI客服接入钉钉与微信的对比分析
【8月更文第22天】随着人工智能技术的发展,越来越多的企业开始尝试将AI客服集成到自己的业务流程中。本文将基于《10分钟构建AI客服并应用到网站、钉钉或微信中》的解决方案,详细评测AI客服在钉钉和微信中的接入流程及实际应用效果,并结合个人体验分享一些心得。
9905 9
|
1月前
|
消息中间件 弹性计算 关系型数据库
函数计算驱动多媒体文件处理解决方案体验评测
从整体解读到部署体验,多方位带你了解如何利用函数计算驱动多媒体文件处理,告别资源瓶颈。
10441 13
|
22天前
|
存储 JSON Serverless
西游再现,函数计算一键部署 Flux 超写实文生图模型部署
参与体验活动生成西游人物图像,既有机会赢取好礼!本次实验在函数计算中内置了flux.1-dev-fp8大模型,通过函数计算+Serverless应用中心一键部署Flux模型,快速生成超写实图像。首次开通用户可领取免费试用额度,部署过程简单高效。完成部署后,您可以通过修改提示词生成各种风格的图像,体验Flux模型的强大绘图能力。
西游再现,函数计算一键部署 Flux 超写实文生图模型部署
|
1月前
|
SQL 容灾 关系型数据库
让X不断延伸, 从跨AZ到跨Region再到跨Cloud
本文从“空间”这一维度,聊一聊PolarDB-X在跨空间部署能力上的不断发展和延伸,以及在不同空间范围下的高可用和容灾能力,并着重介绍一下最新的产品能力——GDN(Global Database Network)。
|
1月前
|
缓存 测试技术 调度
PolarDB-X的TPC-H列存执行计划
本文从官方的角度逐条解析PolarDB-X在TPC-H列存执行计划的设计要点。这些要点不仅包含了各项优化的原理,还提供了相关的证明与代码实现,希望帮助读者更深入地理解PolarDB-X的列存优化器。
7872 11