相关示例源码:github.com/chentianmin… 功能分析 public final Flux<T> subscribeOn(Scheduler scheduler, boolean requestOnSeparateThread) 在subscribe的时候进行线程切换,subscribeOn()使得它上游的订阅阶段以及整个消费阶段异步执行。 各参数含义如下: scheduler:线程切换的调度器,Scheduler用来生成实际执行异步任务的Worker。 requestOnSeparateThread:是否需要在Worker上执行requ...