举一个CompletableFuture 是偏异步处理操作的例子

今天药忘吃喽~ 2023-10-13 10:32 30阅读 0赞

## **假设我们有一个场景，需要同时调用两个远程服务获取数据，并在两个请求都完成后进行进一步的处理。这种情况下，CompletableFuture可以很好地支持异步处理操作的组合和协调。** ##

下面是一个使用CompletableFuture的简单示例代码：

CompletableFuture<String> future1 = CompletableFuture.supplyAsync(() -> {
        
        // 模拟调用远程服务1获取数据
        return remoteService1.getData();
    });
    
    CompletableFuture<String> future2 = CompletableFuture.supplyAsync(() -> {
        
        // 模拟调用远程服务2获取数据
        return remoteService2.getData();
    });
    
    CompletableFuture<Void> combinedFuture = CompletableFuture.allOf(future1, future2);
    
    combinedFuture.thenRun(() -> {
        
        // 在两个请求都完成后进行进一步的处理
        String data1 = future1.join();
        String data2 = future2.join();
        // 进一步的处理逻辑...
    });

在上面的示例中，我们使用**CompletableFuture**.supplyAsync方法分别创建了两个异步任务future1和future2，它们分别代表调用远程服务1和远程服务2来获取数据。然后，我们使用**CompletableFuture**.allOf方法将这两个任务进行组合，返回一个新的**CompletableFuture**对象combinedFuture，表示在所有任务完成后执行的操作。

接下来，我们通过combinedFuture.thenRun方法定义了一个回调函数，表示在所有任务完成后要执行的进一步处理逻辑。在回调函数中，我们通过future1.join()和future2.join()获取了两个任务的结果数据，并进行进一步的处理。

这个示例展示了**CompletableFuture**在异步处理操作中的应用，通过组合和协调多个异步任务，可以在任务完成后执行进一步的操作。