java - 求對ArrayBlockingQueue中一段源碼的解釋
問題描述
為什么take()方法在判斷隊列中元素個數是否為0的時候使用了while循環,而不是if;
我認為,如果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方法
相關文章:
1. node.js - mysql如何通過knex查詢今天和七天內的匯總數據2. mysql 插入數值到特定的列一直失敗3. 360瀏覽器與IE瀏覽器有何區別???4. Python從URL中提取域名5. mysql - 百萬行的表中是否盡量避免使用update等sql語句?6. python - 在使用Pycharm時經常看到如下的樣式,小括號里紅色的部分是什么意思呢?7. javascript - 新浪微博網頁版的字數限制是怎么做的8. 怎么在網頁中設置圖片進行左右滑動9. javascript - 豆瓣的這個自適應是怎么做的?10. javascript - 用jsonp抓取qq音樂總是說回調函數沒有定義
