使用CompletableFutures的异步非阻塞任务

Question

我需要在Java8中创建一个异步的、非阻塞的任务，我想使用CompletableFutures，但我不确定它是否满足我的需求。

为了简化这种情况，假设我们有一个API，它为用户检索一些数据，但同时想要启动一个单独的任务来执行一些操作。我不需要也不想等待这个单独的任务完成，我想立即将响应发送给用户。模拟代码中的一个示例：

public Response doSomething(params) {
  Object data = retrieveSomeData(params);

  // I don't want to wait for this to finish, I don't care if it succeeds or not
  doSomethingNoWait(data);

  return new Response(data);
}

我看着CompletableFutures，大概是这样的：

CompletableFuture.supplyAsync(this::doSomethingNoWait)  
             .thenApply(this::logSomeMessage); 

我想知道的是，这是不是正确的方法？在doSomethingNoWait完成它必须做的事情之前，响应会返回给用户吗？

谢谢!

Answer 1

问得好。是的，CompleteableFuture非常适合你的需求！让我们进一步研究该类的功能。

CompleteableFuture是Future类的包装器，允许并行执行。让我们来看一个来自this article的例子。

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
        throw new IllegalStateException(e);
    }
    return "Result of the asynchronous computation";
});

在上面的示例中，程序将异步启动CompletableFuture，并让新线程在后台休眠。如果我们添加如下所示的.thenApply()：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
        throw new IllegalStateException(e);
    }
    return "Result of the asynchronous computation";
}).thenApply(result -> {
   System.out.println(result);
   return "Result of the then apply";
});

应用程序将像我们前面讨论的那样执行，但一旦它完成(非异常)，运行supplyAsync的当前线程将执行打印语句。

请注意，如果在完成执行后将同步转换添加到将来，则调用线程将执行该转换。如下所示：

CompletableFuture<String> future = CompletableFuture.supplyAsync(() -> {
    try {
        TimeUnit.SECONDS.sleep(1);
    } catch (InterruptedException e) {
        throw new IllegalStateException(e);
    }
    return "Result of the asynchronous computation";
});
// Long calculations that allows the future above to finish
future.thenApply(result -> {
   System.out.println(result);
   return "Result of the then apply";
});

thenApply将在运行future.thenApply(...)的线程上运行，而不是在后台运行supplyAsync的线程上运行。

Answer 2

只有当supplyAsync(this：：doSomethingNoWait)阶段正常完成时，才会执行thenApply(this：：logSomeMessage)。

你可以这样做：

CompletableFuture.supplyAsync(this::doSomethingNoWait)  
logSomeMessage()