AQS同步队列CLH中5种节点状态
1、CANCELLED(1):表示当前结点已取消调度。当timeout或被中断(响应中断的情况下),会触发变更为此状态,进入该状态后的结点将不会再变化。
2、SIGNAL(-1):表示后继结点在等待当前结点唤醒。后继结点入队时,会将前继结点的状态更新为SIGNAL。
3、CONDITION(-2):表示结点等待在Condition上,当其他线程调用了Condition的signal()方法后,CONDITION状态的结点将从等待队列转移到同步队列中,等待获取同步锁。
4、PROPAGATE(-3):共享模式下,前继结点不仅会唤醒其后继结点,同时也可能会唤醒后继的后继结点。
5、0:新结点入队时的默认状态。
acquire方法流程
独占锁为例,非公平锁为例,一个线程尝试获取锁的acquire方法流程。 1、首先调用tryAcquire获取锁,获取成功则返回,失败则调用addWaiter新建一个node节点添加到链表尾部
2、addWaiter逻辑是先通过cas进行添加到链表尾部,添加成功则返回node,添加失败则通过 循环+cas的方式,直到添加成功,再返回node
3、调用acquireQueued使当前node进入自旋,首先拿到当前节点的前驱节点prev,判断前驱节点prev是否是头节点head,如果是则通过tryAcquire尝试获取锁,获取成功,则把当前节点设置为头head节点,并返回。
4、如果前驱节点prev不是头节点head,或者通过tryAcquire尝试获取锁失败,则通过shouldParkAfterFailedAcquire方法,检查是否需要通过park()进入waiting状态,直到被unpark()。
5、如果需要进入waiting状态,则通过parkAndCheckInterrupt方法进入waiting状态,并检查中断标记。
6、shouldParkAfterFailedAcquire方法,首先拿到前驱的状态。 6.1、如果前驱节点的状态为SIGNAL,则当前节点需要进入waiting状态。 6.2、如果前驱节点状态大于0(也就是CANCELLED取消状态),那就一直往前找,直到找到最近一个正常等待的状态,并排在它的后边。这时被取消的节点就不会被链表中的节点引用而被GC回收。 6.3、否则把前驱节点的状态设置为SIGNAL状态。 6.4、总结:当前驱节点是SIGNAL状态时,当前节点需要进入waiting状态。当前驱节点不是SIGNAL状态时,需要找到一个SIGNAL状态的node节点,排在他后面。
7、parkAndCheckInterrupt方法,调用LockSupport.park方法进入waiting状态。
总结具体流程
结点进入队尾后,检查状态,找到安全休息点; 调用park()进入waiting状态,等待unpark()或interrupt()唤醒自己; 被唤醒后,看自己是不是有资格能拿到号。如果拿到,head指向当前结点,并返回从入队到拿到号的整个过程中是否被中断过;如果没拿到,继续流程1。
|