调度器（Scheduler）

待定

待定

调度器的种类

可以从Schedulers类的描述中的工厂方法获得调度器。下表显示了RxGroovy中通过这些方法可用的调度器的种类：

RxGroovy事件源操作符的默认调度器

RxGroovy中的一些事件源操作符具有变体，允许设置操作符用于（至少某些部分）其操作的调度器。其他不在任何特定的调度器上运行，或在指定的默认调度器上运行。具有特定默认调度器的那些包括：

测试调度器

TestScheduler允许对调度器的时钟行为进行手动微调。这对于测试依赖于明确的时间安排的动作是非常有用的。此调度器还有三种方法：

advanceTimeTo(time,unit)

将调度器的时钟修改到特定时间点

advanceTimeBy(time,unit)

将调度器的时钟向前推进一段特定的时间

triggerActions( )

根据调度器的时钟启动任何已安排的时间等于或早于当前时间的未启动操作

参考

• Testing Reactive Applications by Ben Christensen
• RxJava Threading Examples by Graham Lea
• Advanced RxJava: Schedulers (part 1) (part 2) (part 3) (part 4) by Dávid Karnok

调度器的种类

可以从Schedulers类的描述中的工厂方法获得调度器。下表显示了RxJava中通过这些方法可用的调度器的种类：

RxJava 1.x事件源操作符的默认调度器

RxJava 1.x中的一些事件源操作符具有变体，允许设置操作符用于（至少某些部分）其操作的调度器。其他不在任何特定的调度器上运行，或在指定的默认调度器上运行。具有特定默认调度器的那些包括：

使用调度器

不仅可以将这些调度器传递给RxJava事件源操作符，还可以使用它们来安排自己的订阅工作。以下示例使用Scheduler.Worker类的调度方法让其运行在newThread的调度器上：

worker = Schedulers.newThread().createWorker();
worker.schedule(new Action0() {

    @Override
    public void call() {
        yourWork();
    }

});
// some time later...
worker.unsubscribe();

递归调度器

在Worker对象使用schedule然后使用schedule(this)递归的调用调度：

worker = Schedulers.newThread().createWorker();
worker.schedule(new Action0() {

    @Override
    public void call() {
        yourWork();
        // recurse until unsubscribed (schedule will do nothing if unsubscribed)
        worker.schedule(this);
    }

});
// some time later...
worker.unsubscribe();

检查或设置取消订阅状态

Worker对象的类实现了Subscription接口， 使用isUnsubscribed和unsubscribe 方法， 可以在被订阅后停止运行或者从调度任务中取消订阅：

Worker worker = Schedulers.newThread().createWorker();
Subscription mySubscription = worker.schedule(new Action0() {

    @Override
    public void call() {
        while(!worker.isUnsubscribed()) {
            status = yourWork();
            if(QUIT == status) { worker.unsubscribe(); }
        }
    }

});

当Worker已经变成Subscription，就可以（并应该、最终）调用它的unsubscribe方法来表示它可以停止工作并释放资源：

worker.unsubscribe();

延迟和定期调度器

可以延迟对给定计划程序的操作，直到超过某个时间跨度通过使用schedule一个实现。以下示例调度someAction在 someScheduler调度器的时钟经过500ms后运行:

someScheduler.schedule(someAction, 500, TimeUnit.MILLISECONDS);

另一种Scheduler方法允许安排定期执行操作。以下示例调度someAction在someScheduler调度器时钟经过500ms后运行，然后每隔250ms也都运行：

someScheduler.schedulePeriodically(someAction, 500, 250, TimeUnit.MILLISECONDS);

测试调度器

TestScheduler允许对调度器的时钟行为进行手动微调。这对于测试依赖于明确的时间安排的动作是非常有用的。此调度器还有三种方法：

advanceTimeTo(time,unit)

将调度器的时钟修改到特定时间点

advanceTimeBy(time,unit)

将调度器的时钟向前推进一段特定的时间

triggerActions( )

根据调度器的时钟启动任何已安排的时间等于或早于当前时间的未启动操作

参考

• RxJava Threading Examples by Graham Lea
• Testing Reactive Applications by Ben Christensen
• Advanced RxJava: Schedulers (part 1) (part 2) (part 3) (part 4) by Dávid Karnok