CompletableFuture、SupplySync（）和Apply（）

Question

需要确认一些事情。以下代码：

CompletableFuture
    .supplyAsync(() -> {return doSomethingAndReturnA();})
    .thenApply(a -> convertToB(a));

将与以下相同：

CompletableFuture
    .supplyAsync(() -> {
        A a = doSomethingAndReturnA();
        convertToB(a);
 });

右？

此外，接下来的另外两个问题是“我们有什么理由使用 thenApply？

1） 有转换的大代码吗？

或

2)需要在其他地方重用lambda块？

Answer 1

thenApply（） 是一个回调函数，当 supplyAsync（） 返回一个值时，将执行该函数。

在代码片段2中，调用< code > doSomethingAndReturnA()的线程等待函数执行并返回数据。

但是在一些异常情况下(比如调用Webservice和等待响应)，线程需要等待很长时间才能得到响应，这严重消耗了大量的系统计算资源(仅仅是等待响应)。

为了避免这种情况，CompletableFuture带有回调功能，一旦调用doThingAndRecnA（），一个单独的线程将负责执行doThingAndRecnA（），并且主调用者线程将继续执行其他操作，而无需等待响应返回。

一旦doThingAndRecnA的响应可用，将调用回调方法（即thenApply（））

Answer 2

这不是一回事。在第二个示例中，如果不使用＜code＞thenappy

但是，在第一个示例中，当使用< code>thenApply方法时，可能会发生其他情况。

首先，如果执行＜code＞doSomething和Returna＜code＞的＜code＞CompletableFuture＜/code＞已经完成，调用＜code＞然后应用＜code＞将在调用线程中发生。如果＜code＞CompletableFutures

困惑？这篇文章可能会有所帮助（感谢@SotiriosDimanolis的链接）。

我提供了一个简短的例子来说明thenApply是如何工作的。

public class CompletableTest {
    public static void main(String... args) throws ExecutionException, InterruptedException {
        final CompletableFuture<Integer> future = CompletableFuture
                .supplyAsync(() -> doSomethingAndReturnA())
                .thenApply(a -> convertToB(a));

        future.get();
    }

    private static int convertToB(final String a) {
        System.out.println("convertToB: " + Thread.currentThread().getName());
        return Integer.parseInt(a);
    }

    private static String doSomethingAndReturnA() {
        System.out.println("doSomethingAndReturnA: " + Thread.currentThread().getName());
        try {
            Thread.sleep(1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        return "1";
    }
}

输出为：

doSomethingAndReturnA: ForkJoinPool.commonPool-worker-1
convertToB: ForkJoinPool.commonPool-worker-1

因此，当第一个操作很慢时（即CompletableFuture尚未完成），两个调用都发生在同一个线程中。但是如果我们要删除＜code＞线程。sleep-从＜code＞DoSomething和Returna＜/code＞调用输出（可能）如下：

doSomethingAndReturnA: ForkJoinPool.commonPool-worker-1
convertToB: main

请注意，转换ToB调用位于main线程中。