क्या जावा में कोई भी (असंबद्ध) मेला अवरुद्ध कतार है?

Question

क्या ब्लॉकिंग कतार का कोई कार्यान्वयन है जो निष्पक्ष ले() ऑपरेशन की गारंटी देता है यदि एकाधिक उपभोक्ता एक ही कतार से तत्व को हटा रहे हैं। मैंने LinkedBlockingQueue, LinkedTransferQueue की जांच की और ऐसा लगता है कि उनमें से दोनों अनुचित हैं। ArrayBlockingQueue निष्पक्ष ऑपरेशन प्रदान करता है लेकिन इसकी बाध्यता है।

Answer 1

PriorityBlockingQueue

Answer 2

निष्पक्षता नीति SynchronousQueue लिए निर्दिष्ट किया जा सकता है:

एक कतार निष्पक्षता के साथ निर्माण किया फीफो क्रम में सही अनुदान के लिए सेट का उपयोग कर सकते धागे

Answer 3

हम एक असीम लागू कर सकते हैं कंसूरेंट लिंक्ड कतार और एक निष्पक्ष सेमफोर जैसी असंबद्ध कतार का उपयोग करके निष्पक्ष अवरुद्ध कतार। नीचे दी गई कक्षा ब्लॉकिंग क्यूई इंटरफेस से सभी विधियों को लागू नहीं करती है, लेकिन प्रदर्शन उद्देश्यों के लिए उनमें से कुछ ही। मुख्य() विधि केवल एक परीक्षण के रूप में लिखा जाता है।

public class FairBlockingQueue<T> { 

    private final Queue<T> queue; 
    private final Semaphore takeSemaphore; 

    public FairBlockingQueue() { 
     queue = new ConcurrentLinkedQueue<T>(); 
     takeSemaphore = new Semaphore(0, true); 
    } 

    public FairBlockingQueue(Collection<T> c) { 
     queue = new ConcurrentLinkedQueue<T>(c); 
     takeSemaphore = new Semaphore(c.size(), true); 
    } 

    public T poll() { 
     if (!takeSemaphore.tryAcquire()) { 
      return null; 
     } 
     return queue.poll(); 
    } 

    public T poll(long millis) throws InterruptedException { 
     if (!takeSemaphore.tryAcquire(millis, TimeUnit.MILLISECONDS)) { 
      return null; 
     } 
     return queue.poll(); 
    } 

    public T take() throws InterruptedException { 
     takeSemaphore.acquire(); 
     return queue.poll(); 
    } 

    public void add(T t) { 
     queue.add(t); 
     takeSemaphore.release(); 
    } 

    public static void main(String[] args) throws Exception { 
     FairBlockingQueue<Object> q = new FairBlockingQueue<Object>(); 
     Object o = q.poll(); 
     assert o == null; 
     o = q.poll(1000); 
     assert o == null; 

     q.add(new Object()); 
     q.add(new Object()); 
     q.add(new Object()); 

     o = q.take(); 
     assert o != null; 
     o = q.poll(); 
     assert o != null; 
     o = q.poll(1000); 
     assert o != null; 

     o = q.poll(); 
     assert o == null; 
    } 
}