AQS机制

作者: 奔跑吧李博 | 来源:发表于2023-01-07 23:43 被阅读0次
AQS:全名为AbstractQuenedSynchronizer,翻译过来即抽象的队列同步器,是一种用来构建锁和同步器的框架。

基于AQS构建同步器,很多并发类都是基于它实现的,这些类都是继承于AbstractQueuedSynchronizer,包括:

  • ReentrantLock
  • Semaphore
  • CountDownLatch
  • ReentrantReadWriteLock
  • SynchronusQueue

AbstractQueuedSynchronizer类及重要方法:

public abstract class AbstractQueuedSynchronizer
    extends AbstractOwnableSynchronizer
    implements java.io.Serializable {

    /**
     * The synchronization state.
     */
    private volatile int state;
    
    protected boolean tryAcquire(int arg) {
        throw new UnsupportedOperationException();
    }

   static final class Node {
      volatile Node prev;
      volatile Node next;
      volatile Thread thread;
   }
}
AQS的原理

基于CLH队列,用volatile修饰共享变量state,线程通过CAS去改变状态,成功则获取锁成功,失败则进入等待队列,等待被唤醒。

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

AQS是自旋锁
在等待唤醒的时候,经常会使用自旋(while(!cas()))的方式,不停地尝试获取锁,直到获取成功。


AQS维护了一个volatile int state和一个FIFO线程等待队列,多线程争用资源被阻塞的时候就会进入这个队列。

AQS设计思想
1.AQS使用一个int成员变量state来表示同步状态
2.使用Node实现FIFO队列,可以用于构建锁或者其他同步装置
3.AQS资源共享方式:独占Exclusive(排它锁模式)和共享Share(共享锁模式)

  • Exclusive
    独占,只有一个线程能执行。
    如:ReentrantLock

  • Share
    共享,多个线程可以同时执行。
    如:Semaphore、CountDownLatch、ReadWriteLock,CyclicBarrier

自定义同步器的实现

AQS底层使用了模板方法模式,在构建自定义同步器时,只需要依赖AQS底层再实现共享资源state的获取与释放操作即可。自定义同步器在实现的时候只需要实现共享资源state的获取和释放方式即可,至于具体线程等待队列的维护,AQS已经在顶层实现好了。自定义同步器实现的时候主要实现下面几种方法:

  • isHeldExclusively():该线程是否正在独占资源。只有用到condition才需要去实现它。
  • tryAcquire(int):独占方式。尝试获取资源,成功则返回true,失败则返回false。
  • tryRelease(int):独占方式。尝试释放资源,成功则返回true,失败则返回false。
  • tryAcquireShared(int):共享方式。尝试获取资源。负数表示失败;0表示成功,但没有剩余可用资源;正数表示成功,且有剩余资源。
  • tryReleaseShared(int):共享方式。尝试释放资源,如果释放后允许唤醒后续等待结点返回true,否则返回false。

参考:
https://blog.csdn.net/JavaShark/article/details/125300628
https://blog.csdn.net/feiying0canglang/article/details/121109407

相关文章

  • AQS机制

    AQS:全名为AbstractQuenedSynchronizer,翻译过来即抽象的队列同步器,是一种用来构建锁和...

  • 17.读写锁ReentrantWriteReadLock

    读写锁ReentrantWriteReadLock,基于AQS的锁机制,实现ReadWriteLock接口。内部有...

  • Java并发锁框架AQS(AbstractQueuedSynch

    一,视频教程说明 视频基于 AQS 源码分析,深入分析AQS原理,达到彻底理解Java锁机制的目标! 视频地址:h...

  • AQS

      队列同步器(AbstractQueuedSynchronizer. AQS)在Java并发机制中占据非常基础且...

  • AQS

    AQS解析 AQS通过FIFO的等待队列,提供了一个用来实现阻塞锁和相关的同步器(信号量、事件机制)的框架,它是很...

  • Java的AQS详解1--独占锁的获取及释放

    其实,很早之前就写过一篇浅谈Java的AQS,当时对AQS的运作机制有了大致的掌握,但可能源码还是没完全吃透,有些...

  • 马桶Java :5.Java AQS 机制 (Reentrant

    马桶?Java 上厕所就能看完的小知识! 欢迎关注、点赞 持续更新!AQS 机制 (ReentrantLock) ...

  • 漫谈AQS以及公平与非公平机制

    对java并发机制熟悉的人都知道底层基本上都是基于AQS实现的,即AbstractQueuedSynchroniz...

  • Java并发编程——AQS源码解析

    Java并发编程——AQS源码解析 什么是AQS AQS有什么用 AQS实现方式 一、AQS是什么? AQS是一个...

  • Java并发编程之锁机制之Condition接口

    前言 在前面的文章中,我曾提到过,整个Lock接口下实现的锁机制中AQS(AbstractQueuedSynchr...

网友评论

    本文标题:AQS机制

    本文链接:https://www.haomeiwen.com/subject/fkloqdtx.html