国产成人精品久久免费动漫-国产成人精品天堂-国产成人精品区在线观看-国产成人精品日本-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级特黄的片子视频免费 | 久久99热精品免费观看欧美 | 免费国产不卡午夜福在线观看 | 久久99综合国产精品亚洲首页 | 香港一级特黄高清免费 | 国产伦理久久精品久久久久 | 99er精品| 久久综合精品国产一区二区三区无 | 日本黄色美女网站 | 免费国产一区二区在免费观看 | 欧美色欧美色 | 久久久精品久久久久久久久久久 | 美女操男人 | 国产成人午夜极速观看 | 91精品视频在线播放 | 男女性男女刺激大片免费观看 | 欧美精品亚洲人成在线观看 | 九草在线视频 | 中国一级淫片aaa毛片毛片 | 日韩性黄色一级 | 国产一区二区三区在线视频 | 精品久久久久国产免费 | 一个人的视频日本免费 | 狼伊千合综网中文 | 日韩美女爱爱 | 亚洲波多野结衣日韩在线 |