可以或应该重用 Schedulers.newElastic 吗？

Question

寻找有关反应器调度程序的指导。

我想在后台运行某些 IO 任务，即向技术团队发送电子邮件。为了使其异步，我使用 Mono.fromRunnable 订阅了调度程序。

我可以选择使用 Schedulers.elastic() 或 Schedulers.newElastic()。我更喜欢后者，因为它允许我给它一个唯一的名称，这将有助于日志分析。

是否可以制作静态变量，例如

Scheduler emailSched = Schedulers.newElastic("email");

然后在我的 Mono 上订阅它，而不是每次都创建一个新的调度程序实例？

我只找到了What is the difference between Schedulers.newElastic and Schedulers.elastic methods?，这对我的问题没有多大帮助。

Answer 1

我应该每次都创建一个新的调度程序实例吗？

如果您不想这样做，没有技术原因需要这样做。在大多数情况下，这可能无关紧要。

主要区别在于：

• 如果你愿意，你可以给它一个不同的名字（简单）
• 任何单独的弹性调度程序都会缓存和重用它在后台创建的执行程序，默认超时为 60 秒。但是，该缓存不会在同名的不同调度程序实例之间共享。
• 您可以处置任何单独的弹性调度程序，而不会影响其他同名调度程序。

在你描述的情况下，这些都不是真正起作用的因素。

与上述分开，请注意Schedulers.boundedElastic() 现在是首选选项，尤其是对于包装阻塞 IO（这似乎是您在那里所做的）。