Cómo detectar excepciones en FutureTask

Question

Después de encontrar que FutureTask ejecutándose en un Executors.newCachedThreadPool() en Java 1.6 (y desde Eclipse) se traga excepciones en el método Runnable.run(), he intentado encontrar una forma de detectar estos sin agregar throw/catch a todas mis implementaciones Runnable.

La API sugiere que anulando FutureTask.setException() debería ayudar en esto:

Causas este futuros reportar una ExecutionException con el throwable dada como su causa, a no ser que este futuro ya se ha establecido o se ha cancelado. Este método es invocado internamente por el método de ejecución al fallar el cálculo.

Sin embargo, no parece que este método sea llamado (que se ejecuta con el depurador muestra se detecta la excepción por FutureTask, pero no setException se llama). He escrito el siguiente programa para reproducir mi problema:

public class RunTest { 
    public static void main(String[] args) { 
     MyFutureTask t = new MyFutureTask(new Runnable() { 

      @Override 
      public void run() { 
       throw new RuntimeException("Unchecked exception"); 

      } 
     }); 

     ExecutorService service = Executors.newCachedThreadPool(); 
     service.submit(t); 
    } 
} 

public class MyFutureTask extends FutureTask<Object> { 

    public MyFutureTask(Runnable r) { 
     super(r, null); 
    } 

    @Override 
    protected void setException(Throwable t) { 
     super.setException(t); 
     System.out.println("Exception: " + t); 
    } 
} 

Mi pregunta principal es: ¿Cómo puedo capturar excepciones lanzadas en un FutureTask? ¿Por qué no se llama a setException?

También me gustaría saber por qué el mecanismo Thread.UncaughtExceptionHandler no es utilizado por FutureTask, ¿hay alguna razón para esto?

Answer 1

setException probablemente no está hecho para anulación, pero se proporciona para permitirle establecer el resultado a una excepción, en caso de ser necesario. Lo que se quiere hacer es reemplazar el método done() y tratar de conseguir el resultado:

public class MyFutureTask extends FutureTask<Object> { 

    public MyFutureTask(Runnable r) { 
     super(r, null); 
    } 

    @Override 
    protected void done() { 
     try { 
      if (!isCancelled()) get(); 
     } catch (ExecutionException e) { 
      // Exception occurred, deal with it 
      System.out.println("Exception: " + e.getCause()); 
     } catch (InterruptedException e) { 
      // Shouldn't happen, we're invoked when computation is finished 
      throw new AssertionError(e); 
     } 
    } 
} 

Answer 2

He consultado el código fuente de FutureTask y no he podido encontrar dónde se llama al setException.
Hay un método innerSetException de FutureTask.Sync (clase interna de FutureTask) al que se llama en el caso de un Throwable lanzado por el método de ejecución. Este método también se llama en setException.
Por lo tanto, parece que el javadoc no es correcto (o muy difícil de entender ...).

Answer 3

¿Ha intentado utilizar un UncaughtExceptionHandler?

• Debe implementar la interfaz UncaughtExceptionHandler.
• Para establecer un UncaughtExceptionHandler para hilos de grupo, proporcione un ThreadFactory en la llamada Executor.newCachedThreadPool(ThreadFactory).
• puede establecer el UncaughtExceptionHandler para el hilo creado a través de setUncaughtExceptionHandler(Thread.UncaughtExceptionHandler eh)

Presentar las tareas con ExecutorService.execute, ya que sólo las excepciones lanzadas desde las tareas presentadas con execute hacen al controlador de excepciones. Para Tareas enviadas con ExecutorService.submit, cualquier excepción lanzada se considera parte del valor de retorno de la tarea.Si una tarea presentada con presentar termina con una excepción, se relanza al llamar Future.get, envuelto en una ExecutionException

Answer 4

Una solución mucho mejor: Java FutureTask completion check

Cuando se llama a futureTask.get() para recuperar el resultado del cálculo que lo hará lanzar una excepción (ExecutionException) si el Runnable/Callable subyacente lanzó una excepción.

ExecutionException.getCause() devolverá la excepción que arrojó el Runnable/Callable.

También arrojará una excepción diferente si se canceló Runnable/Callable.