RxJS 是一个强大的 JavaScript 库，它的核心是一种异步数据流编程模型。它提供了许多操作符和调度器（scheduler）来方便地处理异步编程。调度器是 RxJS 中一个十分重要的概念。调度器提供了对异步代码执行时的控制，并可以控制代码在何时、何处、何种方式下被执行。
什么是调度器？
调度器是 RxJS 中的一个概念，它可以控制 Observable 对象的传输行为。当一个 Observable 对象被 subscribed 之后，它会开始发出数据。这个数据发生的顺序和时间是难以预料的，但 RxJS 提供了调度器来提供精细的控制能力。
在 RxJS 中，调度器可以被认为是一个执行上下文，其中包含了一个队列，它能够管理交付给它的任务（Observable 对象）的调用时间和地点。RxJS 中有许多内置的调度器，比如 asap、async、queue 等等。同时，RxJS 也提供了一个定制化调度器的接口，使得我们可以自己定制调度器，以更好地适应我们的异步需求。
RxJS 中的常用调度器
asap 调度器
asap 调度器是 RxJS 中默认的调度器。它会在同一事件循环中尽快地执行任务（发出数据）。这可以保证任务有序地执行。
示例代码：
import { fromEvent, asapScheduler } from 'rxjs';
fromEvent(document, 'click', asapScheduler).subscribe(() => {
console.log('发出数据');
});上述代码中，在 document 上发生点击事件后，使用 asapScheduler 调度器发出数据，此时 console.log 会输出。
async 调度器
async 调度器会在订阅后尽快地异步执行任务，而不是立即执行。它通过将任务放到 setTimeout 中来异步执行任务。这可以确保任务不会阻塞 UI 线程。
示例代码：
import { fromEvent, asyncScheduler } from 'rxjs';
fromEvent(document, 'click', asyncScheduler).subscribe(() => {
console.log('发出数据');
});上述代码中，在 document 上发生点击事件后，使用 asyncScheduler 调度器发出数据，此时 console.log 会输出。
queue 调度器
queue 调度器是一种比较底层但十分强大的调度器。它会尝试执行每一个任务，但只会在前一个任务结束后才会调用下一个任务。这样做可以确保任务的有序执行。
示例代码：
import { fromEvent, queueScheduler } from 'rxjs';
fromEvent(document, 'click', queueScheduler).subscribe(() => {
console.log('发出数据');
});上述代码中，在 document 上发生点击事件后，使用 queueScheduler 调度器发出数据，此时 console.log 会输出。
定制调度器
RxJS 提供了 SchedulerLike 接口，使得我们可以自己定制调度器。我们只需要实现其中的 schedule 方法，就可以将任务（Observable 对象）添加到队列中，并在合适的时机调用这些任务。下面是一个定制化调度器的示例代码：
-- -------------------- ---- -------
------ - -------------- ----- - ---- -------
----- --------------- ---------- ------------- -
------------------- ----- ------- --
------ ----------------- -
---------------- ------------ -------- ------
------ ------------------------
-
-
----- --------- - --- --------------------------
--------------------- -- -
----------------------
---上述代码中，我们自定义了一个名为 CustomScheduler 的调度器，并通过实现 schedule 方法来完成任务的调度。在调度器被 subscribe 之后，schedule 方法将负责执行任务。
RxJS 中的调度器相关操作
除了以上介绍过的调度器外，RxJS 还提供了一些与调度器相关的操作符。
observeOn 操作符
observeOn 操作符可以指定调度器，用于控制消费者端的数据处理。
示例代码：
import { fromEvent, asyncScheduler } from 'rxjs';
import { observeOn } from 'rxjs/operators';
fromEvent(document, 'click')
.pipe(observeOn(asyncScheduler))
.subscribe(() => {
console.log('发出数据');
});上述代码中，使用 observeOn 操作符指定了使用 asyncScheduler 调度器来处理数据。
subscribeOn 操作符
subscribeOn 操作符可以指定调度器，用于控制生产者端的数据处理。这在网络请求等 I/O 密集型操作中，可以帮助我们更好地控制异步执行的顺序。
示例代码：
import { fromEvent, asyncScheduler } from 'rxjs';
import { subscribeOn } from 'rxjs/operators';
fromEvent(document, 'click')
.pipe(subscribeOn(asyncScheduler))
.subscribe(() => {
console.log('发出数据');
});上述代码中，使用 subscribeOn 操作符指定了使用 asyncScheduler 调度器来生产数据。
总结
调度器是 RxJS 中的一个重要概念，它可以控制异步代码执行的方式和时间。RxJS 提供了许多内置的调度器，同时也提供了定制调度器的接口。在实际应用中，我们可以通过使用 observeOn 和 subscribeOn 等操作符来更好地控制数据流。在多个异步操作中，选择合适的调度器和操作符，可以帮助我们更好地处理复杂的异步逻辑，提高代码的可读性和维护性。
来源：JavaScript中文网 ，转载请注明来源 https://www.javascriptcn.com/post/64ac476948841e9894851e0e