首先我们从java.util.concurrent.locks包中的AbstraceQueuedSynchronizer说起，在下文中称为AQS。
AQS是一个用于构建锁和同步器的框架。例如在并发包中的ReentrantLock、Semaphore、CountDownLatch、ReentrantReadWriteLock等都是基于AOS构建，这些锁都有一个特点，都不是直接扩展自AQS，而是都有一个内部类继承自AQS。为什么会这么设计而不是直接继承呢？简而言之，锁面向的是使用者，同步器面向的是线程控制，在锁的实现中聚合同步器而不是直接继承AQS很好的隔离了二者所关注的领域。
AbstractQueuedSynchronizer在内部依赖一个双向同步队列来完成同步状态的管理，当前线程获取同步状态失败时，同步器会将该线程和等待状态信息构造成一个节点并将其加入到同步队列中。Node节点以AQS的内部类存在，其字段属性如下：
AbstractQueuedSynchronizer$Node | |
属性 | 描述 |
volatile int waitStatus | 等待状态，并不是同步状态，而是在队列中的线程节点等待状态（Node节点中一共定义四种状态） CANCELLED = 1 //线程由于超时或被中断会被取消在队列中的等待，被取消了的线程不会再被阻塞，即状态不会再改变 SIGNAL = -1 //后继节点处于等待状态，当前节点释放锁或者取消等待时会通知后继节点 CONDITION = -2 //暂时忽略，涉及Condition
网友评论 |
