Thread Java - comportamento strano Thread.interrupted() e future.cancel (true)

Question

Desidero gestire un elenco di oggetti Futures restituiti dal mio TaskExecutor.
Ho qualcosa di simile

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 è un compito che implementa Callable < String> e controlli per Thread.interrupted) Stato

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

(Ora il problema è che solo un sottoinsieme di i Thread simultanei restituiscono 'true' quando viene chiamato Thread.interrupted().
L'affermazione in removeFutures() restituisce true per ogni futuro rimosso (Ho verificato anche isDone() ed isCompleted().
Il numero di thread interrotti è casuale. Più di 15 thread in esecuzione a volte 13 sono interrotti, a volte 2 ...
Io davvero non capisco dove sia il problema, se chiamo future.cancel (true) e questo restituisce true ... e poi controllo Thread.interrupted (questo è chiamato solo una volta), mi aspetto questo per tornare vero pure.
Qualsiasi idea di che cosa mi manca?

sono su di generazione Java 1.6.0_02-b05

Answer 1

almeno, si dovrebbe ripristinare l'INTERR uption bandiera per rendere TaskExecutor a conoscenza dell'interruzione filo:

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

Answer 2

Un potenziale problema che gli interrupt sono spesso ingerite. Quindi da qualche parte in profondità nel doSomething() (o anche nel caricamento di classe), un interrupt può essere catturato, per esempio, wait() e quindi scartato dal codice "trascurato". Le interruzioni sono cattive, IMO.

Può valere la pena verificare che tutte le attività siano effettivamente in esecuzione al momento dell'annullamento.

Answer 3

Si noti che Thread.interrupted() restituisce lo stato corrente interrotto e quindi lo cancella, quindi tutte le chiamate future restituiranno false. Quello che vuoi è probabilmente Thread.currentThread().isInterrupted().

Inoltre, tenere presente che future.cancel(true) in genere restituisce solo false se l'attività era già stata completata o annullata. Se restituisce true, non è garantito che l'attività verrà effettivamente annullata.

Che cosa succede in doSomething()? È possibile che una RuntimeException sfugga da qualche parte a causa dell'interrupt. Hai un set UncaughtExceptionHandler? In caso contrario, sarà necessario passare uno ThreadFactory allo Executor che imposterà il gestore delle eccezioni e registrerà eventuali eccezioni mancanti.