java - 我可以运行 2 个 Mono 异步 Reactor Core 吗？

Question

在java中:

    Mono<response> response = mon.just()
    Mono<object> object = mono.just()
    return response.block()

响应和对象并不相互依赖。有没有办法同时并行运行 2 个单声道？

Answer 1

方法不止一种。一种简单的解决方案是使用 subscribeOn 运算符:

Mono<response> response = Mono.just(...).subscribeOn(Schedulers.boundedElastic());
Mono<object> object = Mono.just(...).subscribeOn(Schedulers.boundedElastic());

每当有人订阅你的 Monos 时，它都会在另一个线程中发生。在这种情况下，线程是从现有池中获取的。 调度程序 提供了多种方法，允许您使用现有线程或创建新线程(请参阅 documentation )。

如果您对响应式(Reactive)流和多线程感兴趣，我最近写了一篇article 关于它。