shouldParkAfterFailedAcquire
如果ThreadA的鎖還沒有釋放的情況下,ThreadB和ThreadC來爭搶鎖肯定是會失敗,那么失敗以后會調(diào)用shouldParkAfterFailedAcquire方法
Node有5中狀態(tài),分別是:CANCELLED(1),SIGNAL(-1)、CONDITION(-2)、PROPAGATE(-3)、默認狀態(tài)(0)
CANCELLED:?在同步隊列中等待的線程等待超時或被中斷,需要從同步隊列中取消該Node的結(jié)點,?其結(jié)點的waitStatus為CANCELLED,即結(jié)束狀態(tài),進入該狀態(tài)后的結(jié)點將不會再變化
SIGNAL:?只要前置節(jié)點釋放鎖,就會通知標識為SIGNAL狀態(tài)的后續(xù)節(jié)點的線程
CONDITION:?和Condition有關系,后續(xù)會講解
PROPAGATE:共享模式下,PROPAGATE狀態(tài)的線程處于可運行狀態(tài)
0:初始狀態(tài)
這個方法的主要作用是,通過Node的狀態(tài)來判斷,ThreadA競爭鎖失敗以后是否應該被掛起。?
1. 如果ThreadA的pred節(jié)點狀態(tài)為SIGNAL,那就表示可以放心掛起當前線程
2. 通過循環(huán)掃描鏈表把CANCELLED狀態(tài)的節(jié)點移除
3. 修改pred節(jié)點的狀態(tài)為SIGNAL,返回false.?
返回false時,也就是不需要掛起,返回true,則需要調(diào)用parkAndCheckInterrupt掛起當前線程
private static boolean shouldParkAfterFailedAcquire(Node pred, Node node) { int ws = pred.waitStatus;//前置節(jié)點的waitStatus if (ws == Node.SIGNAL)//如果前置節(jié)點為SIGNAL,意味著只需要等待其他前置節(jié)點的線程被釋放, return true;//返回true,意味著可以直接放心的掛起了 if (ws > 0) {//ws大于0,意味著prev節(jié)點取消了排隊,直接移除這個節(jié)點就行 do { node.prev = pred = pred.prev; //相當于: pred=pred.prev; node.prev=pred; } while (pred.waitStatus > 0); //這里采用循環(huán),從雙向列表中移除CANCELLED的節(jié)點 pred.next = node; } else {//利用cas設置prev節(jié)點的狀態(tài)為SIGNAL(-1) compareAndSetWaitStatus(pred, ws, Node.SIGNAL); } return false; }?
總結(jié)
以上是生活随笔為你收集整理的shouldParkAfterFailedAcquire的全部內(nèi)容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: NofairSync.tryAcquir
- 下一篇: parkAndCheckInterrup