Being asynchronously notified of a BlockingQueue having an item available
Perhaps you could subclass some BlockingQueue
(such as ArrayBlockingQueue
or LinkedBlockingQueue
or what ever you're using), add support for listeners and do
@Override
public boolean add(E o) {
super.add(o);
notifyListeners(o);
}