如何用future中断线程，想通过future发出的中断执行一些任务

Question

我对 Java 中的未来和多线程很陌生。我有一个简单的问题，结果却很复杂，我有许多线程（它们都有打开的会话），它们是无限打开的。每当一个线程抛出自定义异常（会话超时异常）时，我必须中断所有线程并优雅地关闭所有会话。我所做的是存储线程返回的未来对象（在 ArrayList 中）并循环遍历它，并在一个线程抛出异常时为所有对象发出 future.cancel。

private static void futureCancel()
{
        for(int i=0;i<numberStreams;i++)
        {
            Future<String> future=futureList.get(i);
            try{
                future.cancel(true);
                future.get();
            }
            catch(InterruptedException e)
            {
                System.out.println("In interrupted block!");
            } catch (ExecutionException e) {
                e.printStackTrace();
            }       
        }
        return;
    }

这里的问题是，由于一些需求问题以及会话另一端的工作方式，我无法在线程代码中添加 InterruptedException。如果我从我的可调用对象中抛出一个 InterruptedException，它不会到达上面指定的 catch 块。如果我在我的线程中添加睡眠（可以进行测试）并处理 InterruptedException，它会在 future.cancel 发出后立即进入该块。我做错了什么？

Answer 1

Futuer#cancel(boolean) javadoc 状态

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

所以ExecutorService 没有执行Runnable/Callable 并且可以将其从其队列中删除，或者它已经执行并且ExecutorService 必须调用Thread#interrupt() 和您的Runnable/@987654330 @代码必须处理它。

没有其他方法可以通过Future 接口中断线程。如果您的Runnable 没有办法处理中断，那么可能会发生很多事情。如果出现InterruptedException，它将冒泡到ExecutorService 并被包裹在ExecutionException 中，而Future#get() 将抛出该ExecutionException。如果在执行Runnable 的线程中没有出现InterruptedException，您的Runnable 将继续畅通无阻。

你真的应该考虑改变你的Runnable来处理中断。

Answer 2

如果我从可调用对象中抛出 InterruptedException，它不会到达上面指定的 catch 块。

不会的。 InterruptedException 在future.get() 周围的catch 块是调用 get 的线程被中断——而不是你的Callable。

如果您的Callable 被中断并抛出InterruptedException，那么当您调用get() 时，它将进入ExecutionException，而e.getCause() 应该是InterruptedException。