Condition的await()方法
生活随笔
收集整理的這篇文章主要介紹了
Condition的await()方法
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
public final void await() throws InterruptedException {if (Thread.interrupted())throw new InterruptedException();Node node = addConditionWaiter();//釋放同步狀態(鎖)int savedState = fullyRelease(node);int interruptMode = 0;//判斷節點是否放入同步對列while (!isOnSyncQueue(node)) {//阻塞LockSupport.park(this);//如果已經中斷了,則退出if ((interruptMode = checkInterruptWhileWaiting(node)) != 0)break;}if (acquireQueued(node, savedState) && interruptMode != THROW_IE)interruptMode = REINTERRUPT;if (node.nextWaiter != null) // clean up if cancelledunlinkCancelledWaiters();if (interruptMode != 0)reportInterruptAfterWait(interruptMode);
}
將當前線程創建為節點,加入等待隊列; 釋放鎖,喚醒同步隊列中的后繼節點; while循環判斷節點是否放入同步隊列:
退出 while 說明節點已經在同步隊列中,調用 acquireQueued() 方法加入同步狀態競爭。 競爭到鎖后從 await() 方法返回,即退出該方法。
分析上述方法的大概過程:
- 沒有放入,則阻塞,繼續 while 循環(如果已經中斷了,則退出)
- 放入,則退出 while 循環,執行后面的判斷
總結
以上是生活随笔為你收集整理的Condition的await()方法的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: HashMap中hash函数怎么是实现的
- 下一篇: 转发网关