在 stackoverflow 上看了一个问题： ParallelFlux vs flatMap() for a Blocking I/O task
git00ll · 2021-12-16 13:58:00 +08:00 · 1592 次点击这是一个创建于 1060 天前的主题，其中的信息可能已经有所发展或是发生改变。
reactor 项目下的两种写法。
Flux.just(1)
.repeat(10)
.parallel(3)
.runOn(Schedulers.elastic())
.doOnNext(i -> blockingTask())
.sequential()
.subscribe()
or
Flux.just(1)
.repeat(10)
.flatMap(i -> Mono.fromCallable(() -> {blockingTask(); return i;}).subscribeOn(Schedulers.elastic()), 3)
.subscribe();
这两种写法有什么区别呢，看起来没有区别。哪种写法更流行呢
4 条回复 • 2021-12-17 13:34:22 +08:00
 |
1
Tenlearn 2021-12-16 14:02:26 +08:00
哪种看着舒服不是一目了然
|
 |
2
2i2Re2PLMaDnghL 2021-12-16 15:43:31 +08:00  1
不用 Java ，但感觉第二种不像人干事
如果维护人员脑子没问题的话，就必会把第一种的性能优化到至少不明显次于第二种。基础库对节能减排贡献非常巨大。 |
 |
3
mmdsun 2021-12-17 12:47:16 +08:00 via iPhone
https://projectreactor.io/docs/core/release/reference/#faq.wrap-blocking 。文档用的 Mono.fromCallable
|
Select Language