Java PriorityQueue等待

Question

我正試圖通過使用多線程的Java解決Java編寫器偏好的讀寫器問題。以下是我的代碼的簡化版本。它會起作用嗎？

public PriorityQueue<myClass> pq; 
public void foo(){ 
    myClass obj = new myClass(); 
    pq.add(obj); 
    obj.wait(); 
    //Actual code 
} 
public void bar(){ 
    pq.remove().notify(); 
} 

假設優先級隊列pq最初是空的，並且封裝類的構造函數調用pq的構造函數。另外，先調用foo，然後調用bar。所以當foo被調用時，它將obj添加到隊列中，併成爲前端元素，以便在刪除的元素bar中調用remove時。我的問題是，是否會執行「實際代碼」？還是我在兩個完全不同的對象上執行wait（）和notify（）？如果是這樣，我該如何解決？

Answer 1

你應該注意到PriorityQueue不是線程安全的......即，如果同時調用foo和/或bar，它們可能會不可避免地破壞pq的內部狀態。

Answer 2

我仍然試圖解析你的問題，到目前爲止我可以提取的是，你想實現一個優先隊列myClass，展示作家偏好。 Java的現成鎖定不提供嚴格的作者偏好，但如果您確定（可能是最好的），並使用近似的作者偏好，則可以在正常模式下使用正常的ReentrantReadWriteLock。

寫完所有這些（並考慮了它可能出錯的多種方式）我真的很想知道爲什麼java.util.concurrent的PriorityBlockingQueue實現不符合您的需要。

以下代碼遠未經過測試，但通過了我的1:00 AM嗅探測試。

private final PriorityQueue<myClass> pq = ...; 
// associated RW lock, in fair mode (==true) 
private final ReadWriteLock pqLock = new ReentrantReadWriteLock(true);  
private final Condition pqWriteCondition = pqLock.writeLock().newCondition();  

public void produceNew() 
{ 
    myClass obj = new myClass(); 
    pqLock.writeLock.lock(); 
    try { 
     pq.offer(obj); 
     pqWriteCondition.notifyAll(); 
    } finally { 
     pqLock.writeLock.unlock(); 
    } 
    //Actual code 
} 

public void consumeFirst() { 
    myClass consume = null; 
    pqLock.readLock.lock(); 
    try { 
     consume = pq.poll(); 
     while (consume == null) { 
     pqWriteCondition.wait(); 
     consume = pq.poll(); 
     } 
    } finally { 
     pqLock.readLock.unlock(); 
    } 
    //Actual code 

}