CompletableFuture和CountDownLatch超时

Question

我希望将一个Runnable封装在要异步计算的CompletableFuture中，但要控制计算什么时候开始和结束。我创建了一个带有CompletableFuture的CountDownLatch来阻止处理，但是下面的代码段会抛出一个错误：

CountDownLatch countDownLatch = new CountDownLatch(1);
CompletableFuture completableFuture = CompletableFuture.runAsync(() -> {
    try {
        countDownLatch.await();
    } catch (InterruptedException e) {
        e.printStackTrace();
    }
    System.out.println("Stop");
});
Thread.sleep(1000L);
System.out.println("Start");
completableFuture.get(1000L, TimeUnit.MILLISECONDS);
countDownLatch.countDown();

java.util.concurrent.CompletableFuture.timedGet(CompletableFuture.java:1771) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1915) at Sandbox.main(Sandbox.java:23)的

启动线程"main“java.util.concurrent.TimeoutException中的异常

另一方面，当我在没有超时的情况下调用get时，它会结冰(只打印Start )。

我期望CompletableFuture中的runnable在调用countDownLatch.countDown();时运行。

Answer 1

因为CompletableFuture#get是一个阻塞调用。因此，countDownLatch.countDown();在CompletableFuture#get得到结果之前不会执行。CompletableFuture将不会完成并返回结果，因为它将等待countDownLatch进行计数。因此，基本上您已经在两个线程之间创建了一个依赖关系，这样一个线程将等待另一个线程，反之亦然。

Answer 2

您正在等待超时结束，而不允许线程继续进行。Future.get正在阻塞，这将永远不允许您在超时到期之前访问countDown Latch，因此您的线程永远不会完成。这里要做的是，首先让线程在Latch上调用Latch，然后在get调用中等待超时。把这两条线倒转就能解决这个问题。这是看上去的样子。

countDownLatch.countDown();
completableFuture.get(1000L, TimeUnit.MILLISECONDS);

实际上，如果您从get调用中删除超时(它无限期地阻塞)，那么这就是系统中死锁的典型例子。工作线程等待直到主线程计数下闩锁，而主线程等待工作线程完成，以便它可以继续并countDown锁存。幸运的是，get所通过的超时能够避免概率死锁。相反，您可以在任何时候cancel未来，并避免潜在的死锁，因为您的任务是响应中断。