什么是 RxJS 中的“调度程序”

Question

我在文档中经常看到术语Scheduler。

但是，这个词是什么意思？我什至不知道如何使用所谓的Scheduler。官方文档没有告诉我 Scheduler 到底是什么。这只是 RxJS 中的一个常见概念还是特定概念？

Answer 1

Rx 调度程序提供了一种抽象，允许调度工作在未来运行，而调用代码无需了解用于调度工作的机制。

每当 Rx 方法需要生成通知时，它都会在调度程序上安排工作。通过为 Rx 方法提供调度程序而不是使用默认值，您可以巧妙地控制这些通知的发送方式。

在 Rx 的服务器端实现（例如 Rx.NET）中，调度程序发挥着重要作用。它们允许您在线程池或专用线程上安排繁重的工作，并在 UI 线程上运行最终订阅，以便更新您的 UI。

在使用 RxJs 时，实际上很少需要担心大多数方法的调度程序参数。由于 JavaScript 本质上是单线程的，因此调度选项并不多，默认调度程序通常是正确的选择。

唯一真正的选择是：

• immediateScheduler - 立即同步运行工作。有点像根本不使用调度程序。因此，计划的工作可以保证同步运行。
• currentThreadScheduler - 与immediateScheduler 类似，工作立即运行。但是，它不会递归地运行工作。因此，如果工作正在运行并安排更多工作，那么额外的工作将被放入队列中，以便在当前工作完成后运行。因此工作有时同步运行，有时异步运行。此调度程序可用于避免堆栈溢出或无限递归。例如，Rx.Observable.of(42).repeat().subscribe() 在immediate 调度程序上运行会导致无限递归，但由于return 默认在currentThread 调度程序上运行，因此可以避免无限递归。
• timeoutScheduler - 唯一支持计划在未来运行的工作的调度程序。本质上使用setTimeout 安排所有工作（尽管如果您安排工作“现在”运行，那么它使用其他更快的异步方法来安排工作）。保证在此调度程序上安排的任何工作都是异步运行的。

现在可能还有更多，比如在浏览器动画帧上调度工作的调度器等等。

如果您尝试编写可测试的代码，那么您几乎总是希望提供调度程序参数。这是因为在您的单元测试中，您将创建 testScheduler 实例，这将让您的单元测试控制您的 Rx 代码使用的时钟（从而控制操作的确切时间）。