`
xussen
  • 浏览: 31357 次
  • 性别: Icon_minigender_1
  • 来自: 杭州
社区版块
存档分类
最新评论

AQS源码阅读理解(uncompleted)

阅读更多
有head和tail
当acquire*操作的时候,如果我们定义的资源限制操作返回false时,会在tail端加入一个新的节点(Node里面的所有基础属性都是volatile,用CAS设置tail指针)。
然后利用LockSupport.part(this)阻塞。
当release的时候,如果我们定义的资源操作返回true,会将head节点的下一个SIGNAL节点的thread唤醒。
被唤醒的那个线程会继续尝试执行tryAcquire,这时候会和新线程的请求发生争用,ReentrantLock在这里做了两种策略,一种是判断当前线程是否在链表的第一个位置(fair),一种是不做判断直接争用(unfair)
 
shouldParkAfterFailedAcquire会判断当前加入的节点的前一个节点是否未获得锁(SIGNAL),如果未获得,就返回true,告诉后面该part当前thread了
如果前个线程是CANCELLED的,删除CANCELLED节点,返回false。如果是0,设置为SIGNAL,返回false
也就是说,它做的主要做的是清理的工作,如果是false,就不会去part当前thread,而是再继续走for循环。
这样能保证每次醒来的节点会清理一遍前面的CANCELLED节点,让p==head可以通过
 
Interruptibly式的获取:其他线程对这个线程进行中断,导致LockSupport.part(this)继续执行,返回Thread.interrupted();外部会break-for,在for外层cancel该节点,并抛出InterruptedException
Nanos式的获取:LockSupport.parkNanos(this, nanos),每次醒来都会检查时间,如果时间超出,cancel该节点
 
 
 
方法:
独占获取:            acquire                     acquireInterruptibly                    tryAcquireNanos 
tryAcquire              acquireQueued          doAcquireInterruptibly                doAcquireNanos
共享获取:            acquireShared           acquireSharedInterruptibly          tryAcquireSharedNanos
tryAcquireShared    doAcquireShared       doAcquireSharedInterruptibly      doAcquireSharedNanos
 
独占释放:             release                     
tryRelease
共享释放:             releaseShared           
tryReleaseShared    doReleaseShared
 
hasQueuedThreads  hasContented     getFirstQueuedThread     isFirst     fullIsFirst     getQueuedLength    
getQueuedThreads     getExeclusiveQueuedThreads     getSharedQueuedThreads     getWaitingThreads
owns     hasWaiters     getWaitQueueLength
 
shouldParkAfterFailedAcquire
unparkSuccessor
setHeadAndPropagate
cancelAcquire
 
 
Condition
内部成员:firstWaiter、lastWaiter。内部包含一条Node链
内部方法:
signal、signalAll
await、awaitNanos、awaitUnit、await(long, TimeUnit)、awaitUninterruptibly
hasWaiters、getWaitQueueLength、getWaitingThreads
isOwnedBy(AQS)
 
执行await*操作时,会往末尾(lastWaiter)里添加nextWaiter
然后释放资源(release(state)),调用LockSupport.park(this)
执行signal操作时,会将firstWaiter移到sync queue末尾,调用的还是enq(node),并且将该node的waitStatus设置成SIGNAL,然后在程序执行lock.release时可以按正常资源释放的操作进行。
 
调用阻塞的入口两种,AQS.acquire和Condition.await
分享到:
评论

相关推荐

    AQS源码阅读笔记,画了两三天的AQS...

    AQS源码阅读笔记 AQS(AbstractQueuedSynchronizer)是Java并发编程中的一种同步器框架,它提供了一个队列来管理线程的排队和唤醒机制。下面是AQS源码阅读笔记的详细解释: 1. `ReentrantLock` 的 `unlock()` 方法...

    AQS源码分析 (1).pdf

    接下来,我们来具体分析一下AQS的源码。AQS中定义了一个名为state的volatile变量,用于表示同步状态。这个变量有三种操作方法:getstate()、setstate()和compareAndSetState(),分别用于获取、设置和原子性地更新...

    7 AQS源码分析.docx

    《深入解析AQS源码:理解Java并发编程的核心机制》 AQS,即AbstractQueuedSynchronizer,是Java并发编程中的重要组件,主要用于构建锁和同步器。它基于一种称为CLH(Craig, Landin, and Hagersten)队列的等待队列...

    JUC(一)-AQS源码分析

    AQS源码分析一、锁的介绍1.1 乐观锁/悲观锁1.2 共享锁/独占锁1.3 公平锁/非公平锁1.4 小结二、AQS框架结构介绍2.1 类图2.2 AQS数据结构三、源码详解3.1 acquire源码详解3.2 release源码详解四、从ReentranLock看公平...

    7、深入理解AQS独占锁之ReentrantLock源码分析(1).pdf

    根据给定文件的信息,我们可以深入理解AQS(AbstractQueuedSynchronizer)独占锁之ReentrantLock的源码分析及其实现原理。这不仅包括ReentrantLock本身的特性,还包括了其背后的AQS框架是如何工作的。 ### 一、管程...

    JUC AQS(AbstractQueuedSynchronizer)

    ReentrantLock Lock 加锁过程源码分析图,AQS 源码分析

    aqs_demo.rar

    《AQS同步器与Redisson锁在Java高并发API及SpringBoot中的应用》 在Java并发编程领域,AbstractQueuedSynchronizer(AQS)是一个非常重要的基础组件,它是Java并发包java.util.concurrent中实现锁和同步器的核心...

    Java并发编程:深入解析抽象队列同步器(AQS)及其在Lock中的应用

    维护资源状态的可用性最后,文档提供了AQS源码的初步分析,突出了其设计和实现的关键部分,如等待队列节点类Node的定义综合来看,文章为Java开发者提供了对AQS及其在ReentrantLock中应用的详细理解,是探索Java并发...

    JDK_AQS解析

    通过对关键方法的理解和分析,我们可以更好地理解Java并发库中的同步组件是如何工作的。AQS的设计不仅提高了锁的可重用性,还极大地增强了灵活性和扩展性。通过学习AQS,我们不仅能更深入地了解Java并发库的内部实现...

    Java并发之AQS详解.pdf

    Java并发之AQS详解 AbstractQueuedSynchronizer(AQS)是 Java 并发编程中的一个核心组件,提供了一套多线程访问共享资源的同步器框架。AQS 定义了两种资源共享方式:Exclusive(独占)和 Share(共享)。在 AQS 中...

    AQS的底层原理.zip

    《AQS的底层原理》 在Java并发编程领域,...通过深入理解AQS的原理和机制,有助于我们更好地设计和优化多线程程序,提升系统性能。对于Java开发者来说,掌握AQS的使用和原理,是提升并发编程能力的关键一步。

    AQS流程图.html

    java锁AQS基础逻辑

    AQS流程图ReentranLock.vsdx

    AQS流程图ReentranLock.vsdx

    Java volatile与AQS锁内存可见性

    从JUC中的AQS引入,讲解Java volatile与AQS锁内存可见性

    juc aqs java

    juc 的aqs介绍。

    Java并发 结合源码分析AQS原理

    Java并发结合源码分析AQS原理 Java并发编程中,AQS(AbstractQueuedSynchronizer)是一个核心组件,它提供了一个基于FIFO队列和状态...通过对AQS的深入了解和源码分析,我们可以更好地理解Java并发编程的机制和原理。

    带你看看Java-AQS同步器 源码解读四 条件队列Condition上

    Java AQS(AbstractQueuedSynchronizer)是一个强大的同步组件,它被广泛应用于并发编程中,如Java的Lock...通过对AQS源码的深入解读,我们可以更好地理解并发编程的底层机制,从而编写出更加高效和健壮的多线程代码。

    深入理解Java中的AQS.docx

    **深入理解Java中的AQS** AbstractQueuedSynchronizer(AQS)是Java并发编程库(java.util.concurrent)中的核心组件,它为实现锁和同步器提供了基础框架。AQS利用了一个内置的FIFO(先进先出)双端队列来管理线程...

Global site tag (gtag.js) - Google Analytics