Będąc asynchronicznie powiadamiane o BlockingQueue posiadające element dostępny

Question

Potrzebuję Object, aby być asynchronicznie powiadamiany, gdy niektóre BlockingQueue ma przedmiotu do podania.

Rozglądałem zarówno Javadoc oraz w internecie na pre-made roztworze, a następnie skończyło się z (być może naiwne) roztworu kopalni, to jest tutaj:

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

i

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) { 
      } 
     } 
    } 
} 

Zasadniczo, jest to wątek blokowania na take() funkcjonowania kolejki wywołań zwrotnych że obiekt słuchacza każdym razem operacja take() powiedzie, ewentualnie odesłanie specjalną cookie obiekt (zignorować, jeśli chcesz).

Pytanie brzmi: czy istnieje lepszy sposób na zrobienie tego? Czy popełniam niewybaczalny błąd (zarówno pod względem współbieżności/wydajności i/lub czystości kodu)? Z góry dziękuję.

Answer 1

Może podklasy niektóre BlockingQueue (takich jak ArrayBlockingQueue lub LinkedBlockingQueue czy co tam używasz), dodać wsparcie dla słuchaczy i czy

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

Answer 2

Wygląda to na dobry standardowy wzorzec blokowania i słuchania kolejki. Dokonujesz dobrego wyboru, tworząc interfejs słuchacza. Jeśli nie korzystasz z klasy BlockingQueue (której nie znam), jedyną rzeczą, którą masz do zarządzania, jest poprawne wait() i notify() zarządzanie połączeniem blokującym.

Ten szczególny SO Pytanie "A simple scenario using wait() and notify() in java" zapewnia dobry przegląd na oczekiwania i powiadomić i korzystanie związane BlockingQueue