📌 📄 内容摘要:
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 ...
────────── 链接信息 ────────── 🔗 论坛链接: linux.do 📎 访问地址: https://linux.do/t/topic/325593/1 ─────────────────────────────
📢 来源:LINUX DO