在java中:
Mono<response> response = mon.just()
Mono<object> object = mono.just()
return response.block()
响应和对象并不相互依赖。 有没有办法同时并行运行 2 个单声道?
最佳答案
方法不止一种。一种简单的解决方案是使用 subscribeOn
运算符:
Mono<response> response = Mono.just(...).subscribeOn(Schedulers.boundedElastic());
Mono<object> object = Mono.just(...).subscribeOn(Schedulers.boundedElastic());
每当有人订阅你的 Monos 时,它都会在另一个线程中发生。在这种情况下,线程是从现有池中获取的。 调度程序
提供了多种方法,允许您使用现有线程或创建新线程(请参阅 documentation )。
如果您对响应式(Reactive)流和多线程感兴趣,我最近写了一篇article 关于它。
关于java - 我可以运行 2 个 Mono 异步 Reactor Core 吗?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/50571182/