C'è una coda di blocco corretto (non limitato) in java?

Question

Esiste qualche implementazione della coda di blocco che garantisce l'operazione fair take() se più utenti rimuovono l'elemento dalla stessa coda. Ho controllato LinkedBlockingQueue, LinkedTransferQueue e sembra che entrambi siano ingiusti. ArrayBlockingQueue fornisce operazioni corrette ma è limitato.

Answer 1

PriorityBlockingQueue

Answer 2

politica Equità può essere specificato per SynchronousQueue:

una coda costruito con equità impostato a veri concede le discussioni accesso a FIFO fine

Answer 3

Siamo in grado di realizzare una sconfinata coda di blocco equa utilizzando una coda illimitata come coda ConcurrentLinked e un semaforo equo. La classe seguente non implementa tutti i metodi dall'interfaccia BlockingQueue ma solo alcuni di essi a scopo dimostrativo. Il metodo main() è scritto solo come test.

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; 
    } 
}