java - 从阻塞方法调用创建 CompletableFuture

Question

如何将阻塞方法调用“转换”为 CompletableFuture ？示例:

T waitForResult() throws InterruptedException {
    obj.await(); // blocking call
    // ...
    return something;
}

我需要把它变成这样:

CompletableFuture.of(this::waitForResult); // .of(Callable<T>) doesn't exist

一些需要考虑的事情:

1. waitForResult() 可能会抛出异常。这些必须正确处理，以便 completableFuture.get() 会抛出 InterruptedException 或 ExecutionException。
2. 不得涉及其他线程(supplyAsync() 会这样做)。
3. 它必须是一个 CompletableFuture(可能被包装)。

我试过了，但这不能正确处理异常:

CompletableFuture.completedFuture(Void.TYPE).thenApply(v -> {
    try {
        listener.await();
        // ...
        return listener.getResult();
    } catch (InterruptedException e) {
        throw new RuntimeException(e);
    } catch (SnmpException e) {
        throw new RuntimeException(e);
    }
});

我知道Create CompletableFuture from a sync method call ，但这对我没有帮助:

• 问题中的原始代码阻塞了主线程
• 答案中的代码要么合并了第三个线程，要么没有正确处理异常(如果我错了请纠正我)

Answer 1

我不确定我是否理解您的要求。这符合他们的要求吗？

private <T> CompletableFuture<T> supplySynchronously(Callable<T> callable) {
    CompletableFuture<T> f = new CompletableFuture<>();
    try {
        f.complete(callable.call());
    } catch (Exception e) {
        f.completeExceptionally(e);
    }
    return f;
}