Notifica asincrona di un BlockingQueue con un articolo disponibile

Question

Ho bisogno di un Object per essere avvisato in modo asincrono quando alcuni BlockingQueue hanno un articolo da fornire.

Ho cercato sia Javadoc e il web per una soluzione pre-fatto, quindi ho finito con una soluzione (forse ingenua) di mine, qui è:

interface QueueWaiterListener<T> { 
    public void itemAvailable(T item, Object cookie); 
} 

e

class QueueWaiter<T> extends Thread { 

    protected final BlockingQueue<T> queue; 
    protected final QueueWaiterListener<T> listener; 
    protected final Object cookie; 

    public QueueWaiter(BlockingQueue<T> queue, QueueWaiterListener<T> listener, Object cookie) { 
     this.queue = queue; 
     this.listener = listener; 
     this.cookie = cookie; 
    } 

    public QueueWaiter(BlockingQueue<T> queue, QueueWaiterListener<T> listener) { 
     this.queue = queue; 
     this.listener = listener; 
     this.cookie = null; 
    } 

    @Override 
    public void run() { 
     while (!isInterrupted()) { 
      try { 
       T item = queue.take(); 
       listener.itemAvailable(item, cookie); 
      } catch (InterruptedException e) { 
      } 
     } 
    } 
} 

Fondamentalmente, c'è un blocco di thread su un'operazione take() di una coda che richiama un oggetto listener ogni volta che un'operazione take() riesce, facoltativamente inviando un oggetto speciale cookie (ignorarlo se lo si desidera).

La domanda è: c'è un modo migliore per farlo? Sto facendo un errore imperdonabile (sia in concorrenza/efficienza e/o pulizia del codice)? Grazie in anticipo.

Answer 1

forse si potrebbe creare una sottoclasse qualche BlockingQueue (come ArrayBlockingQueue o LinkedBlockingQueue o che cosa mai si sta utilizzando), aggiungere il supporto per gli ascoltatori e fare

@Override 
public boolean add(E o) { 
    super.add(o); 
    notifyListeners(o); 
} 

Answer 2

Questo sembra un buon modello standard per il blocco delle code e gli ascoltatori. Fai una buona scelta di fare l'interfaccia del listener. Se non si utilizza la classe BlockingQueue (di cui non sono a conoscenza), l'unica cosa che si ha è la corretta wait() e notify() per la gestione della chiamata di blocco.

Questo particolare SO Domanda "A simple scenario using wait() and notify() in java" offre una buona panoramica su attesa e notificare e l'uso relative al BlockingQueue