ReentrantLock是如何基于AQS实现的VIP

1、reentrantlock是如何基于aqs实现的reentrantlock是一个可重入的互斥锁，基于aqs实现，它具有与用法 synchronized 办法和语句相同的一些基本行为和语义，但功能更强大。lock和unlockreentrantlock 中举行同步操作都是从lock办法开头。lock猎取锁，举行一系列的业务操作，结束后用法unlock释放锁。private final reentrantlock lock = new reentrantlock（）;public void sync（）lock.lock（）;try / method body finally lock.unloc

2、k（）lockreentrantlock 中lock的实现是通过调用aqs的 abstractqueuedsynchronizeracquire 办法实现。public final void acquire（int arg） /尝试猎取锁if （！tryacquire（arg） &&acquirequeued（addwaiter（node.exclusive）， arg）selfinterrupt（）;按照之前介绍的模板办法模式，对于锁的猎取tryacquire是在reentrantlock中实现的。而非公正锁中的实际实现办法为nonfairtryacquire。reentra

3、ntlocknonfairtryacquireprotected final boolean tryacquire（int acquires） return nonfairtryacquire（acquires）;final boolean nonfairtryacquire（int acquires） final thread current = thread.currentthread（）;int c = getstate（）;if （c = 0） if （compareandsetstate（0, acquires） setexclusiveownerthread（current）;re

4、turn true;else if （current = getexclusiveownerthread（） int nextc = c + acquires;if （nextc 0） do node.prev = pred = pred.prev; while （pred.waitstatus 0）;pred.next = node; else compareandsetwaitstatus（pred, ws, node.signal）;return false;推断一个节点是否需要被堵塞是通过该节点的前继节点的状态推断的。假如前继节点状态为 singal ，则表示前继节点还在等待，当前节点

5、需要继续被堵塞。返回true。假如前继节点大于0，则表示前继节点为取消状态。取消状态的节点不参加锁的竞争，挺直跳过。返回false。假如前继节点时其他状态（0,propagate），不举行堵塞，表示当前节点需要重试尝试猎取锁。返回false。shouldparkafterfailedacquire办法假如返回true，表示需要将当前节点堵塞，堵塞办法为parkandcheckinterrupt。abstractqueuedsynchronizerparkandcheckinterruptprivate final boolean parkandcheckinterrupt（） locksupp

6、ort.park（this）;return terrupted（）;堵塞是通过locksupport举行堵塞，被堵塞的节点不参加锁的竞争（不在举行循环猎取锁），只能被unpark后才继续竞争锁。而被堵塞的节点要被释放则依靠于unlock办法。unlockreentrantlock 中unlock的实现是通过调用aqs的 abstractqueuedsynchronizerrelease 办法实现。public final boolean release（int arg） if （tryrelease（arg） node h = head;if （h != null &

7、& h.waitstatus != 0）unparksuccessor（h）;return true;return false;release调用tryrelease办法，tryrelease是在 reentrantlock 中实现。reentrantlocktryreleaseprotected final boolean tryrelease（int releases） int c = getstate（） - releases;if （thread.currentthread（） != getexclusiveownerthread（）throw new illegalmonit

8、orstateexception（）;boolean free = false;if （c = 0） free = true;setexclusiveownerthread（null）;setstate（c）;return free;tryrelease办法规律很容易，首先减去releases（普通为1）表示释放一个锁，假如释放后state=0表示释放锁胜利，后续等待的节点可以猎取该锁了。假如state!=0则表示该锁为重入锁，需要多次释放。当释放锁胜利后（state=0），会对头结点的后继节点举行unpark。abstractqueuedsynchronizerunparksuccessor

9、private void unparksuccessor（node node） int ws = node.waitstatus;if （ws 0） s = null;for （node t = tail; t != null && t != node; t = t.prev）if （t.waitstatus 0的节点）。公正锁和非公正锁reentrantlock 的构造办法接受一个可选的公正参数。当设置为 true 时，在多个线程的竞争时，倾向于将锁分配给等待时光最长的线程。public reentrantlock（boolean fair） sync = fair ? ne

10、w fairsync（） : new nonfairsync（）;在多个锁竞争统一资源的环境下，aqs维护了一个等待队列，未能猎取到锁的线程都会被挂到该队列中。假如用法公正锁则会从队列的头结点开头猎取该资源。而按照代码在公正锁和非公正锁的实现的差别仅仅在于公正锁多了一个检测的办法。公正锁protected final boolean tryacquire（int acquires） /if （c = 0） if （！hasqueuedpredecessors（） /!hasqueuedpredecessors（）便是比非公正锁多出来的操作&& compareandsetstate（0, acquires） setexclusiveownerthread（current）;return true;/return false;hasqueuedpredecessors（）public final boolean hasqueuedpredecessors（） node t = tail; / read fields in reverse initialization ordernode h