国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-a级毛片无码免费真人-a级毛片毛片免费观看久潮喷

您的位置:首頁技術文章
文章詳情頁

java - 求對ArrayBlockingQueue中一段源碼的解釋

瀏覽:106日期:2023-11-16 10:11:21

問題描述

為什么take()方法在判斷隊列中元素個數是否為0的時候使用了while循環,而不是if;

java - 求對ArrayBlockingQueue中一段源碼的解釋

我認為,如果notEmpty.await()方法既然蘇醒返回了 ,那么此線程肯定拿到了lock。

而蘇醒的原因也是因為put()方法放入了新的元素,而其他線程無法拿到鎖,自然無法取走元素,那么此時對于拿到鎖的線程來說count肯定不為0了,應該放心的執行 dequeue()獲取元素就可以了。 不知道作者使用了while是何意呢?

問題解答

回答1:

“notEmpty.await()方法既然蘇醒返回了 ,那么此線程肯定拿到了 lock” 這句話是正確的。

假設你寫的代碼是:

if (count == 0) notEmpty.await();

可以明確的一點就是我們需要保證在 return dequeue() 之前需要滿足的一個條件是 count != 0。我們假設 線程A 此時拿到了 lock,那么 線程A 的 notEmpty.await() 此時便會停止阻塞,準備向下執行 return dequeue()。但是假設在競爭激烈的條件下,線程A 拿到 lock 之后,準備執行下一條 JVM 指令的時候,線程B 此時搶占了 lock,然后繼續向下執行 return dequeue(),剛好使得 count 變為了 0;而此時因為寫的只是 if(count == 0),那么線程 A 在拿到 lock 之后,還是會繼續向下執行 return dequeue(),從而導致了錯誤。

關于為什么wait()、await() 這樣當條件不滿足時就阻塞的方法一定要在 while 循環中使用,可以參考《Effective Java》第二版第 69 條(244 頁)。

回答2:

public ArrayBlockingQueue(int capacity, boolean fair) { if (capacity <= 0)throw new IllegalArgumentException(); this.items = new Object[capacity]; lock = new ReentrantLock(fair); notEmpty = lock.newCondition(); //notEmpty 就是這個鎖的條件 notFull = lock.newCondition();}

所以在你這段代碼里當前隊列為空時(count==0),調用了notEmpty.await(),這段代碼對鎖是有影響的,實際上底層上已經釋放了鎖,只是這個方法保證了被喚醒時一定又能夠拿回鎖(當有元素放入隊列會調用notEmpty.signal()進行喚醒),那為什么需要使用while呢?因為insert后lock.unlock,未必notEmpty.await()立即被喚醒,可能之前插入一個線程運行remove方法

標簽: java
相關文章:
主站蜘蛛池模板: 亚洲一区免费在线 | 一级黄色大片 | 国产乱子伦在线观看不卡 | 成人国产一区二区三区精品 | 日韩在线播放中文字幕 | 日本欧美亚洲 | 91成人在线免费观看 | 国产精品夜色视频一级区 | 全免费a级毛片免费看 | 日本一级aaaa特黄毛片 | 久久精品国产一区二区三区日韩 | 手机在线毛片 | 久久精品中文字幕免费 | 亚洲一区二区三区在线网站 | 国产欧美日韩亚洲精品区2345 | 欧美老妇69交 | 日韩久久一级毛片 | 国产成人亚洲合集青青草原精品 | 国产在线激情视频 | 久久亚洲不卡一区二区 | 国产亚洲精品自在线观看 | 国产国产人免费人成成免视频 | 日本xxxxxxx69xx| 亚洲国产精品久久久久666 | 俄罗斯a级毛片 | 欧美特级午夜一区二区三区 | 午夜香蕉成视频人网站高清版 | 久久99久久精品国产只有 | 久久爽久久爽久久免费观看 | 精品在线免费视频 | 欧美猛交xxxx免费看 | 久久亚洲成人 | 99视频在线精品 | 波多野结衣在线不卡 | 久久精品最新免费国产成人 | 久久久综合视频 | 久久久国产精品网站 | 亚洲欧美日韩综合二区三区 | 天天躁天天碰天天看 | 老人久久www免费人成看片 | 黄色美女网站免费看 |