naomi233 在 关于WebFlux的并发疑问🤔 中发帖
为什么下面的代码的sequential()没有效果,没有按顺序订阅流
import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;
public class test {
public static void main(String[] args) {
Flux.range(1, 10)
.parallel() // 转换为并行流
.runOn(Schedulers.parallel()) // 指定并行执行的调度器
.map(i -> {
// System.out.println("Processing " + i + " on ...