AQS（AbstractQueuedSynchronizer）详解

AQS概述

**AQS（AbstractQueuedSynchronizer）**是Java并发包(java.util.concurrent)中的一个核心抽象类，它是构建锁和同步器的基础框架。AQS由Doug Lea设计，旨在简化并发工具的开发，为Java中大部分同步工具提供了统一的底层实现机制。

AQS的主要特点包括：

• 状态管理：使用一个int类型的volatile变量state表示同步状态
• 等待队列：使用FIFO队列管理等待线程
• 模式支持：支持独占模式和共享模式
• 条件支持：支持ConditionObject实现等待/通知机制

AQS核心原理

状态管理

AQS使用一个volatile int state变量来表示同步状态，通过getState()、setState()和compareAndSetState()方法来访问和修改这个状态。状态的具体含义由子类定义，例如：

• 在ReentrantLock中，state表示锁的持有次数
• 在Semaphore中，state表示剩余的许可数量
• 在CountDownLatch中，state表示需要倒数的计数值

等待队列

AQS使用一个CLH队列的变种来管理等待线程。CLH队列是一个虚拟的双向队列，每个节点代表一个等待线程。队列中的节点包含线程引用、等待状态、前驱节点和后继节点等信息。

独占模式与共享模式

AQS支持两种同步模式：

获取与释放同步状态

AQS的核心方法包括：

• acquire(int arg)：独占模式下获取同步状态
• release(int arg)：独占模式下释放同步状态
• acquireShared(int arg)：共享模式下获取同步状态
• releaseShared(int arg)：共享模式下释放同步状态

这些方法的实现遵循以下流程：

CAS操作

AQS大量使用**CAS（Compare And Swap）**操作来保证原子性，避免使用重量级锁。CAS是一种乐观锁机制，通过比较并交换操作来更新共享变量的值，避免了线程上下文切换的开销。

AQS应用场景

构建锁

AQS是构建各种锁的基础，例如：

• ReentrantLock：可重入的独占锁，支持公平和非公平模式
• ReentrantReadWriteLock：可重入的读写锁，读锁共享，写锁独占

构建同步器

AQS也用于构建各种同步器：

• Semaphore：信号量，用于控制同时访问资源的线程数量
• CountDownLatch：倒计时门闩，允许一个或多个线程等待其他线程完成操作
• CyclicBarrier：循环屏障，让一组线程到达一个屏障时被阻塞，直到最后一个线程到达时才放开

其他同步工具

• ThreadPoolExecutor：线程池中的Worker类使用AQS实现线程的中断状态管理
• FutureTask：使用AQS实现任务状态的同步

代码示例

下面是一个基于AQS实现的简单互斥锁：

import java.util.concurrent.locks.AbstractQueuedSynchronizer;

public class Mutex {
    // 静态内部类，继承AQS
    private static class Sync extends AbstractQueuedSynchronizer {
        // 尝试获取资源（独占模式）
        @Override
        protected boolean tryAcquire(int arg) {
            if (compareAndSetState(0, 1)) { // state从0变为1，表示获取锁
                setExclusiveOwnerThread(Thread.currentThread()); // 设置当前线程为独占线程
                return true;
            }
            return false;
        }
        
        // 尝试释放资源（独占模式）
        @Override
        protected boolean tryRelease(int arg) {
            if (getState() == 0) // 如果锁未被持有，抛出异常
                throw new IllegalMonitorStateException();
            setExclusiveOwnerThread(null); // 清除独占线程
            setState(0); // 释放锁，state设为0
            return true;
        }
        
        // 检查资源是否被独占
        @Override
        protected boolean isHeldExclusively() {
            return getState() == 1;
        }
    }
    
    private final Sync sync = new Sync();
    
    // 获取锁
    public void lock() {
        sync.acquire(1);
    }
    
    // 释放锁
    public void unlock() {
        sync.release(1);
    }
    
    // 检查锁是否被持有
    public boolean isLocked() {
        return sync.isHeldExclusively();
    }
}

总结

AQS是Java并发编程的核心组件，它通过状态管理、等待队列和CAS操作等机制，为构建各种锁和同步器提供了统一的框架。理解AQS的工作原理对于深入掌握Java并发编程至关重要，它不仅帮助我们理解Java并发工具的实现机制，还能指导我们设计自己的同步工具。

参考链接

1. Java官方文档 - AbstractQueuedSynchronizer
2. Java并发编程实战
3. The java.util.concurrent Synchronizer Framework
4. Java并发包源码分析