在 stackoverflow 上看了一个问题： ParallelFlux vs flatMap() for a Blocking I/O task

V2EX = way to explore

V2EX 是一个关于分享和探索的地方

For Existing Member Sign In

This topic created in 1596 days ago, the information mentioned may be changed or developed.

reactor 项目下的两种写法。

Flux.just(1)
    .repeat(10)
    .parallel(3)
    .runOn(Schedulers.elastic())
    .doOnNext(i -> blockingTask())
    .sequential()
    .subscribe()

Flux.just(1)
    .repeat(10)
    .flatMap(i -> Mono.fromCallable(() -> {blockingTask(); return i;}).subscribeOn(Schedulers.elastic()), 3)
    .subscribe();

这两种写法有什么区别呢，看起来没有区别。哪种写法更流行呢

写法

schedulers

flatmap

4 replies • 2021-12-17 13:34:22 +08:00

Tenlearn

Dec 16, 2021

哪种看着舒服不是一目了然

2i2Re2PLMaDnghL

Dec 16, 2021

不用 Java ，但感觉第二种不像人干事
如果维护人员脑子没问题的话，就必会把第一种的性能优化到至少不明显次于第二种。基础库对节能减排贡献非常巨大。

mmdsun

Dec 17, 2021 via iPhone

https://projectreactor.io/docs/core/release/reference/#faq.wrap-blocking 。文档用的 Mono.fromCallable

git00ll

Dec 17, 2021

@mmdsun 他这个的意思是将同步操作包装成异步操作，官方这样做没问题。
论坛里是要对 Flux 中的每一项进行一个堵塞 io 操作，是使用 parallel + runOn 的方式，还是使用 flatMap+subscribeOn 的方式做对比。
两种方式都能将同步任务发送到不同线程中执行，都能达到同样的目的，但是不知道区别与优劣，以及那种写法更好。