Что происходит под Future.cancel (истинной)

Question

Предположим, у меня есть Runnable экземпляр:

class MyTask implements Runnable { 

    public void run() { 
    //some heavy calculation which takes time 
     Thread.sleep(5000) 
    //rest code 
    ... 
    } 

} 

Затем я использую ExecutorService представить вышеуказанную задачу:

ExecutorService service = Executors.newFixedThreadPool(3); 
Future<?> task = service.submit(new MyTask()); 

Теперь я могу отмените задание на task.cancel(true);. Я понял, что task.cancel(true) прервет рабочий поток, в котором работает эта задача, например Thread.currentThread().interrupt(). Но этот устанавливает только флаг, чтобы сообщить, что рабочий поток прерван.

Мой вопрос: если MyTask Runnable начал работать, как на самом деле future.cancel(true) останавливает мой код в run() продолжает выполнение кода останова? Существует ли периодическая проверка для прерываемого флага рабочей нити? Я имею в виду, что я не понимаю, как код в run() можно отменить, только установите прерванный флаг в true.

Answer 1

Future.cancel не что ваш рабочий код перестанет выполняться. То, что он делает, это установить прерванный флаг и вызвать блокировку JDK-вызовов для вызова InterruptedException. Ваш рабочий код может выбрать повторное прерванное прерывание и периодически проверять прерванный флаг, и в этом случае механизм отмены будет работать. В противном случае вы можете проглотить InterruptedException и игнорировать флаг iterrupted, и в этом случае механизм отмены ничего не сделает, но установите для отмененного флажка значение true.

См http://www.ibm.com/developerworks/library/j-jtp05236/

Answer 2

Существует метод с именем isInterrupted(), который сообщает текущему коду в потоке, что он прерывается возвратом true/false.

Обычно это проверяется методами, такими как wait, sleep, которые вы могли бы вызвать в потоке. Если вы не используете эти методы, вам придется вручную проверить этот метод [isInterrupted()], чтобы определить, прервал ли кто-то ваш поток.

Если случайно вы получите истинное, вы можете решить, какие действия выполнить (скажем, например: бросить InterruptedException или сломаться из петли, и т.д ...)