AQS架构

水深无声 2021-12-10 01:07 301阅读 0赞

AQS，全称是AbstractQueuedSynchronizer，中文译为**抽象队列式同步器**

**AQS架构：**

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2ODA3ODYy_size_16_color_FFFFFF_t_70][]

说明：AQS维护了一个volatile int state （代表共享资源）和一个FIFO线程等待队列（多线程争用资源被阻塞时会进入队列中）

AQS定义了两种资源共享方式：Exclusive（独占方式）、Share（共享方式）

具体在java源码AbstractQueuedSynchronizer类中：

*      protected boolean isHeldExclusively() :该线程是否正在独占资源
 *      tryAcquire/tryRelease:独占的方式尝试获取和释放资源
 *      tryAcquireShared/tryReleaseShared:共享方式尝试获取和释放资源

## ReentrantLock重入锁： ##

*  state初始化状态为0，表示未锁定状态
 *  线程A获取锁的时候，会调用tryAcquire()独占该锁并将state+1；
 *  此后，其他线程再次tryAcquire的时候就会失败，直到A线程unlock()到state=0（释放锁）为止，其他线程才有机会获取锁；
 *  在A线程释放锁之前，A线程是可以重复获取此锁的，（state会累加），这就是可重入的概念；
 *  需要注意的是：获取多少次锁，就要释放多少次锁，这样才能保证state最终回归0状态；

## CountDownLatch： ##

*  任务分为N个子线程去执行，state也初始化为N（注意：N需要和线程个数保持一致）
 *  这N个子线程是并发执行的，每个子线程执行完之后，countDown()一次，state相应也会CAS方式减1
 *  等到所有子线程都执行完毕（state==0），会LockSupport.unpark()调用线程(改方法是直接使用UNSafe，调用操作系统层面控制线程的方式，使得线程继续执行)
 *  然后主线程就是从await函数返回，继续执行；

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM2ODA3ODYy_size_16_color_FFFFFF_t_70]: /images/20211209/74962825b0bc464499870cc1d0e225fe.png