我想每當我們在隊列中添加元素時，我應該調用一個方法來在隊列中添加元素后立即獲取。package com.java.listner;import java.util.LinkedList;import java.util.Queue;public class QueueListner {public static Queue<String> queue=new LinkedList<String>(); public boolean add(String e) { itemAvailableInqueue(); return false; } public static void main(String[] args) { queue.add("record1"); System.out.println(queue.poll()); } public void itemAvailableInqueue() { int size = queue.size(); for (int i = 1; i < size; i++) { System.out.println(queue.poll()); } }}
1 回答
繁星coding
TA貢獻1797條經驗 獲得超4個贊
要將監聽器添加到隊列中，您需要使其“可監聽”，最簡單的方法是裝飾器模式。此模式的目標是在類中添加特性，同時保留其基本功能。
在 的情況下Queue，您只需擴展一個AbstractQueue類，覆蓋它的offer方法。其他方法只是委托給后備隊列，因為它們不需要通知偵聽器。
public class ListenableQueue<E> extends AbstractQueue<E> {
interface Listener<E> {
void onElementAdded(E element);
}
private final Queue<E> delegate; // backing queue
private final List<Listener<E>> listeners = new ArrayList<>();
public ListenableQueue(Queue<E> delegate) {
this.delegate = delegate;
}
public ListenableQueue<E> registerListener(Listener<E> listener) {
listeners.add(listener);
return this;
}
@Override
public boolean offer(E e) {
// here, we put an element in the backing queue,
// then notify listeners
if (delegate.offer(e)) {
listeners.forEach(listener -> listener.onElementAdded(e));
return true;
} else {
return false;
}
}
// following methods just delegate to backing instance
@Override public E poll() { return delegate.poll(); }
@Override public E peek() { return delegate.peek(); }
@Override public int size() { return delegate.size(); }
@Override public Iterator<E> iterator() { return delegate.iterator(); }
}
因此，此ListenableQueue實現Queue接口具有Queue考慮支持委托隊列屬性的所有功能（即容量限制、阻塞行為等），因此可以像任何其他Queue.
使用示例：
// we create new `LinkedList` as a backing queue and decorate it
ListenableQueue<String> q = new ListenableQueue<>(new LinkedList<>());
// register a listener which polls a queue and prints an element
q.registerListener(e -> System.out.println(q.poll()));
// voila!
q.add("record1");
添加回答
舉報
0/150
提交
取消