RXJS----Scheduler调度者

2017-03-24

什么是调度者？调度者控制着何时启动一个订阅和何时通知被发送。它有三个组件构成:

一个调度者是一个数据结构。它知道如何根据优先级或其他标准存储和排列任务。
一个调度者是一个执行上下文。它表示何处何时任务被执行(例如: immediately(立即), or in another callback mechanism(回调机制) such as setTimeout or process.nextTick, or the animation frame)
一个调度者具有虚拟的时钟。它通过调度器上的getter方法now()提供了“时间”的概念。在特定调度程序上调度的任务将仅仅遵守由该时钟表示的时间。

调度者使得你可以确定可观察对象在什么执行上下文中给观察者发送通知

下面的例子，我们使用常见的的可观察对象，它同步的发送三个数值1/2/3。使用observeOn操作符指定用于传递这些值的异步调度程序。

var observable = Rx.Observable.create(function (observer) {
  observer.next(1);
  observer.next(2);
  observer.next(3);
  observer.complete();
})
.observeOn(Rx.Scheduler.async);
console.log('just before subscribe');
observable.subscribe({
  next: x => console.log('got value ' + x),
  error: err => console.error('something wrong occurred: ' + err),
  complete: () => console.log('done'),
});
console.log('just after subscribe');

输出

just before subscribe
just after subscribe
got value 1
got value 2
got value 3
done

注意如何获取值…被发送在”just after subscribe “之后，这是不同于我们目前为止所看到的默认行为。这是因为observeOn（Rx.Scheduler.async）在Observable.create和最终的Observer之间引入了一个代理Observer。让我们重命名一些标识符，使这个重要的区别在下面代码中显而易见：

var observable = Rx.Observable.create(function (proxyObserver) {
  proxyObserver.next(1);
  proxyObserver.next(2);
  proxyObserver.next(3);
  proxyObserver.complete();
})
.observeOn(Rx.Scheduler.async);
var finalObserver = {
  next: x => console.log('got value ' + x),
  error: err => console.error('something wrong occurred: ' + err),
  complete: () => console.log('done'),
};
console.log('just before subscribe');
observable.subscribe(finalObserver);
console.log('just after subscribe');
proxyObserver在 observeOn(Rx.Scheduler.async)被创建，它的next通知函数大约如下:
var proxyObserver = {
  next: (val) => {
    Rx.Scheduler.async.schedule(
      (x) => finalObserver.next(x),
      0 /* delay */,
      val /* will be the x for the function above */
    );
  },
  // ...
}

Async调度操作符和setTimeout或setInterval一起起作用，虽然延期可能是0。通常情况下，在js中，setTimeout(fn, 0)被当作使fn在下一个时间循环迭代中最早执行。这就解释了为什么got value 1在just after subscribe之后执行。

scheduler Types

Scheduler	Purpose
null	通过不传递任何调度程序，通知被同步和递归地传递。用于恒定时操作或尾递归操作。
Rx.Scheduler.queue	Schedules on a queue in the current event frame (trampoline scheduler). Use this for iteration operations.
Rx.Scheduler.asap	Schedules on the micro task queue, which uses the fastest transport mechanism available, either Node.js’ process.nextTick() or Web Worker MessageChannel or setTimeout or others. Use this for asynchronous conversions.
Rx.Scheduler.async	Schedules work with setInterval. Use this for time-based operations.

翻译不全