AQS 執行緒 續集 喚醒 和 阻塞

2021-10-01 06:12:18 字數 1744 閱讀 8374

接著 搶占式 共享 那裡，當 獲取鎖始終 失敗。

//獲取失敗，執行緒等待--具體後面介紹if(


shouldparkafte***iledacquire


(p, node)


&&parkandcheckinterrupt()


)       interrupted =


true


;
在獲取同步狀態失敗後，執行緒並不是立馬進行阻塞，需要檢查該執行緒的狀態，檢查狀態的方法為 shouldparkafte***iledacquire(node pred, node node) 方法，該方法主要靠前驅節點判斷當前執行緒是否應該被阻塞，**如下：

private


static boolean shouldparkafte***iledacquire


(node pred, node node)


while


(pred.waitstatus >0)


;            pred.next = node;


}//前驅節點狀態為condition、propagate


else


return


false


;}
這段**主要檢查當前執行緒是否需要被阻塞，具體規則如下：

如果當前執行緒的前驅節點狀態為signal，則表明當前執行緒需要被阻塞，呼叫unpark()方法喚醒，直接返回true，當前執行緒阻塞

如果當前執行緒的前驅節點狀態為cancelled（ws >0），則表明該執行緒的前驅節點已經等待超時或者被中斷了，則需要從clh佇列中將該前驅節點刪除掉，直到回溯到前驅節點狀態 <= 0，返回false

如果前驅節點非signal，非cancelled，則通過cas的方式將其前驅節點設定為signal，返回false

如果shouldparkafte***iledacquire(node pred, node node)方法返回true，則呼叫parkandcheckinterrupt()方法阻塞當前執行緒：

private final boolean parkandcheckinterrupt()
parkandcheckinterrupt()方法主要是把當前執行緒掛起，從而阻塞住執行緒的呼叫棧，同時返回當前執行緒的中斷狀態。其內部則是呼叫locksupport工具類的park()方法來阻塞該方法。 當執行緒釋放同步狀態後，則需要喚醒該執行緒的後繼節點：

public final boolean release


(int arg)


return


false


;}
喚醒 需要 呼叫 unpark.

private


void


unparksuccessor


(node node)


//喚醒後繼節點


if(s != null)


locksupport.


unpark


(s.thread)


;}
可能會存在當前執行緒的後繼節點為null，超時、被中斷的情況，如果遇到這種情況了，則需要跳過該節點，但是為何是從tail尾節點開始，而不是從node.next開始呢？原因在於node.next仍然可能會存在null或者取消了，所以採用tail回溯辦法找第乙個可用的執行緒。最後呼叫locksupport的unpark(thread thread)方法喚醒該執行緒。

面試題 3種執行緒阻塞喚醒的對比

wait notify author wgr create 2020 12 29 0 28 public class test6 catch interruptedexception e system.out.println thread.currentthread getname 被喚醒 當a先睡...

面試題 3種執行緒阻塞喚醒的對比

wait notify author wgr create 2020 12 29 0 28 public class test6 catch interruptedexception e system.out.println thread.currentthread getname 被喚醒 當a先睡...

python 阻塞執行緒和守護執行緒

一 執行緒的建立 threading.thread建立乙個執行緒，返回乙個物件，用變數接收 變數.start啟動執行緒 coding utf 8 author 2022 5 10 gil 全域性直譯器鎖，只允許 同一時間只允許1個執行緒進入cpu，所以cpython中沒有並行，是併發 import ...