如何不嵌套实现两个CompletableFuture数据库查询按先后顺序执行

你可以直接使用 CompletableFuture 自带的链式编排能力实现无嵌套的顺序执行，核心用thenCompose方法串联两个异步任务即可，示例代码如下：

// 完全无嵌套的链式调用
mainRepository.getAppointments()
        // 第一步：查询A完成后更新对应UI
        .thenAccept(retrievedAppointments -> {
            Platform.runLater(() -> {
                //Update ui for query A   
            });
        })
        // 第二步：上一步执行完成后启动查询B，thenCompose会将第二个异步任务接入调用链
        .thenCompose(unused -> mainRepository.getCustomers())
        // 第三步：查询B完成后更新对应UI
        .thenAccept(customers -> {
            Platform.runLater(() -> {
                //Update ui for query B  
            });
        });

方法说明 #

• thenCompose 是CompletableFuture专门用于串联两个异步任务的API，当第一个任务执行完成后，会调用传入的函数生成第二个异步任务，整个调用链为线性结构，完全避免了嵌套回调的问题
• 你不需要使用查询A的返回结果，直接忽略thenCompose传入的unused参数即可，完全匹配业务要求

可选优化 #

如果需要严格保证查询A的UI更新逻辑执行完成后再启动查询B，可以把Platform.runLater也包装成CompletableFuture，确保UI更新动作完成后再往下执行：

private CompletableFuture<Void> runOnFxThread(Runnable runnable) {
    CompletableFuture<Void> future = new CompletableFuture<>();
    Platform.runLater(() -> {
        try {
            runnable.run();
            future.complete(null);
        } catch (Throwable e) {
            future.completeExceptionally(e);
        }
    });
    return future;
}

// 优化后的调用链
mainRepository.getAppointments()
        .thenCompose(retrievedAppointments -> runOnFxThread(() -> {
            //Update ui for query A 
        }))
        .thenCompose(unused -> mainRepository.getCustomers())
        .thenCompose(customers -> runOnFxThread(() -> {
            //Update ui for query B
        }));

内容的提问来源于stack exchange，提问作者WHOATEMYNOODLES