前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >AQS --- 初窥门径

AQS --- 初窥门径

作者头像
贪挽懒月
发布2021-07-23 16:15:47
3500
发布2021-07-23 16:15:47
举报
文章被收录于专栏:JavaEEJavaEE

AQS这个词你可能耳熟能详了,但是面试问道,可能又说不出个所以然来。别急少年,我一次奇遇偶得一本失传已久的武林秘籍,学完你就能达到已臻化境的境界,秘籍目录如下:

  • 初窥门径
  • 渐入佳境
  • 融会贯通

我看你骨骼惊奇,有道灵光从天灵盖射出,确定不来学一下吗?

1. 是什么?

中文名字叫“抽象队列同步器”,英文名字叫“AbstractQueuedSynchronizer”。将这个名字拆开来理解,抽象,说明它的设计用到了模板设计模式,说明它把一些常用的方法抽象出来了,需要子类去继承;同步器,就是用来控制线程之前的同步的;那么队列是什么意思呢,说明它用队列来保存未抢到锁的线程。它是JUC包下的一个类,如下:

AQS

这里有三个类,分别是:

  • AbstractOwnableSynchronizer
  • AbstractQueuedLongSynchronizer
  • AbstractQueuedSynchronizer

我们说的AQS一般是指AbstractQueuedSynchronizer。知道了它是啥,那它到底是一个怎样的存在呢?在JUC中到底起着什么样的作用呢?

AQS它是用来构建锁或者其他同步器组件(CountDownLatch、CyclicBarrier、Semaphore等)重量级基础框架以及整个JUC的基石。通过内置的FIFO队列来完成资源获取线程的排队工作,并通过一个int类型的变量来表示持有锁的状态。也就是,JUC中跟锁相关的那些东西,都需要一些通用的东西,然后把这些通用地抽象出来,就成了AQS。AQS呢就可以理解为一个队列加一个int类型的变量。队列用来保存需要抢占锁的那些资源,int类型的变量表示持有锁的状态。AQS中的队列是一个CLH(CLH是三个人名的缩写,这是一个单向链表)队列的变种,是虚拟双端队列。

2. 能干嘛?

上面说了它是整个JUC的基石,是构建锁和其他同步组件的基础框架。AQS怎么就和锁、同步器组件有关了?请看下面:

  • ReentrantLock:
代码语言:javascript
复制
public class ReentrantLock implements Lock, java.io.Serializable {

    /**
     * Base of synchronization control for this lock. Subclassed
     * into fair and nonfair versions below. Uses AQS state to
     * represent the number of holds on the lock.
     */
    abstract static class Sync extends AbstractQueuedSynchronizer {
        private static final long serialVersionUID = -5179523762034025860L;
        ……
}
  • ReentrantReadWriteLock:
代码语言:javascript
复制
public class ReentrantReadWriteLock
        implements ReadWriteLock, java.io.Serializable {
        ……

    /**
     * Synchronization implementation for ReentrantReadWriteLock.
     * Subclassed into fair and nonfair versions.
     */
    abstract static class Sync extends AbstractQueuedSynchronizer {
        private static final long serialVersionUID = 6317671515068378041L;
        ……
}
  • CountDownLatch :
代码语言:javascript
复制
public class CountDownLatch {
    /**
     * Synchronization control For CountDownLatch.
     * Uses AQS state to represent count.
     */
    private static final class Sync extends AbstractQueuedSynchronizer {
        private static final long serialVersionUID = 4982264981922014374L;
        ……
}
  • Semaphore:
代码语言:javascript
复制
public class Semaphore implements java.io.Serializable {
    private static final long serialVersionUID = -3222578661600680210L;
    /** All mechanics via AbstractQueuedSynchronizer subclass */
    private final Sync sync;

    /**
     * Synchronization implementation for semaphore.  Uses AQS state
     * to represent permits. Subclassed into fair and nonfair
     * versions.
     */
    abstract static class Sync extends AbstractQueuedSynchronizer {
    ……
}

……

看到没,这些类的源码中,都有AbstractQueuedSynchronizer。所以,我们常用的那些锁、同步器,是面向使用者的,而AQS这个同步器,是面向实现者的,即我们常用的JUC中的那些锁、同步器,底层都是由AQS去实现的。AQS它统一并规范了锁的实现,屏蔽了同步状态的管理、线程的阻塞和唤醒等实现细节,使锁、同步器只需要对外暴露简单易用的API即可。

本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档