Project Reactor 从同一个执行器创建多个调度器

Question

在我的应用程序中，我有一个 java Executor，如果我从 Executor 的同一个实例创建多个 Scheduler，它会产生问题吗？ :

public class MyServiceController {
    @Autowired
    private Executor mainExecutor;

    public Object something() {
         return Flux.from(somethingElse())
                    .publishOn(Schedulers.fromExecutor(mainExecutor))
                    .toFuture()
    }

}

（或者有多个类实现此模式，它们都具有相同的 mainExecutor 实例）

Answer 1

在这两种情况下都应该没问题，相同的 Executor 将支持您从它创建的每个 Scheduler 产生的所有 Scheduler.Worker，如果它是一个ExecutorService（尽管包装器有不同的 Scheduler 实现）。

为了清楚起见，我仍然会考虑让 Scheduler 成为 Executor 旁边的单例。

Project Reactor 从同一个执行器创建多个调度器

Project Reactor create multiple scheduler from the same Executor

java

executorservice

project-reactor

flux