当前位置：首页 > Java

java 如何实现promise

2026-03-23 13:28:02Java

实现 Promise 的核心逻辑

Java 本身没有原生 Promise 类，但可以通过 CompletableFuture 或手动实现类似功能。以下是两种实现方式：

使用 CompletableFuture（推荐） Java 8 引入的 CompletableFuture 提供了类似 Promise 的链式调用和异步处理能力：

CompletableFuture.supplyAsync(() -> {
    // 模拟耗时操作
    return "Result";
}).thenApply(result -> {
    return result + " processed";
}).thenAccept(finalResult -> {
    System.out.println("Final result: " + finalResult);
}).exceptionally(ex -> {
    System.out.println("Error: " + ex.getMessage());
    return null;
});

手动实现 Promise 模式 若需更接近 JavaScript Promise 的 API，可自定义类：

public class Promise<T> {
    private T result;
    private Throwable error;
    private List<Consumer<T>> successCallbacks = new ArrayList<>();
    private List<Consumer<Throwable>> failureCallbacks = new ArrayList<>();

    public Promise(Supplier<T> task) {
        new Thread(() -> {
            try {
                this.result = task.get();
                successCallbacks.forEach(cb -> cb.accept(result));
            } catch (Exception e) {
                this.error = e;
                failureCallbacks.forEach(cb -> cb.accept(error));
            }
        }).start();
    }

    public Promise<T> then(Consumer<T> callback) {
        if (result != null) {
            callback.accept(result);
        } else {
            successCallbacks.add(callback);
        }
        return this;
    }

    public Promise<T> catchError(Consumer<Throwable> callback) {
        if (error != null) {
            callback.accept(error);
        } else {
            failureCallbacks.add(callback);
        }
        return this;
    }
}

关键特性对比

CompletableFuture 优势

原生支持线程池配置
提供 thenCombine/allOf 等组合操作
内置异常处理机制

自定义 Promise 优势

java 如何实现promise

更接近前端开发者的使用习惯
可自由扩展 API（如 finally 方法）

异步执行示例

// 使用自定义 Promise
new Promise<String>(() -> {
    Thread.sleep(1000);
    return "Async Data";
}).then(data -> {
    System.out.println("Received: " + data);
}).catchError(e -> {
    System.err.println("Failed: " + e);
});