java - 将 Future 转换为 Mono

Question

我有返回convert java.util.concurrent.Future的遗留代码，现在我应该将此方法调用包装在返回 react 器发布者Mono或Flux的层中。我相信转换为它们中的任何一个的方法应该是相似的，那么将其转换为 Mono 的正确方法是什么。

假设我从 API 获取 Future 并且我需要 Mono

Answer 1

鉴于从 Future 获取结果总是会阻塞，一个可能的解决方案是将计算转移到阻塞友好的调度程序。

 Mono.fromCallable(() -> {
        try {
            Future future = null;
            return future.get();
        } catch (Exception e) {
            throw new RuntimeException(e);
        }
 }).subscribeOn(Schedulers.boundedElastic());

您可以使用 BlockHound https://github.com/reactor/BlockHound 验证您的代码是否有效地非阻塞。