¿Hay alguna cola de bloqueo de la feria (ilimitada) en java?

Question

¿Existe alguna implementación de la cola de bloqueo que garantice la operación fair take() si varios consumidores están eliminando elementos de la misma cola? Comprobé LinkedBlockingQueue, LinkedTransferQueue y parece que ambos son injustos. ArrayBlockingQueue proporciona una operación justa pero limitada.

Answer 1

PriorityBlockingQueue

Answer 2

política de imparcialidad se puede especificar para SynchronousQueue:

una cola construido con equidad establece a verdaderas subvenciones hilos de acceso en FIFO fin

Answer 3

Podemos implementar una ilimitada cola de bloqueo justo utilizando una cola ilimitada como la cola ConcurrentLinked y un semáforo justo. La siguiente clase no implementa todos los métodos desde la interfaz BlockingQueue, sino solo algunos con fines de demostración. El método main() se escribe solo como prueba.

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