# AQS (AbstractQueuedSynchronizer) 概述

有的时候博客内容会有变动,首发博客是最新的,其他博客地址可能会未同步,认准https://blog.zysicyj.top

全网最细面试题手册,支持艾宾浩斯记忆法。这是一份最全面、最详细、最高质量的 java面试题,不建议你死记硬背,只要每天复习一遍,有个大概印象就行了。 https://store.amazingmemo.com/chapterDetail/1685324709017001`

AQS (AbstractQueuedSynchronizer) 概述

AQS,即 AbstractQueuedSynchronizer,是Java并发包中的一个核心组件,它为实现依赖于先进先出 (FIFO) 等待队列的阻塞锁和相关的同步器(如信号量、事件等)提供了一个框架。

核心概念

AQS 使用一个整型的 volatile 变量(称为 state)来表示同步状态,并通过内置的 FIFO 队列来管理那些阻塞在同步状态上的线程。

状态(State)

AQS 中的 state 变量是用来表示同步状态的。例如,在一个独占锁的实现中,state 可能表示锁的占用情况(0 表示未锁定,1 表示锁定)。

节点(Node)和队列

当线程尝试获取同步状态失败时,AQS 会将该线程包装成一个节点(Node)并将其加入到队列中。这个队列是一个双向链表,用于实现等待队列。

AQS 的主要方法

AQS 定义了一系列的方法,这些方法可以被同步器实现以提供其独特的同步逻辑。

独占模式

  • boolean tryAcquire(int arg):尝试获取资源,成功则返回 true,失败则返回 false

  • boolean tryRelease(int arg):尝试释放资源,成功则返回 true,失败则返回 false

共享模式

  • int tryAcquireShared(int arg):尝试获取资源。返回值大于等于0表示成功;小于0表示失败。

  • boolean tryReleaseShared(int arg):尝试释放资源,成功则返回 true,失败则返回 false

模板方法

  • void acquire(int arg):调用 tryAcquire,并在失败时将线程加入队列,可能会阻塞。

  • void release(int arg):调用 tryRelease 并唤醒等待中的线程。

  • void acquireShared(int arg):调用 tryAcquireShared,并在失败时将线程加入队列,可能会阻塞。

  • void releaseShared(int arg):调用 tryReleaseShared 并唤醒等待中的线程。

AQS 的重要性

AQS 的设计极大地简化了同步控制的实现,许多并发工具类都是基于 AQS 构建的,例如:

  • ReentrantLock:一个可重入的互斥锁。

  • CountDownLatch:一个允许一个或多个线程等待一系列指定操作的完成。

  • Semaphore:一个计数信号量。

  • FutureTask:一个可取消的异步计算。

AQS 的使用示例

以下是一个简化的 AQS 使用示例,展示了如何实现一个独占锁:

class Mutex extends AbstractQueuedSynchronizer {
    // 尝试获取锁
    protected boolean tryAcquire(int acquires) {
        assert acquires == 1; // Otherwise unused
        if (compareAndSetState(0, 1)) {
            setExclusiveOwnerThread(Thread.currentThread());
            return true;
        }
        return false;
    }

    // 尝试释放锁
    protected boolean tryRelease(int releases) {
        assert releases == 1; // Otherwise unused
        if (getState() == 0) throw new IllegalMonitorStateException();
        setExclusiveOwnerThread(null);
        setState(0);
        return true;
    }

    // 是否锁定状态
    public boolean isLocked() {
        return getState() != 0;
    }
}

在这个示例中,tryAcquire 方法检查 state 是否为0,如果是,则尝试将其设置为1,如果设置成功,则表示获取了锁。tryRelease 方法将 state 设置回0,并清除独占线程。

AQS 提供的模板方法 acquirerelease 会调用这些方法,并在必要时进行线程的排队和唤醒。

总结

AQS 是 Java 并发编程中的一个重要组件,它通过内部的同步状态、等待队列和模板方法,为构建锁和其他同步器提供了强大的基础。理解和掌握 AQS 对于深入学习 Java 并发编程至关重要。

最后更新于