FutureTask 中的 awaitDone 抛出 InterruptedException答案

【问题标题】：awaitDone in FutureTask throwing InterruptedExceptionFutureTask 中的 awaitDone 抛出 InterruptedException
【发布时间】：2014-11-27 13:34:59
【问题描述】：

我已经在网上搜索了一个星期，但没有一个帖子喜欢 How do I get FutureTask to return after TimeoutException? 似乎回答了我的问题。我从我的代码中提取了一个代码示例：

 Future<Object> result = executorService.submit(new Callable<Object>() {
    @Override public Object call() throws Exception {
     ...........
    }
  });

  try {
    return result.get(timeout.getValue(), timeout.getUnit().getTimeUnit());
  } catch (TimeoutException e) {
    result.cancel(true);
    throw new TTimeoutException(e);
  }

如果我运行这个，有时（1000 分之一）我会得到 p>

 java.lang.InterruptedException
        at java.util.concurrent.FutureTask.awaitDone(FutureTask.java:400)
        at java.util.concurrent.FutureTask.get(FutureTask.java:199)
        at com.abc.callers.A.call(A.java:83)

第 83 行是上面代码示例中显示的未来任务的 result.get()。

现在我的问题是，将来调用 result.cancel(true) 会导致 result.get 中的 InterruptedException 吗？如果不是，谁能改变我当前线程的中断状态？ AFAIK result.get() 与运行我正在取消的提交任务的线程不同..

【问题讨论】：

Cancel 不应导致 InterruptedException，因为行号表明调用了 result.get()。
@AndyDufresne 不，这是来自被中断线程的调用堆栈。它不会告诉你中断是从哪里来的。
@AndyDufresne：我不太确定这一点，因为未来线程中发生的异常会被引导到 get() 方法调用。这就是为什么这个方法应该被调用的原因之一，即使它什么也不返回。
@HovercraftFullOfEels - 如果我的理解不正确，请纠正我 - 上面的代码 sn-p 缺少 InterruptedException 的 catch 块，但假设它与 TimeOutException 相同，result.cancel() 方法如何调用导致同一线程中的中断？
从您发布的代码中，由于cancel 的结果是不可能得到InterruptedException，因为当InterruptedException 被抛出时您没有调用cancel。或者反过来说，如果您在 catch (TimeoutException… 块内调用 cancel，您将无法在 get 中获得 InterruptedException，因为 get 已经完成了 TimeoutException。显然，InterruptedException 的原因在于您在此处没有发布的一段代码。

标签： java multithreading interrupt future executorservice

【解决方案1】：

来自 Javadoc：

boolean cancel(boolean mayInterruptIfRunning)

尝试取消此任务的执行。如果任务已完成、已被取消或由于其他原因无法取消，则此尝试将失败。如果成功，并且在调用取消时此任务尚未启动，则此任务不应该运行。如果任务已经开始，则mayInterruptIfRunning 参数确定是否应该中断执行该任务的线程以尝试停止该任务。

此方法返回后，对isDone() 的后续调用将始终返回true。如果此方法返回 true，则对 isCancelled() 的后续调用将始终返回 true。

所以如果设置了mayInterruptIfRunning，那么是的，它会尝试中断运行任务的线程。

换句话说，.cancel(true) 会尝试中断正在运行的任务，而.cancel(false) 不会。

如果你调用.cancel(false) 并且任务甚至还没有开始，听起来result.get() 仍然会被打断。

【讨论】：

我已经读过了。但是当我检查 awaitDone 的代码时，它正在检查 Thread.interrupted() 这意味着当前线程而不是 result.cancel() 将中断的运行线程。

【解决方案2】：

感谢大家的投入。经过这么多的挖掘，我终于找到了答案。

这是一个服务器端代码，故障出在客户端代码中，如果它没有在指定的时间限制内返回结果，则它正在中断服务器。当然客户端的时间限制小于服务器的超时限制。

虽然他们正在捕获从服务器抛出的中断异常，但由于服务器正在使用动态代理，所以它被包裹在 UndeclaredThrowableException 下。

【讨论】：