Spring Webflux项目Reactor中的调度器

Question

Project Reactor很棒，我可以很容易地切换一个线程来处理另一个线程上的某些部分，但我已经查看了schedulers.fromExecutorService（）方法，该方法每次都会分配新的ExecutorService。因此，当调用此方法时，总是会创建调度器并再次分配调度器。我不确定，但我认为这可能会导致内存泄漏...

Mono<String> sometext() {
return Mono
.fromCallable(() -> "" )
.subscribeOn(Schedulers.newParallel("my-custom));
}

我想知道如何将调度器注册为bean，它单例所以只会分配一次，而不是每次都在构造函数中创建他。很多博客都是这样解释线程模型的。

...
private final Scheduler scheduler = Schedulers.newParallel("my-custom);
..
Mono.fromCallable(() -> "" ).subscribeOn(scheduler)

Answer 1

schedulers.newparallel()确实会在每次调用它时创建一个新的调度器，它带有一个相关的backed threadpool-所以是的，您是正确的，如果您使用该方法，那么您希望确保在某个地方存储对它的引用，以便可以重用它。简单地提供相同的name参数不仅会检索新的调度器，还会创建一个具有相同名称的不同调度器。

如何做到这一点取决于您--可以通过spring bean（只要它是单例而不是原型bean！）、字段或其他最适合您的用例的方法。

但是，在所有这些之前，我首先考虑您是否确实需要创建一个单独的并行调度器。schedulers.parallex()调度器是一个默认的并行调度器，可用于并行计算tin（它不会在每次调用时创建一个新的调度器），除非您出于某种原因需要为不同的服务单独配置并行调度器，否则最好的做法就是使用它。