01: package com.icesoft.faces.webapp.http.core;
02:
03: import edu.emory.mathcs.backport.java.util.concurrent.LinkedBlockingQueue;
04:
05: public class ViewQueue extends LinkedBlockingQueue {
06: private Runnable listener;
07:
08: public void onPut(Runnable listener) {
09: this .listener = listener;
10: }
11:
12: public void put(Object object) throws InterruptedException {
13: if (!contains(object)) {
14: super.put(object);
15: }
16: listener.run();
17: }
18: }
|