如果使用thenApply，则不会调用CompletableFuture＃whenComplete

Question

我有以下代码，该代码在远程服务器上安排任务，然后使用轮询完成ScheduledExecutorService#scheduleAtFixedRate。任务完成后，它将下载结果。我想将a返回Future给调用方，以便他们可以确定阻止时间和阻止时间，并为他们提供取消任务的选项。

我的问题是，如果客户端取消Future该download方法返回的值，则whenComplete块不会执行。如果我删除thenApply它。很明显，我对Future构图有些误解…我应该改变什么？

public Future<Object> download(Something something) {
    String jobId = schedule(something);
    CompletableFuture<String> job = pollForCompletion(jobId);
    return job.thenApply(this::downloadResult);
}

private CompletableFuture<String> pollForCompletion(String jobId) {
    ScheduledExecutorService executor = Executors.newSingleThreadScheduledExecutor();
    CompletableFuture<String> completionFuture = new CompletableFuture<>();

    ScheduledFuture<?> checkFuture = executor.scheduleAtFixedRate(() -> {           
            if (pollRemoteServer(jobId).equals("COMPLETE")) {
                completionFuture.complete(jobId);
            }
    }, 0, 10, TimeUnit.SECONDS);
    completionFuture                
            .whenComplete((result, thrown) -> {
                System.out.println("XXXXXXXXXXX"); //Never happens unless thenApply is removed
                checkFuture.cancel(true);
                executor.shutdown();
            });
    return completionFuture;
}

同样，如果我这样做：

return completionFuture.whenComplete(...)

代替

completionFuture.whenComplete(...);
return completionFuture;

whenComplete也永远不会执行。这对我来说似乎很违反直觉。从逻辑上说，Future返回应该不是whenComplete我应该坚持的那个吗？

编辑：

我更改了代码以明确向后传播取消。这是令人讨厌和难以理解的，但是它可以正常工作，我找不到更好的方法：

public Future<Object> download(Something something) throws ChartDataGenException, Exception {
        String jobId = schedule(something);
        CompletableFuture<String> job = pollForCompletion(jobId);
        CompletableFuture<Object> resulting = job.thenApply(this::download);
        resulting.whenComplete((result, thrown) -> {
            if (resulting.isCancelled()) { //the check is not necessary, but communicates the intent better
                job.cancel(true);
            }
        });
        return resulting;
}

编辑2：

我发现了tascalate-concurrent，这是一个出色的库，提供sane的明智实现CompletionStage，并支持可以通过DependentPromise透明方式反向传播取消的相关承诺（通过类）。似乎非常适合此用例。

这应该足够了：

DependentPromise
          .from(pollForCompletion(jobId))
          .thenApply(this::download, true); //true means the cancellation should back-propagate

请注意，没有测试这种方法。

Answer 1

您的结构如下：

           ┌──────────────────┐
           │ completionFuture |
           └──────────────────┘
             ↓              ↓
  ┌──────────────┐      ┌───────────┐
  │ whenComplete |      │ thenApply |
  └──────────────┘      └───────────┘

因此，当您取消thenApply未来时，原始completionFuture对象不会受到影响，因为它与thenApply舞台无关。但是，如果您不链接该thenApply阶段，那么您将返回原始completionFuture实例，并且取消该阶段会导致所有相关阶段的取消，从而使whenComplete操作立即执行。

schedule(something)和pollRemoteServer(jobId)`。如果您的应用程序状态以某种方式更改，使得取消下载后再也无法满足此条件，那么这种未来将永远无法完成…

关于您的最后一个问题，哪个期货是“我应该坚持的那个期货？”，实际上，并不需要线性的期货链，而方便的方法CompletableFuture可以轻松地创建这样的链，而不仅仅是通常，这是最没有用的事情，因为如果您具有线性依赖性，则只需编写一段代码即可。您将两个独立阶段链接在一起的模型是正确的，但是取消不能通过它起作用，但是它也不可以通过线性链来起作用。

如果希望能够取消源阶段，则需要对其进行引用，但是，如果想要获得从属阶段的结果，则也需要对该阶段进行引用。