Mono.toFuture() 是否阻塞？

Question

来自Official Documentation of Mono#block()的消息是：

订阅此 Mono 并无限期阻止，直到收到下一个信号。返回该值，如果 Mono 完成为空，则返回 null。如果 Mono 错误，则抛出原始异常（如果是已检查异常，则将其包装在 RuntimeException 中）。

所以可以确定 block() 方法是阻塞的，直到block() 解决它才会执行下一行。

但我的困惑是，当我使用 toFuture() 时，我期望它是非阻塞的，但它的行为与 block 方法完全相同。在Documentation of Mono#toFuture() 中声明：

将此 Mono 转换为 CompletableFuture 在 onNext 或 onComplete 上完成并在 onError 上失败。

不太清楚。此文档中没有任何地方说 Mono#toFuture() 被阻止。

1. 请确认toFuture()方法是阻塞还是非阻塞？
2. 另外如果是非阻塞那么，哪个线程将负责执行CompletableFuture里面的代码？

更新：添加代码 sn-p

使用Mono.block()方法：

    long time = System.currentTimeMillis();
    String block = Mono.fromCallable(() -> {
        logger.debug("inside in fromCallable() block()");
        //Upstream httpcall with apache httpClient().
        // which takes atleast 1sec to complete.
        return "Http response as string";
    }).block();
    logger.info("total time needed {}", (System.currentTimeMillis()-time));

    return CompletableFuture.completedFuture(block);

---

使用Mono.ToFuture()方法：

    long time = System.currentTimeMillis();
    CompletableFuture<String> toFuture = Mono.fromCallable(() -> {
        logger.debug("inside in fromCallable() block()");
        //Upstream httpcall with apache httpClient().
        // which takes atleast 1sec to complete.
        return "Http response as string";
    }).toFuture();
    logger.info("total time needed {}", (System.currentTimeMillis()-time));
    return toFuture;

这两个代码 sn-ps 的行为完全相同。

Answer 1

是的，你的怀疑是绝对正确的。实际上，Mono.block() 和 Mono.toFuture() 会立即订阅并将您带出响应式系统。

这个官方Springblog post会让你更清楚。

我还建议通过Mono 的source code 显示block 和toFuture 立即订阅。

@ruhul 第一条评论的解释

您在序列之后放置.toFuture() 的行会导致代码阻塞。

所以，在下面的代码中

Mono.fromCallable(() -> {
        logger.debug("inside in fromCallable() block()");
        //Upstream httpcall with apache httpClient().
        // which takes atleast 1sec to complete.
        return "Http response as string";

    }).toFuture(); // this line is the blocking code.

当您遇到 toFuture() 时，就会开始订阅序列并且您的代码会脱离响应式上下文。