WebSVN - OpenConcerto - Diff - Rev 93 and 156 - /trunk/OpenConcerto/src/org/openconcerto/utils/SleepingQueue.java

 import org.openconcerto.utils.cc.IClosure;
 import org.openconcerto.utils.cc.IPredicate;
 import java.beans.PropertyChangeListener;
 import java.beans.PropertyChangeSupport;
+import java.lang.Thread.UncaughtExceptionHandler;
 import java.util.Collection;
 import java.util.Deque;
 import java.util.concurrent.Callable;
 import java.util.concurrent.CancellationException;
 import java.util.concurrent.ExecutionException;
         this.tasksQueue = new SingleThreadedExecutor();
+    }
     public final void start() {
+        this.start(null);
+    }
+    public final void start(final IClosure<Thread> customizeThread) {
+        customizeThread(this.tasksQueue);
+        if (customizeThread != null)
+            customizeThread.executeChecked(this.tasksQueue);
         synchronized (this) {
             this.tasksQueue.start();
             this.setState(RunningState.RUNNING);
             started();
+        }
      */
     protected void willPut(FutureTask<?> r) throws InterruptedException {
+    }
     /**
-     * An exception was thrown by a task. This implementation merely
+     * An exception was thrown by a task. This implementation uses
-     * {@link Exception#printStackTrace()}.
+     * {@link Thread#getUncaughtExceptionHandler()} or
+     * {@link Thread#getDefaultUncaughtExceptionHandler()} if available, otherwise falls back to
+     * just {@link Exception#printStackTrace()}. To set the handler, {@link #start(IClosure)} can be
+     * used.
+     *
      * @param exn the exception thrown.
      */
     protected void exceptionThrown(final ExecutionException exn) {
+        final Thread thr = this.tasksQueue;
+        UncaughtExceptionHandler h = thr.getUncaughtExceptionHandler();
+        if (h == null)
+            h = Thread.getDefaultUncaughtExceptionHandler();
+        if (h != null) {
+            h.uncaughtException(thr, exn);
+        } else {
-        exn.printStackTrace();
+            exn.printStackTrace();
+        }
+    }
     /**
      * Cancel all queued tasks and the current task.
      */
     protected final void cancel() {
+    }
     private final class SingleThreadedExecutor extends DropperQueue<FutureTask<?>> {
         private SingleThreadedExecutor() {
             super(SleepingQueue.this.name + System.currentTimeMillis());
-            customizeThread(this);
+        }
         @Override
         protected void process(FutureTask<?> task) {
             if (!task.isDone()) {

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

svn://code.openconcerto.org/openconcerto

(root)/trunk/OpenConcerto/src/org/openconcerto/utils/SleepingQueue.java - Rev 93 → 156