并发编程之深入理解AQS

这篇具有很好参考价值的文章主要介绍了并发编程之深入理解AQS。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

目录

什么是AQS?

AQS的特性

AQS总结


什么是AQS?

       java.util.concurrent包中的大多数同步器实现都是围绕着共同的基础行为,比如等待队列、条件队列、独占获取、共享获取等,而这些行为的抽象就是基于AbstractQueuedSynchronizer(简称AQS)实现的,AQS是一个抽象同步框架,可以用来实现一个依赖状态的同步器。

      JDK中提供的大多数的同步器如ReentrantLock, Semaphore、CountDownLatch等,都是基于AQS框架来实现的。(一般是通过一个内部类Sync继承AQS将同步器所有调用都映射到Sync对应的方法)以下是ReentrantLock的相关源码:

并发编程之深入理解AQS,并发编程,java,开发语言

       通过以上图片我们可以看到ReentrantLock实现了Lock接口,然后内部类Sync继承了AbstractQueuedSynchronizer,所以说ReentrantLock也是基于AQS框架来实现的。

AQS的特性

1. 阻塞等待队列 2. 共享/独占 3. 公平/非公平 4. 可重入 5. 允许中断

AQS内部维护属性volatile int state

state表示资源的可用状态

State三种访问方式:

getState()、setState()、compareAndSetState()

AQS定义两种资源共享方式

Exclusive-独占,只有一个线程能执行,如ReentrantLock

Share-共享,多个线程可以同时执行,如Semaphore/CountDownLatch

AQS定义两种队列

同步等待队列: 主要用于维护获取锁失败时入队的线程

条件等待队列: 调用await()的时候会释放锁,然后线程会加入到条件队列,调用signal()唤醒的时候会把条件队列中的线程节点移动到同步队列中,等待再次获得锁。

同步等待队列

        AQS当中的同步等待队列也称CLH队列,CLH队列是Craig、Landin、Hagersten三人发明的一种基于双向链表数据结构的队列,是FIFO先进先出线程等待队列,Java中的CLH队列是原CLH队列的一个变种,线程由原自旋机制改为阻塞机制。

AQS 依赖CLH同步队列来完成同步状态的管理:

1. 当前线程如果获取同步状态失败时,AQS则会将当前线程已经等待状态等信息构造成一个节点(Node)并将其加入到CLH同步队列,同时会阻塞当前线程。

2. 当同步状态释放时,会把首节点唤醒(公平锁),使其再次尝试获取同步状态。

3. 通过signal或signalAll将条件队列中的节点转移到同步队列。(由条件队列转化为同步队列)

并发编程之深入理解AQS,并发编程,java,开发语言

条件等待队列

AQS中条件队列是使用单向列表保存的,用nextWaiter来连接

1. 调用await方法阻塞线程。

2. 当前线程存在于同步队列的头结点,调用await方法进行阻塞(从同步队列转化到条件队列)。

 Condition接口详解
       condition条件等待队列用于支持线程的条件等待和唤醒操作。当一个线程在某个条件上等待时(使用await方法),它将会释放持有的锁,并进入条件等待队列,等待其他线程通过signal或signalAll方法来唤醒它。以下是await和signal方法的相关解析:

await()方法

      当线程调用await方法时,它首先会检查当前线程是否持有锁。如果线程没有持有锁,则会抛出IllegalMonitorStateException异常。持有锁的情况下会创建一个节点(Node对象)来表示当前线程,并将该节点加入到条件等待队列中(即将节点加入到Condition的等待队列中)。 线程会释放持有的锁,并进入等待状态,直到被唤醒。同时,线程会被阻塞在条件等待队列上的节点上,使其不再参与锁的竞争。当线程被唤醒时,它会重新尝试获取锁,并从await方法返回,继续执行后续代码。

signal/signalAll方法

       当线程调用signal方法时,它会将条件等待队列中的第一个节点从条件等待队列中移动到同步队列中(即移动到AQS的等待队列中),表示该线程有机会再次参与锁的竞争。


AQS总结

         AQS是多线程同步器,它是JUC包中多个组件的底层实现,如 Lock、 CountDownLatch、Semaphore等都用到了AQS. 从本质上来说,AQS 提供了两种锁机制,分别是排它锁和共享锁。 排它锁,就是存在多线程竞争同一共享资源时,同一时刻只允许一个线程访问该共享资源,也就是多个线程中只能有一个线程获得锁资源,比如Lock中的ReentrantLock可重入锁实现就是用到了 AQS中的排它锁功能。 共享锁也称为读锁,就是在同一时刻允许多个线程同时获得锁资源,比如 CountDownLatch和Semaphore都是用到了AQS中的共享锁功能。
        AQS采用了一个int类型的互斥变量state用来记录锁竞争的一个状态,0表示当前没有任何线程竞争锁资源,而大于等于1表示已经有线程正在持有锁资源。一个线程来获取锁资源的时候,首先判断state是否等于0,如果是(无锁状态),则把这个state更新成1,表示占用到锁。此时如果多个线程进行同样的操作,会造成线程安全问题。把阻塞的线程按照先进先出的原则加入到一个双向链表的结构中(同步等待队列),当获得锁资源的线程释放锁之后,会从双向链表的头部去唤醒下一个等待的线程再去竞争锁。另外关于公平性和非公平性问题,AQS的处理方式是,在竞争锁资源的时候,公平锁需要判断双向链表中是否有阻塞的线程,如果有,则需要去排队等待;而非公平锁的处理方式是,不管双向链表中是否存在等待锁的线程,都会直接尝试更改互斥变量state去竞争锁。文章来源地址https://www.toymoban.com/news/detail-819119.html

到了这里,关于并发编程之深入理解AQS的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • Java——并发编程(CAS、Lock和AQS)

    答: Lock 接口比同步方法和同步块提供了 更具扩展性的锁操作 。他们允许更灵活的结构,可以具有完全不同的性质,并且可以支持多个相关类的条件对象。 可以使锁更公平; 可以使线程在等待锁的时候响应中断; 可以让线程尝试获取锁,并在无法获取锁的时候立即返回或

    2024年02月06日
    浏览(55)
  • 华为云出品《深入理解高并发编程:Java线程池核心技术》电子书发布

    系统拆解线程池核心源码的开源小册 透过源码看清线程池背后的设计和思路 详细解析AQS并发工具类 点击下方链接进入官网,右上角搜索框搜索“《深入理解高并发编程:Java线程池核心技术》” 即可获取下载。 https://auth.huaweicloud.com/authui/login.html?locale=zh-cnservice=https%3A%2F%2F

    2024年02月16日
    浏览(40)
  • ElasticSearch 中的中文分词器以及索引基本操作详解,Java高并发编程详解深入理解pdf

    PUT book/_settings { “number_of_replicas”: 2 } 修改成功后,如下: 更新分片数也是一样。 2.3 修改索引的读写权限 索引创建成功后,可以向索引中写入文档: PUT book/_doc/1 { “title”:“三国演义” } 写入成功后,可以在 head 插件中查看: 默认情况下,索引是具备读写权限的,当然这

    2024年04月09日
    浏览(51)
  • 深入理解并发编程艺术之内存模型

    随着硬件技术的飞速发展,多核处理器已经成为计算设备的标配,这使得开发人员需要掌握并发编程的知识和技巧,以充分发挥多核处理器的潜力。然而并发编程并非易事,它涉及到许多复杂的概念和原理。为了更好地理解并发编程的内在机制,需要深入研究内存模型及其在

    2024年02月14日
    浏览(48)
  • 深入理解高并发编程 - 线程的执行顺序

    在Java中,线程的执行顺序是由操作系统的调度机制决定的,具体顺序是不确定的,取决于多个因素,如操作系统的调度策略、线程的优先级、线程的状态转换等。因此,不能对线程的执行顺序做出可靠的假设。 以下是一个简单的Java代码示例,演示了多个线程的执行顺序是不

    2024年02月14日
    浏览(53)
  • 深入理解高并发编程 - 深度解析ScheduledThreadPoolExecutor

    ScheduledThreadPoolExecutor 继承自 ThreadPoolExecutor 并实现了 ScheduledExecutorService 接口,这使得它可以同时充当线程池和定时任务调度器。 构造方法接收一个 corePoolSize 参数,它表示线程池中的核心线程数。核心线程是一直保持存活的线程,即使没有任务执行,以便支持定时任务的调

    2024年02月12日
    浏览(48)
  • JUC并发编程学习笔记(十八)深入理解CAS

    什么是CAS 为什么要学CAS:大厂你必须深入研究底层!有所突破! java层面的cas-------compareAndSet compareAndSet(int expectedValue, int newValue) 期望并更新,达到期望值就更新、否则就不更新! Unsafe类 java不能直接操作内存,但是可以调用c++,c++可以操作内存,java可以通过native定义

    2024年02月05日
    浏览(60)
  • 深入理解高并发编程 - 深度解析Thread 类的源码

    先看源码:Thread 类实现了 Runnable 接口 而 Runnable 被@FunctionalInterface 注解标记为函数式接口,Runnable 接口源代码 再来看看@FunctionalInterface 注解的源码 FunctionalInterface 用于标记类或接口是否是一个函数式接口,并在运行时可用于反射获取信息。 这段代码是 Thread 类的一个静态初

    2024年02月09日
    浏览(48)
  • 并发编程 - AQS 源码

    1. AQS 源码 2. AQS 框架具体实现 - 独占锁实现 ReentrantLock 源码 实现 ReentrantLock 的三大核心原理: LocksSuport :加锁解锁 自旋 :如果没有加锁成功就一直自旋 CAS :保证只能有一个线程可以加锁成功 queue 队列:用容器保存上面未加锁成功的阻塞线程,要解锁的时候从容器中拿出

    2023年04月21日
    浏览(34)
  • JUC并发编程之AQS原理

    全称是 AbstractQueuedSynchronizer,是阻塞式锁和相关的同步器工具的框架 特点: 用 state 属性来表示资源的状态(分独占模式和共享模式),子类需要定义如何维护这个生态,控制如何获取锁和释放锁 getState - 获取 state 状态 setState - 设置 state 状态 compareAndSetState - cas 机制设置 s

    2023年04月18日
    浏览(86)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包