确保任务可中断

Question

如何在打电话时确保我的任务对中断有反应Future.cancel()？

ExecutorService executor = Executors.newSingleThreadExecutor();
Future<Boolean> future = executor.submit(task);

try {
    future.get(timeout, timeoutUnit);
} catch (TimeoutException e) {
    future.cancel(true);
}

Answer 1

当我调用Future.cancel（）时，如何确保我的任务能够响应中断？

调用future.cancel(...)将停止尚未运行的任务。如果它正在运行，那么如果使用future.cancel(true)它将中断正在运行的线程。

要停止线程，您需要测试线程中断标志：

if (!Thread.currentThread().isInterrupted()) {
   ...

并且您需要InterruptedException适当处理句柄。例如：

try {
    Thread.sleep(...);
} catch (InterruptedException e) {
    // re-establish the interrupt condition
    Thread.currentThread.interrupt();
    // probably stop the thread
    return;
}