使用 CompletableFuture 在 Java 8 中将 Javascript 包装回调作为 Promise 等价物

Question

在 Javascript 中，我可以将回调包装为如下的承诺：

function subscribeAsCallback(request, callback) {
    // ... async operation
    const response = ...; 
    callback(response); 
}

function subscribeAsPromise(request) {
    return new Promise((resolve, reject) => {
        subscribeAsCallback(request, (response) => {
            resolve(response);
        });
    });
}

这样我就可以调用它了

subscribeAsPromise(request).then(response => {
   // handling response logic
});

我想问一下它在 Java 中的等价物是什么？这是我在 Java 中的代码，我不知道如何包装回调。

public class DataSubscriber {
    public void subscribeAsCallback(Request request, Consumer<Response> consumer) {
        // ... async operation 
        Response response = ...; 
        consumer.accept(response); 
    }

    public CompletableFuture<Response> subscribeAsPromise(Request request) {
        // ... ? 
        // what is the equivalent of its Java version?
    }
}

这样我就可以这样调用代码了：

dataSubscriber.subscribeAsPromise(request).thenApply(response -> {
   // handling response logic
});

Answer 1

我只是想到了一个使用CountDownLatch 的解决方案，虽然我不认为使用 CountDownLatch 是一个好主意，因为它只会阻止线程执行而浪费一些资源。但这将是一种可能的解决方案。

public class DataSubscriber {
    public void subscribeAsCallback(Request request, Consumer<Response> consumer) {
        // ... async operation 
        Response response = ...; 
        consumer.accept(response); 
    }

    public CompletableFuture<Response> subscribeAsPromise(Request request) {        
        return CompletableFuture.supplyAsync(() -> {
            try {
                final Response[] responeResult = { null }; 
                CountDownLatch latch = new CountDownLatch(1);
                subscribeAsCallback(request, new Consumer<Response>() {
                    public void accept(Response response) {
                        responeResult[0] = response;
                        latch.countDown(); 
                    }
                });

                latch.await();
                return responseResult[0]; 
            } catch (Exception ex) {
                throw new RuntimeException(ex);
            }
        });
    }
}

虽然代码看起来不是很好，但这是我能想到的第一个解决方案。希望有其他更好的答案，以便我学习。

Answer 2

您将无法将callback 传递给CompletableFuture。我个人觉得在JavaScript 中处理promises 更容易，在java 中肯定更冗长。

在您的示例中，我看不到将匿名函数(response) => { resolve(response); } 传递给promise 或future 的意义，因为CompletableFuture 提供了一个get() 方法来解析@987654332 @，在你的代码行之后调用

CompletableFuture future = dataSubscriber.subscribeAsPromise(request).thenApply(response -> {
   // handling response logic
});

// do this to "resolve" the future
future.get();

public class DataSubscriber {
    // Please update the name to reflect the correct semantic meaning
    public Response subscribeAsCallback(Request request) {
        // ... async operation 
        Response response = ...; 
        return response;
    }

    public CompletableFuture<Response> subscribeAsPromise(Request request) {
        return CompletableFuture.supplyAsync(this::subscribeAsCallback);
    }
}