Wątek Java - dziwne Thread.interrupted() i future.cancel (true) zachowanie

Question

Chcę zarządzać listą obiektów Futures zwróconych przez mojego TaskExecutor.
mam coś takiego

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 jest zadaniem, które realizuje wywoływalnym < string> i kontrole na Thread.interrupted) Status

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

(Teraz problemem jest to, że tylko podzbiór Współbieżne wątki zwracają "true" po wywołaniu Thread.interrupted().
assert w removeFutures() zwraca wartość true dla każdej przyszłej, która została usunięta (ja sprawdziłem również isDone() i isCompleted()
Liczba wątków, które są przerywane, jest losowa, ponad 15 uruchomionych wątków czasami 13 jest przerywanych, czasami 2 ...
Naprawdę nie rozumiem, gdzie jest problem, jeśli zadzwonię do future.cancel (true) i to zwróci true ... a następnie sprawdzam Thread.interrupted (to jest wywoływane tylko raz), spodziewam się ten powrót prawda, jak również.
żadnego pomysłu na to, co mi brakuje?

Jestem na kompilacji java 1.6.0_02-B05

Answer 1

przynajmniej, należy przywrócić interr Flaga uption aby taskExecutor świadome zerwanie gwintu:

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

Answer 2

Potencjalny problem, że przerwania są często połknięciu. Więc gdzieś głęboko w doSomething() (lub nawet w ładowaniu klasy), przerwanie może zostać przechwycone przez, powiedzmy, wait(), a następnie odrzucone przez "nieostrożny" kod. Przerwania są złe, IMO.

Może warto sprawdzić, czy wszystkie zadania są wykonywane w momencie anulowania.

Answer 3

Należy pamiętać, że Thread.interrupted() zwraca bieżący stan przerwań , a następnie czyści go, więc wszystkie przyszłe wywołania zwrócą wartość false. To, czego chcesz, to prawdopodobnie Thread.currentThread().isInterrupted().

Pamiętaj też, że zwykle future.cancel(true) zwróci wartość false tylko wtedy, gdy zadanie zostało już zakończone lub anulowane. Jeśli zwróci true, nie ma gwarancji, że zadanie zostanie faktycznie anulowane.

Co się dzieje w doSomething()? Jest możliwe, że wyjątek RuntimeException ucieka gdzieś z powodu przerwania. Czy masz zestaw UncaughtExceptionHandler? Jeśli nie, musisz przekazać ThreadFactory do Executor, która ustawi procedurę obsługi wyjątku i zapisze wszystkie nieodebrane wyjątki.