- }
-
- final public void queue(T item) {
- synchronized(items) {
- items.addLast(item);
- // TODO: implement flags/logic in ExternalRead to state that all but the latest request result can be evaporated
- // In some cases where data is produced really fast this might be necessary but currently this queueing will do.
- }
- }
-
- final public void addOrSet(QueryProcessor processor, Object item) {
-
- try {
-
- assert(isPending());
-
- //ArrayList<Procedure<T>> p = null;
-
- synchronized(this) {
-
- setResult(item);
- setReady();
-// p = procs;
-// procs = null;
-
- }
-
-// if(p != null)
-// for(Procedure proc : p) {
-// proc.execute((T)item);
-// }
-
- } catch (Throwable t) {
- t.printStackTrace();
- }
-