> 文档中心 > AQS AbstractQueuedSynchronizer源码分析

AQS AbstractQueuedSynchronizer源码分析

在解决并发问题时,开发者需要各种同步功能进行线程间的通信、协调、控制,比如信号量、锁、条件等待通知等等。
JDK提供了AQS作为实现这些同步器(synchronizer)的基础,jdk中的并发工具类比如ReentrantLock, Semaphore, CountDownLatch等都是使用AQS来实现各自的线程同步能力的。

AQS因为方法命名比较抽象,导致很多朋友开始难以理解各个方法的作用、原理,不用担心,通过学习本文今天我们彻底掌握AQS。

AQS使用

AQS整体实现设计

AQS把同步器的操作分成两个操作,分别是acquire获取和release释放。
acquire和release操作的对象是AQS中的state变量。

比如对于锁来说,加锁对应acquire,释放锁对应release;对于Semaphore信号量来说,获取permit对应acquire,释放permit对应release。

在实现具体的同步器时,需要实现tryAcquire和tryRelease。
tryAcquire定义了获取成功的定义,比如在ReentrantLock中,state为0表示未加锁,大于0表示已加锁, tryAcquire就需要定义如何操作state表示当前线程获得了锁。
AQS中state字段是一个volatile的int实例字段,AQS提供了get,set和compareAndSetState方法来查看修改state的值。对于一个简单的锁实现来说acquire实现就是从0的状态下cas成1说明acquire成功,
release就是把state设置为0,完善的锁实现还需要考虑重入、读写锁等功能,在后面会详细讲解。 tryRelease是释放时对state的修改