java基础----AQS---acquireQueued详解
2022/7/22 2:00:12
本文主要是介绍java基础----AQS---acquireQueued详解,对大家解决编程问题具有一定的参考价值,需要的程序猿们随着小编来一起学习吧!
1. 假设有A、B、C三个线程同时执行,A线程获取到了锁,并且一直持有中。 2. B线程执行,获取锁失败会被加到等待队列中,因为此时队列为空,则建立空节点head,同时B线程添加节点到队列中,作为第一个等待的节点,所以此时队列中有两个节点,头节点和B节点,他们的等待状态都是0。 3. B在acquireQueued方法中,for循环尝试获取锁,他的前驱是头节点,但是获取锁失败,此时运行到shouldParkAfterFailedAcquire,在这个方法中,判断B线程的前驱节点(就是头节点)的等待状态,发现是0, 那么会把它设置为-1(标示SIGNAL);返回false以后,再次尝试去获取锁,再次失败以后再次进入到shouldParkAfterFailedAcquire,此时前驱节点状态是-1,那么就会park线程B。 4. C也同样在acquireQueued获取锁失败后被加到B节点后面,执行shouldParkAfterFailedAcquire,B节点的状态是0,那么C也会在把B状态设置为-1以后返回false继续尝试获取锁,失败以后在进入shouldParkAfterFailedAcquire ,此时前驱B节点状态是-1,那么C也会被挂起。 5. 如果后面还有线程D、E、F都会这样。 6. 直到A释放锁以后,他会唤醒等待队列中head以后第一个节点,就是B节点,B节点醒来继续for循环当中的获取锁,因为此时A已经释放锁,那么B可以获取锁成功,他会把自己设置为头节点。线程设为空,前驱设为空。 7. B执行完以后也会释放锁,唤醒他后面的节点,就是C,C再获取锁继续执行。 8. D、E、F也都如此。
final boolean acquireQueued(final Node node, int arg) { boolean failed = true; try { boolean interrupted = false; for (;;) { final Node p = node.predecessor(); if (p == head && tryAcquire(arg)) { setHead(node); p.next = null; // help GC failed = false; return interrupted; } if (shouldParkAfterFailedAcquire(p, node) && parkAndCheckInterrupt()) interrupted = true; } } finally { if (failed) cancelAcquire(node); } }
此方法是在获取锁失败以后判断是否需要park的方法,非常重要,所有的获取锁的方法都需要调用的:
private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) { int ws = pred.waitStatus; if (ws == Node.SIGNAL) //前驱节点状态判断是SIGNAL,那么说明本节点需要被唤醒,返回true,这里返回true以后就能运行后面的parkAndCheckInterrupt方法。
/* * This node has already set status asking a release * to signal it, so it can safely park. */ return true; if (ws > 0) {//说明前驱节点是取消状态,则往前遍历,直到找到前驱几点状态是非取消的节点为止。返回false,不park,继续尝试获取锁。如果获取失败再次进入到次方法中,如果是signal那么就执行上面逻辑,如果是其他小于等于0执行下面的逻辑 /* * Predecessor was cancelled. Skip over predecessors and * indicate retry. */ do { node.prev = pred = pred.prev; } while (pred.waitStatus > 0); pred.next = node; } else {//说名前驱状态是0或者是传播模式。那么设置前驱节点状态是signal,返回false,不park。继续尝试获取锁。 /* * waitStatus must be 0 or PROPAGATE. Indicate that we * need a signal, but don't park yet. Caller will need to * retry to make sure it cannot acquire before parking. */ compareAndSetWaitStatus(pred, ws, Node.SIGNAL); } return false; }
这篇关于java基础----AQS---acquireQueued详解的文章就介绍到这儿,希望我们推荐的文章对大家有所帮助,也希望大家多多支持为之网!
- 2024-05-09“2024鸿蒙零基础快速实战-仿抖音App开发(ArkTS版)”实战课程已上线
- 2024-05-09聊聊如何通过arthas-tunnel-server来远程管理所有需要arthas监控的应用
- 2024-05-09log4j2这么配就对了
- 2024-05-09nginx修改Content-Type
- 2024-05-09Redis多数据源,看这篇就够了
- 2024-05-09Google Chrome驱动程序 124.0.6367.62(正式版本)去哪下载?
- 2024-05-09有没有大佬知道这种数据应该怎么抓取呀?
- 2024-05-09这种运行结果里的10.100000001,怎么能最快改成10.1?
- 2024-05-09企业src漏洞挖掘-有意思的命令执行
- 2024-05-08阿里云域名注册流程,分享给第一次购买域名的新手站长!