Java DeleverableFuture不取消基础执行

Question

我希望从以下代码中，由于超时，完整的图将停止处理。但是我可以看到，取消没有效果。

public class CompletableFutureTest {

    public static void main(final String[] args) {
        ExecutorService executor = Executors.newFixedThreadPool(10);
        CompletableFuture completableFuture;
        CompletableFuture completableFuture2;
        completableFuture =
                CompletableFuture.runAsync(() -> callSomeMethod(1), executor);
        completableFuture2 =
                CompletableFuture.runAsync(() -> callSomeMethod(2), executor);
        try {

            System.out.println("After everything");
            completableFuture.get(2, TimeUnit.SECONDS);
            completableFuture2.get(2, TimeUnit.SECONDS);
        } catch (ExecutionException e) {
            cancelCompletableFuture(completableFuture);
            cancelCompletableFuture(completableFuture2);
        }  catch (TimeoutException e) {
            cancelCompletableFuture(completableFuture);
            cancelCompletableFuture(completableFuture2);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }

    }

    private static void callSomeMethod(int i) {
        System.out.println("In some method" + i);
        try {
            Thread.sleep(5000);
        } catch (InterruptedException e) {
            System.out.println("Interrupted");
        }
        System.out.println("After sleep" + i);
    }

    private static void cancelCompletableFuture(CompletableFuture completableFuture) {
        completableFuture.cancel(true);
    }


}

我可以看到2个完整的期货仍在运行。

Answer 1

完整future的Javadoc具有您的问题的答案，特别是MayInterruptIfrunning CANCE> CANCEL> CANCEL方法的评论：

MayInterruptifrunning - 此值在此实现中无效，因为中断不用于控制处理。