Project Reactor的默认调度器是什么？

Great question! Let's break this down clearly:

当你的反应式链里既没有调用subscribeOn()也没有调用publishOn()时，确实存在一个默认的执行上下文，但它并不是一个专门的Reactor调度器实例——它就是发起subscribe()调用的那个线程。

核心逻辑：线程继承原则 #

Reactor的设计遵循「调用线程继承」的规则：整个反应式链的所有操作（包括数据源生成、中间操作符处理、下游订阅回调）都会在你调用subscribe()的线程上执行，不会自动切换到其他线程池，直到你显式使用subscribeOn或publishOn指定调度器。

举个直观的代码例子：

Flux.just("a", "b", "c")
    .map(str -> {
        System.out.println("Map operation running on thread: " + Thread.currentThread().getName());
        return str.toUpperCase();
    })
    .subscribe(result -> System.out.println("Subscribe callback running on thread: " + Thread.currentThread().getName()));

如果在主线程运行这段代码，你会看到所有输出里的线程名都是main——从map到订阅回调，全程复用了发起订阅的线程。

常见误区澄清 #

很多人会误以为Reactor有一个全局的默认调度器（比如类似Schedulers.default()这样的东西），但实际上并没有。Reactor的设计理念是尽量避免不必要的线程切换，只有当你明确需要异步执行、线程隔离时，才需要手动指定合适的调度器（比如Schedulers.parallel()用于CPU密集型任务，Schedulers.boundedElastic()用于IO密集型任务）。

内容的提问来源于stack exchange，提问作者a.khakh