Mono.just() 在链式构建阶段立即执行参数计算，若参数本身含阻塞逻辑（如 sleep()），会导致主线程阻塞；真正实现非阻塞需改用 Mono.fromCallable() 并配合真正的异步/非阻塞操作（如 delayElement），而非简单封装阻塞方法。
reactor 中 mono.just() 在链式构建阶段立即执行参数计算，若参数本身含阻塞逻辑（如 `sleep()`），会导致主线程阻塞；真正实现非阻塞需改用 `mono.fromcallable()` 并配合真正的异步/非阻塞操作（如 `delayelement`），而非简单封装阻塞方法。
在响应式编程中，一个常见误解是：只要将代码包装进 Mono 或 Flux，就能自动获得非阻塞性。事实恰恰相反——Reactor 不会魔法般地将同步阻塞调用转为异步。它仅提供调度、背压、组合等响应式能力，底层执行仍依赖实际 I/O 模型与线程行为。
关键在于理解 Mono.just() 的语义：它用于立即、同步地发射一个已知的、预先计算好的值。这意味着传入的表达式（如 getString()）会在 Mono.just(...) 被调用时立刻在当前线程执行，而非延迟到订阅或指定 Scheduler 上运行。
以问题中的第二个测试为例：
Mono.just(getString()) // ⚠️ getString() 在此处同步阻塞主线程！
.map(...) // 此处才进入 subscribeOn 指定的 parallel 线程
.subscribeOn(Schedulers.parallel())
.subscribe(...);getString() 内部的 sleep(2000) 在 for 循环体内逐次执行，导致整个循环被串行阻塞——这与 Reactor 无关，而是 Java 方法调用本身的同步特性所致。
✅ 正确做法：使用 Mono.fromCallable()
它将计算逻辑延迟到订阅时执行，并可受 subscribeOn() 控制线程上下文：
Mono.fromCallable(this::getString) // ✅ getString() 延迟到 parallel 线程执行
.map(s -> {
System.out.println("Thread:" + Thread.currentThread().getName() + " " + s);
try { Thread.sleep(2000); } catch (InterruptedException e) { /* handle */ }
return s.length();
})
.subscribeOn(Schedulers.parallel())
.subscribe(System.out::println);此时 getString() 会在 parallel 线程池中并发执行，循环体不再阻塞，输出 after MONO 将立即打印。
Orderly React SDK 钩子使用参考指南，包括 useOrderEntry、usePositionStream、useOrderbookStream、useCollateral 等。
⚠️ 但请注意：即使使用 fromCallable，sleep() 依然会阻塞该 parallel 线程。在生产环境中，这会耗尽线程池资源，违背响应式设计初衷。真正的非阻塞应基于事件驱动模型（如 Netty、R2DBC、WebClient），或使用 Reactor 提供的非阻塞时间工具：
public static Mono<String> getStringAsync() {
return Mono.delay(Duration.ofSeconds(2)) // 非阻塞等待（基于 HashedWheelTimer）
.thenReturn("Hello World"); // 延迟后发射值
}Mono.delay() 底层不占用线程，仅注册定时任务，因此可安全并发调用数十甚至数百次，而不会导致线程饥饿。
? 总结最佳实践：
- ❌ 避免在 Mono.just() 参数中执行任何耗时或阻塞操作；
- ✅ 使用 Mono.fromCallable() / Mono.defer() 将延迟计算纳入响应式链；
- ✅ 用 Mono.delay()、Mono.timeout()、Flux.interval() 等替代 Thread.sleep()；
- ✅ 数据库/HTTP 调用务必选用非阻塞驱动（如 R2DBC、WebClient），而非 JDBC/RestTemplate；
- ✅ 始终通过 subscribeOn() 显式指定执行上下文，避免意外在主线程或 IO 线程中执行 CPU 密集逻辑。
记住：Reactor 是“编排引擎”，不是“阻塞转换器”。非阻塞的本质在于不阻塞线程，而非“用了 Mono 就不卡”。
