如何为CompletableFuture添加finally逻辑？Java8优化方案咨询

Java8的CompletableFuture并未原生提供finallyRun方法（该特性在Java9中才引入），针对你异步加载数据后无论成败都需关闭进度对话框的场景，以下是几种优雅的实现方案：

方案一：自定义工具方法（无需第三方库） #

直接封装一个通用工具方法，利用whenComplete实现finally语义，写法完全贴合你期望的简洁风格：

// 通用工具方法，可放在工具类中复用
public static <T> CompletableFuture<T> finallyRun(CompletableFuture<T> future, Runnable action) {
    return future.whenComplete((result, throwable) -> action.run());
}

使用示例：

// 异步加载数据库数据
CompletableFuture<List<Data>> loadDataFuture = CompletableFuture.supplyAsync(() -> fetchDataFromDB());

// 链式调用，无论成功失败都会关闭进度对话框
finallyRun(loadDataFuture, progressDialog::dispose)
    .thenAccept(this::populateJTable) // 成功后填充JTable
    .exceptionally(t -> { // 可选：统一处理异常
        showErrorDialog("加载失败：" + t.getMessage());
        return null;
    });

这个方法会在future完成（无论成功或异常）时执行传入的Runnable，完全等价于finally代码块的语义，且无需依赖第三方库。

方案二：使用Guava的ListenableFuture #

如果项目已引入Guava，可以将CompletableFuture转为Guava的ListenableFuture，通过回调统一处理结果与收尾逻辑：

// 1. 将CompletableFuture转为ListenableFuture
ListenableFuture<List<Data>> listenableFuture = Futures.makeListenable(loadDataFuture);

// 2. 封装带finally逻辑的回调模板
public static <T> FutureCallback<T> withFinally(Runnable finallyAction, Consumer<T> onSuccess, Consumer<Throwable> onFailure) {
    return new FutureCallback<T>() {
        @Override
        public void onSuccess(@Nullable T result) {
            try {
                onSuccess.accept(result);
            } finally {
                finallyAction.run();
            }
        }

        @Override
        public void onFailure(Throwable t) {
            try {
                onFailure.accept(t);
            } finally {
                finallyAction.run();
            }
        }
    };
}

// 3. 调用回调
Futures.addCallback(listenableFuture,
    withFinally(
        progressDialog::dispose,
        this::populateJTable,
        t -> showErrorDialog("加载失败：" + t.getMessage())
    ),
    Executors.newSingleThreadExecutor()
);

这种方式适合已经大量使用Guava异步组件的项目，通过模板避免重复编写收尾逻辑。

方案三：Apache Commons AsyncUtils（可选） #

Apache Commons Lang 3.12+的AsyncUtils工具类也能辅助实现，但写法相对繁琐，仅作参考：

AsyncUtils.compose(loadDataFuture,
    data -> {
        populateJTable(data);
        return CompletableFuture.completedFuture(null);
    },
    t -> {
        showErrorDialog("加载失败：" + t.getMessage());
        return CompletableFuture.completedFuture(null);
    }
).whenComplete((v, e) -> progressDialog.dispose());

总结 #

优先推荐方案一的自定义工具方法，无需额外依赖，写法简洁且完全匹配你的需求；若项目已使用Guava，方案二是更贴合现有技术栈的选择。

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