我需要一个 Object
在某些时候被异步通知 BlockingQueue
有一个项目给。
我已经搜索了Javadoc和网络上的预制解决方案,然后我最终得到了一个(也许是天真的)我的解决方案,这里是:
interface QueueWaiterListener<T> {
public void itemAvailable(T item, Object cookie);
}
和
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) {
}
}
}
}
基本上,有一个线程阻塞 take()
每次调用一个侦听器对象的队列的操作 take()
操作成功,可选择发回一个特殊的 cookie
对象(如果你愿意,可以忽略它)。
问题是:有没有更好的方法呢?我是否在做一些不可原谅的错误(在并发/效率和/或代码清洁方面)?提前致谢。