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

问题描述

在我的应用程序中,我只有一个Java Executor,如果我从Scheduler的同一实例创建多个Executor,它会产生问题吗?

public class MyServiceController {
    @Autowired
    private Executor mainExecutor;

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

}

(或具有多个实现此模式的类,它们全部具有相同的mainExecutor实例)

解决方法

在两种情况下都应该很好,相同的Executor将支持您从其中创建的每个Scheduler.Worker产生的所有Scheduler,如果它是{{ 1}}(尽管包装器使用了不同的ExecutorService实现)。

为清楚起见,我仍然考虑将Scheduler放在Scheduler旁边的单身。