如何取消Java 8可完成的未来？

Question

我正在使用Java 8可完成的期货。我有以下代码：

CountDownLatch waitLatch = new CountDownLatch(1);

CompletableFuture<?> future = CompletableFuture.runAsync(() -> {
    try {
        System.out.println("Wait");
        waitLatch.await(); //cancel should interrupt
        System.out.println("Done");
    } catch (InterruptedException e) {
        System.out.println("Interrupted");
        throw new RuntimeException(e);
    }
});

sleep(10); //give it some time to start (ugly, but works)
future.cancel(true);
System.out.println("Cancel called");

assertTrue(future.isCancelled());

assertTrue(future.isDone());
sleep(100); //give it some time to finish

我使用runAsync计划执行等待闩锁的代码。接下来，我取消了将来，希望将被中断的异常抛出内部。但是似乎线程在await调用上仍然处于阻塞状态，即使将来被取消（断言通过）也永远不会抛出InterruptedException。使用ExecutorService的等效代码可以正常工作。是CompletableFuture中的错误还是我的示例中的错误？

Answer 1

显然，这是故意的。方法CompletableFuture ::
cancel
的Javadoc 指出：

[参数：] mayInterruptIfRunning -这个值 没有 在该实施方式的效果，因为中断将不被用于控制处理。

有趣的是，方法ForkJoinTask ::
cancel
对 mayInterruptIfRunning 参数使用几乎相同的措词。

我对这个问题有一个猜测：

• 中断 旨在与阻塞操作（例如 睡眠 ， 等待 或I / O操作）一起使用，
• 但是 CompletableFuture 和 ForkJoinTask 都不打算与阻塞操作一起使用。

而不是阻塞， CompletableFuture 应该创建一个新的 CompletionStage ，并且CPU绑定任务是fork-
join模型的先决条件。因此，对他们中的任何一个使用 中断 都会 破坏 他们的目的。另一方面，它可能会增加复杂性，如果按预期使用，则不需要这样做。