为何Project Reactor日志总是在main线程打印？如何验证其多线程运行？

Reactor本身没有绑定固定线程，默认的执行线程完全继承触发订阅的线程。你观察到日志都在main线程输出，本质是因为你写的测试代码没有显式指定调度器，且是在main线程中调用subscribe()方法触发数据流订阅，所以整个数据流的处理、日志打印逻辑都会默认在main线程上运行。

很多新手入门写的Demo都不会主动做线程切换，自然所有操作都跑在触发订阅的main线程上，这是符合Reactor设计的正常现象。

你可以通过以下两种方式验证线程切换效果：

• 打印当前线程名称：你可以在数据流的任意操作符回调中打印Thread.currentThread().getName()，也可以直接使用Reactor内置的log()操作符，它会自动输出当前操作所属的线程名，示例代码如下：

import reactor.core.publisher.Flux;
import reactor.core.scheduler.Schedulers;

public class ReactorThreadTest {
    public static void main(String[] args) throws InterruptedException {
        Flux.range(1, 3)
                // 指定后续操作切换到并行调度器的线程池执行
                .publishOn(Schedulers.parallel())
                .doOnNext(num -> System.out.printf("处理元素%d，当前线程：%s%n", num, Thread.currentThread().getName()))
                .log()
                .subscribe();
        // 防止main线程提前退出导致异步逻辑未执行
        Thread.sleep(1000);
    }
}

运行上述代码后，你会看到处理元素的日志以及log()操作符输出的日志，所属线程都是parallel-*格式的并行调度器线程，而非main线程。

• 显式切换不同调度器验证：你可以分别用Schedulers.boundedElastic()、Schedulers.single()等不同调度器做publishOn/subscribeOn切换，重复运行代码，即可看到不同的线程名输出，确认响应式代码可以运行在不同线程上。

注意：如果你使用了异步调度器，一定要在测试代码末尾添加阻塞等待逻辑（比如上述的Thread.sleep()，或者调用block()/blockLast()方法等待数据流执行结束），否则main线程执行完订阅逻辑就会直接退出，JVM随之终止，你将看不到异步线程的执行日志，误以为线程切换未生效。

内容的提问来源于stack exchange，提问作者akil nishman