Java Thread - Thread Thread.interrupted() y future.cancel (true) behavior

Question

Quiero administrar una lista de objetos futuros devueltos por mi TaskExecutor.
tengo algo como esto

List<Future<String>> list 

void process(ProcessThis processThis) {  
    for (...) { 
     Future<String> future = taskExecutor.submit(processThis); 
     list.add(future) 
    } 
} 


void removeFutures() { 
    for(Future future : list) { 
     assert future.cancel(true); 
} 

ProcessThis es una tarea que se puede llamar implementa < cuerda> y cheques por Thread.interrupted() Estado

public String call() { 
     while (true) { 
      if (Thread.interrupted()) { 
       break; 
      } 
      doSomething(); 
     } 
    } 

Ahora el problema es que sólo un subconjunto de los Threads concurrentes vuelven a 'verdadero' cuando se invoca Thread.interrupted().
La afirmación en removeFutures() devuelve verdadero para cada futuro que se elimine (también compruebo isDone() y isCompleted()
El número de subprocesos que se interrumpen es aleatorio. Más de 15 subprocesos en ejecución a veces se interrumpen 13, a veces 2 ...
Realmente no entiendo dónde está el problema. Si llamo a future.cancel (verdadero) y esto devuelve cierto ... y luego reviso Thread.interrupted (esto se llama solo una vez), espero esto para volver cierto.
Cualquier idea de lo que me estoy perdiendo?

estoy en construcción java 1.6.0_02-b05

Answer 1

por lo menos, debe restaurar el interr uption bandera para hacer TaskExecutor consciente de la interrupción del hilo:

public String call() { 
    while (true) { 
     if (Thread.interrupted()) { 
      Thread.currentThread().interrupt(); 
      break; 
     } 
     doSomething(); 
    } 
} 

Answer 2

Un problema potencial que las interrupciones son a menudo tragan. Por lo tanto, en algún lugar en el fondo de doSomething() (o incluso en la carga de la clase), una interrupción puede ser capturada por, digamos, wait() y luego descartada por el código 'descuidado'. Las interrupciones son malas, IMO.

Puede valer la pena comprobar que todas las tareas se estén ejecutando en el momento de la cancelación.

Answer 3

Tenga en cuenta que Thread.interrupted() devuelve el estado interrumpido actual y luego lo borra, por lo que todas las invocaciones futuras devolverán falso. Lo que quiere es probablemente Thread.currentThread().isInterrupted().

También tenga en cuenta que future.cancel(true) generalmente solo devolverá falso si la tarea ya se ha completado o cancelado. Si devuelve verdadero, eso no es garantía de que la tarea realmente se cancelará.

¿Qué está pasando en doSomething()? Es posible que una RuntimeException se escape en algún lugar debido a la interrupción. ¿Tienes un conjunto de UncaughtExceptionHandler? De lo contrario, deberá pasar un ThreadFactory al Executor que configurará el manejador de excepciones y registrará las excepciones perdidas.