
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(); 这两种写法有什么区别呢,看起来没有区别。哪种写法更流行呢
1 Tenlearn Dec 16, 2021 哪种看着舒服不是一目了然 |
2 2i2Re2PLMaDnghL Dec 16, 2021 不用 Java ,但感觉第二种不像人干事 如果维护人员脑子没问题的话,就必会把第一种的性能优化到至少不明显次于第二种。基础库对节能减排贡献非常巨大。 |
3 mmdsun Dec 17, 2021 via iPhone https://projectreactor.io/docs/core/release/reference/#faq.wrap-blocking 。文档用的 Mono.fromCallable |