有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源码阅读笔记
java锁底层实现,AQS源码分析。我在公司内部分享写的,如果想进一步了解,可以私聊
AQS源码分析一、锁的介绍1.1 乐观锁/悲观锁1.2 共享锁/独占锁1.3 公平锁/非公平锁1.4 小结二、AQS框架结构介绍2.1 类图2.2 AQS数据结构三、源码详解3.1 acquire源码详解3.2 release源码详解四、从ReentranLock看公平...
ReentrantLock Lock 加锁过程源码分析图,AQS 源码分析
Java-AQS同步器 源码解读-条件队列Condition前文为什么需要条件队列Conditon Queue举个小例子分析怎么使用条件队列写个小DemoJDK中是怎么使用的Lock和ConditionLockConditionSync-Queue和Conditian-QueueAQS ...
7、深入理解 AQS 独占锁之 Reentrantlock 源码分析 (1).pdf 8、读写锁ReentrantReadWriteLock&StampLock详解.pdf 9、并发容器 (Map、List、Set) 实战及其原理.pdf 10、阻塞队列BlockingQueue 实战及其原理分析.pdf
aqs同步器&redisson锁
AQS 原理 lock 最 常 用 的 类 就 是 ReentrantLock , 其 底 层 实 现 使 用 的 是 AbstractQueuedSynchronizer(AQS) 简单来说 AQS 会把所有的请求线程构成一个 CLH 队列,当一个线程执行完毕 (lock.unlock())...
java锁AQS基础逻辑
Java并发之AQS详解.pdf
AQS流程图ReentranLock.vsdx
从JUC中的AQS引入,讲解Java volatile与AQS锁内存可见性
最新AQS资料整理,里面知识涉及到AQS所遇到的所有问题,还有视频可以观看,可以帮助大家解惑,可以轻松应对职场问题
juc 的aqs介绍。
解析AbstractQueuedSynchronizer这个类中,锁的获取、释放的相关逻辑。
AQS抽象队列同步器,AQS抽象队列同步器
画图解释加源码分析AQS原理
AQS特性,以及源码流程,常见应用Semaphorer&CountDownLatch&CyclicBarrie
在现代软件开发中,多核处理器的普及使得并发编程成为开发者不可忽视的技能。Java 并发编程中的 JUC(java.util....深入理解和掌握 JUC 和 AQS,可以让开发者更好地应对多线程并发编程中的挑战,提高程序性能和稳定性。