ForkJoinPool сбрасывает поток прерывистое состояние

Question

Я только что заметил следующие явления при отмене Будущего, возвращенного ForkJoinPool. С учетом следующего примера кода:

ForkJoinPool pool = new ForkJoinPool(); 
Future<?> fut = pool.submit(new Callable<Void>() { 

    @Override 
    public Void call() throws Exception { 
    while (true) { 
     if (Thread.currentThread().isInterrupted()) { // <-- never true 
     System.out.println("interrupted"); 
     throw new InterruptedException(); 
     } 
    } 
    } 
}); 

Thread.sleep(1000); 
System.out.println("cancel"); 
fut.cancel(true); 

Программа никогда не печатает interrupted. Документы из ForkJoinTask#cancel(boolean) говорят:

mayInterruptIfRunning - это значение не имеет никакого эффекта в реализации по умолчанию, потому что прерывания не используется для управления отменой.

Если ForkJoinTasks игнорирует прерывания, как еще вы должны проверять отмену внутри Callables, отправленных в ForkJoinPool?

Answer 1

Это происходит потому, что Future<?> является ForkJoinTask.AdaptedCallable, который проходит ForkJoinTask, чей отменить метод:

public boolean cancel(boolean mayInterruptIfRunning) { 
    return setCompletion(CANCELLED) == CANCELLED; 
} 

private int setCompletion(int completion) { 
    for (int s;;) { 
     if ((s = status) < 0) 
      return s; 
     if (UNSAFE.compareAndSwapInt(this, statusOffset, s, completion)) { 
      if (s != 0) 
       synchronized (this) { notifyAll(); } 
      return completion; 
     } 
    } 
} 

Она не делает каких-либо перерывов, он просто устанавливает статус. Я полагаю, что это происходит, потому что ForkJoinPools's Future s может иметь очень сложную древовидную структуру, и неясно, в каком порядке их отменить.