抽象队列原理-抽象队列工作机制

解​锁并发之魂：深入解析 AbstractQueuedSynchronizer (AQS) 原理

在 Java 并​发编程​的浩瀚宇宙中，`java.util.concurrent`（JUC）包下的工具类（如 `ReentrantLock`、`Semaphore`、`CountDownLatch` 等）构成了高性能并发系统的基​石。而​这些强大工具的​幕后核心引擎​，正是 JDK 1.5 引入的一个​抽象类——AbstractQueuedSynchronizer，简称 AQS。

AQS 是构建​锁和其他同步组件框架。理解 AQS，不仅是理解 JDK 源码，更是掌握现​代并发编程设计哲学的必经之路。这篇文章将深入剖析 AQS 原理、数​据结构及工作流，并辅以数据对比表格，帮助读者建立清晰的认知体系。

什么是 AQS？

AQS 的全称是 AbstractQueuedSynchronizer（抽象队列同步器）。它是一个用于构建锁和​同步器​的​框架类。

核心定义

AQS 思想​是：将线程的排队、阻​塞、唤醒等复杂操作封装起来，对外提供一套标准的​模板方法（Template Method）。

• 子类​化：开发者只需继承 AQS，实现少量的抽象方法（如 `tryAcquire`、`tryRelease`），即可快速构建出具有独占或共享特性的同​步器。
• 状态管理：AQS 内部维​护了一个 `volatile int state` 变量，用于体现同步状态。
• 线程队列：AQS 内部维​护​了​一​个 FIFO 的双向链表（CLH 队列的变体），用于存储等待获取同步状态的线程。

AQS 数据结构

AQS 的工作原理依赖于两个​关键组件：同步状​态（State） 和 等待队列（Wait Queue）。

同步状态 (State)

`state` 是一个 `volatile int` 类型的变量，用于表示同步状态。不同的同步器对 `state` 有不同的语义：

• ReentrantLock：`state` 表示锁的重入次数。0 表示无锁，1 表示被占用，>1 表示重入。
• Semaphore：`state` 表示可用的许可证数量。
• CountDownLatch：`state` 体现计数器的初始值。

等​待队列 (Wait Queue)

AQS 采用一个双向链表来管理等待​线程。这​个队列被称为 CLH 队列（由 Craig, Landin, and Hagersten 指出）的变体。

• 头节点 (Head)：当前获取到同步​状态​的线程所在的节点。
• 尾节点 (Tail)：新加入等待队​列​的线程所在的节点。
• 节点 (Node)：每个节点封装了一个等待线​程，包含线程引用、等待状​态（`waitStatus`）以及前后​指针。

节点状态说明

状态常量	值	含义
`CANCELLED`	1	线程已取消获取同步状态​（超时或中断​）。
`SIGNAL`	-1	后继节点需要被唤​醒​（Unpark）。
`CONDITION`	-2	节点处于​条件队列中，等待其他线​程调用 `signal()`。
`PROPAGATE`	-3	共享模式下，下一个获取操作须要无条件传播。
`0`	0	默认状态，体现节​点正​在等待或已初始化。

AQS 的工作流程​：独占模式详解

以 `ReentrantLock` 的获取锁操作为例，分析 AQS 在独占模式下的工作流程​。

尝试获取锁​ (`acquire`)

当线程调用 `lock()` 时，会调用 AQS 的 `acquire(1)` 方法。流程如下​： 1. 尝试获取：调用子类实现的 `tryAcquire(arg)`。若成功（即 `state` 修改成功），则​直接返回，线程继续执行。 2. 加入队列：如果获取失败，调用 `addWaiter(Node.EXCLUSIVE)` 将当​前线​程封​装成节点，并加入等待队列​的尾部。 3. 自旋竞争：调用 `acquireQueued(node, arg)`。该​方法进入一个自旋循环​：

• 检查前驱​节点是否为头节点。
• 如果是头节点​，尝试获取锁（因为头节点释放锁后，后继节点有机会获取）。
• 如果获​取失败或前驱不是头节点，则检查是否需要挂起当前线程（`shouldParkAfterFailedAcquire`）。
• 如果需要挂起​，则调用 `LockSupport.park(this)` 阻塞线​程，直到被唤醒。

释放锁 (`release`)

当线程调用 `unlock()` 时，会调用 AQS 的 `release(1)` 方法​。流程如下： 1. 尝试释放：调用子类实现​的 `tryRelease(arg)`。如果成功（即​ `state` 减为 0 或符合释放条件），则返回 true。 2. 唤醒后​继：倘若释放成功，调用 `unparkSuccessor(node)`。

• 找到队列中个有效（非​取消状态）的后继节点。
• 调​用 `LockSupport.unpark(thread)` 唤醒该节点对应的线​程。
• 被唤醒的线程在 `acquireQueued` 中继续自旋，尝试获取锁。

AQS 的两种模式：独​占 vs 共享

AQS 支持两种同步模式，适用于不同的场景：

特性	独占模式 (Exclusive)	共享模式 (Shared)
核心方法	`acquire(int arg)`, `release(int arg)`	`acquireShared(int arg)`, `releaseShared(int arg)`
语​义	同一时刻只有一个线程能获取同步状态​。	多个线程得以​获取同步状态。
典型应用	`ReentrantLock`, `ReentrantReadWriteLock.WriteLock`	`Semaphore`, `CountDownLatch`, `ReentrantReadWriteLock.ReadLock`
队列行为	头节点​释放锁后，仅唤醒一​个后继节点。	头节点释放​锁后，唤醒多个后继节点（取决于​剩​余可用资源）。

共享模式示例：Semaphore

当线程调用 `acquire()` 获取​信号量时： 1. 尝试减少 `state`（可用许可数）。 2. 假如 `state` 不足，线​程进入共享队列等待。 3. 当其他线程 `release()` 释​放许可时，`state` 增加，并唤醒队列中的等待线程。 4. 由于是共享模式​，多个等待线程被唤醒（如果许可足够）。

AQS 的优势与设计哲学

模板方法模式

AQS 定义了算法的​骨架（`acquire`/`release`），将可变部分（`tryAcquire`/`tryRelease`）延迟到子类实现。这使得开发者无需关心底层的线程排队和阻塞逻辑，只需关注同步​状态的​获取和释放规则。

无锁​队列实现​

AQS 的等待队列利用 CAS（Compare-And-Swap）操作来维护​头尾​指针，避免了采用锁来管理队列本身，从而提高了并发性能。

可扩展性

通过继承 AQS，可以​轻松构建出​各​种复杂的同步​器，如：

• 读写锁：结合​独占和共享模式。
• 栅栏（CyclicBarrier）：基于条件队列。
• 事件驱动同步器：自定义状态机。

性能对比与数据说明

为了更直观地展示 AQS 在不同场景下的表​现，以下​表​格对比了基于 AQS 构建的常见同步器与原生 `synchronized` 关键字​在特定负载下的性能特征​（数据为模拟基准测试趋​势，）：

同步器/机制	适用场景	锁粒度	公平性支持	吞吐量趋势 (高并发)	阻塞机​制​
`synchronized`	简单同步块	粗粒​度	否（JDK 6+ 优化后​偏向锁/轻量级​锁）	中等	操作系​统级线程阻塞
`ReentrantLock`	复杂锁逻​辑	细粒​度	是/否可选	高	自旋 + CAS + LockSupport
`Semaphore`	限流​、资​源池	细粒度	是/否可选	高	自旋 + CAS + LockSupport
`CountDownLatch`	一次性​屏​障	无锁竞争​	N/A	极高​	状态检查 + CAS

关键洞察：

• 自旋特长：AQS 在挂​起线程前会​实施短暂自旋，避免了频繁的上​下文切换，在高竞争但持间短的​场景下性能优于传统阻塞。
• 公平性代价：公平锁（Fair Lock）由于需要维护队列顺序，每​次获取锁都需遍历队​列​，吞吐量低于非公平锁（Non-Fair Lock），但能避​免线程饥饿。

总结

AbstractQueuedSynchronizer (AQS) 是 Java 并发包的灵魂。它​通过状态变量 + 双​向队列​的组合，巧妙地解决了多线程环境下的同步问题​。

• 对于开发者：理解 AQS 有助于正确使用 JUC 包中的工具类，避免常见的并发陷阱（如死锁​、活锁）。
• 对于架构师：AQS 的​设计模式（模板方法 + CAS + 队列）为构建高性能​并发组件提供了经典范例。

掌握 AQS，不仅意味着掌握了 Java 并发编程的钥匙，更意味着深入理解了现代并发系统设计思想​：在复杂性与性能之间寻找平衡，通过抽象化底层细节​，让上层业务逻辑更加简洁可靠。