av一区二区在线观看_亚洲男人的天堂网站_日韩亚洲视频_在线成人免费_欧美日韩精品免费观看视频_久草视

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

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

瀏覽:113日期: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
相關文章:
主站蜘蛛池模板: 香蕉视频色版 | 国产视频一区在线播放 | 国产伦精品一区二区三区视频网站 | 久久久久久久久国产精品 | 成人在线观看网站 | 欧美一级片免费观看 | 国产草草影院 | 欧美色综合网 | 极品美女一区二区三区 | 日韩在线精品视频 | 免费a视频 | 午夜视频成人 | 精品一二三区 | 日本一本草久p | 国产精品99精品久久免费 | 免费一看一级毛片 | 欧美日韩精品一区二区 | 国产日韩中文字幕 | 日韩成人在线播放 | 久久久一本 | 天天操一操 | 五月婷婷在线播放 | 一区二区三区四区在线视频 | 亚洲精品小视频 | 91久久久久久久久 | 999久久久国产精品 亚洲黄色三级 | 九九热精品 | 亚洲va视频 | 久久久久久久网 | av天天干| 三级黄色片免费看 | 高潮毛片无遮挡免费看 | 91av免费观看 | 午夜在线免费观看 | 日韩性生活视频 | 成人一区二区在线 | 91女人18毛片水多国产 | 人人爽夜夜爽 | 久久久在线视频 | 精品一区二区三区免费 | 欧美国产一区二区 |