原来 AQS实现原理还能如此总结

时间：2020-10-30 12:03:44 阅读：18 评论：0 收藏：0 [点我收藏+]

标签：自定义独占模式 swa lease 缺点可见性共享模式推荐 countdown

01 AQS简介

01 什么是AQS

AQS全称为AbstractQueuedSynchronizer，就是抽象队列同步器。AQS是一个用来构建锁和其他同步组件的基础框架，使用AQS可以简单且高效地构造出应用广泛的同步器，它提供了一个FIFO队列，可以看成是一个用来实现同步锁以及其他涉及到同步功能的核心组件。

02AQS的核心思想

如果被请求的共享资源空闲，则将当前请求资源的线程设置为有效的工作线程，并且将共享资源设置为锁定状态。如果被请求的共享资源被占用，那么就需要一套线程阻塞等待以及被唤醒时锁分配的机制，这个机制AQS是用CLH队列锁实现的，即将暂时获取不到锁的线程加入到队列中。

03什么是CLH队列

CLH(Craig,Landin,and Hagersten)队列是一个虚拟的双向队列(虚拟的双向队列即不存在队列实例，仅存在结点之间的关联关系)。AQS是将每条请求共享资源的线程封装成一个CLH锁队列的一个结点(Node)来实现锁的分配。

04 同步状态

AQS中的共享资源是使用一个int成员变量来表示同步状态，通过内置的FIFO队列来完成获取资源线程的排队工作。AQS使用CAS对该同步状态进行原子操作实现对其值的修改。状态信息通过procted类型的getState，setState，compareAndSetState进行操作。AQS使用CAS对该同步状态进行原子操作实现对其值的修改。状态信息通过procted类型的getState，setState，compareAndSetState进行操作。
源码：

//同步状态，使用volatile来保证其可见性
private volatile int state;

//获取同步状态
protected final int getState() {
    return state;
}

//设置同步状态
protected final void setState(int newState) {
    state = newState;
}

//原子性地修改同步状态
protected final boolean compareAndSetState(int expect, int update) {
    // See below for intrinsics setup to support this
    return unsafe.compareAndSwapInt(this, stateOffset, expect, update);
}

05 资源的共享方式

AQS定义两种资源共享方式

Exclusive(独占)：只能有一个线程能执行，如ReentrantLock。又可分为公平锁和非公平锁：
公平锁：按照线程在队列中的排队顺序，先到者先拿到锁
非公平锁：当线程要获取锁时，无视队列顺序直接去抢锁，谁抢到就是谁的
Share(共享)：多个线程可同时执行，如Semaphore、CountDownLatch等。

06 设计模式

AQS的设计是使用模板方法设计模式，它将一些方法开放给子类进行重写，而同步器给同步组件所提供模板方法又会重新调用被子类所重写的方法。
自定义同步器时需要重写下面几个AQS提供的模板方法

//独占式的获取同步状态，实现该方法需要查询当前状态并判断同步状态是否符合预期，然后再进行CAS设置同步状态 
protected boolean tryAcquire(int arg) { throw new UnsupportedOperationException();} 
//独占式的释放同步状态，等待获取同步状态的线程可以有机会获取同步状态 
protected boolean tryRelease(int arg) { throw new UnsupportedOperationException();} 
//共享式的获取同步状态 
protected int tryAcquireShared(int arg) { throw new UnsupportedOperationException();} 
//尝试将状态设置为以共享模式释放同步状态。该方法总是由执行释放的线程调用。 
protected int tryReleaseShared(int arg) { throw new UnsupportedOperationException(); } 
//当前同步器是否在独占模式下被线程占用，一般该方法表示是否被当前线程所独占 
protected int isHeldExclusively(int arg) { throw new UnsupportedOperationException();}

这些方法的实现必须是内部线程安全的。AQS类中的其他方法都是final ，所以无法被其他类覆盖。

02 CLH队列

当共享资源被某个线程占有，其他请求该资源的线程会被阻塞，从而进入同步队列。AQS底层的数据结构采用CLH队列，它是一个虚拟的双向队列，即不存在队列的实例，仅存在节点之间的关联关系。AQS是将每条请求共享资源的线程封装成一个CLH锁队列的一个结点(Node)来实现锁的分配。注：Sync queue，即同步队列，是双向链表，包括head结点和tail结点，结点主要用作后续的调度。而Condition queue不是必须的，它是一个单向链表，只有当使用Condition时，才会存在此单向链表，并且可能会有多个Condition queue。
技术图片
节点的类型是AQS的静态内部类Node，代码：
Node节点的状态有如下四种