WebSVN - OpenConcerto - Diff - Rev 177 and 180 - /trunk/OpenConcerto/src/org/openconcerto/utils/SleepingQueue.java

 import java.util.concurrent.ScheduledFuture;
 import java.util.concurrent.ScheduledThreadPoolExecutor;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicBoolean;
 import java.util.concurrent.atomic.AtomicReference;
+import java.util.function.Function;
 import java.util.logging.Level;
 import net.jcip.annotations.GuardedBy;
 /**
     public final void tasksDo(IClosure<? super Deque<RunnableFuture<?>>> c) {
         this.tasksQueue.itemsDo(c);
+    }
+    public final <R> R tasksDo(Function<? super Deque<RunnableFuture<?>>, R> c) {
+        return this.tasksQueue.itemsDo(c);
+    }
     private void cancelCheck(RunnableFuture<?> t) {
         if (t != null)
             synchronized (this) {
                 if (this.canceling && (this.cancelPredicate == null || this.cancelPredicate.evaluateChecked(t)))
                     t.cancel(true);

Dépôt officiel du code source de l'ERP OpenConcerto