Rxjava2实战--第四章 Rxjava的线程操作

1 调度器(Scheduler)种类

默认情况下，

Sheduler	作用
single	使用定长为1的线程池（new ScheduledThread Pool(1)）,重复利用这个线程
newThread	每次都启用线程，并在新线程中执行操作
computation	使用固定的线程池（Fixed Scheduler Pool）,大小为CPU核数，适用于CPU密集型计算
io	适合I/O操作（读写文件、读写数据库、网络信息交互等）所使用的Scheduler。行为模式和newThread()差不多，区别在于io()的内部实现是用一个无数量上限的线程池，，可以重用空闲的线程，因此多数情况下，io()比newThread()更有效率
trampoline	表示立即执行，如果当前线程有任务在执行，则会将其暂停，等插入进来的新任务执行完成之后，再接着执行原先未完成的任务。
Scheduleres.from	将java.util.concurrent.Executor转换成一个调度器实例，即可以自定义一个Excutor来作为调度器

RxJava的被观察者们在使用操作符时可以利用线程调度器---Scheduler来切换线程。

默认情况下不做任何线程处理， Observable Observer 处于同一线程中。如果想要切换线程，则可以使用 subscribeOn()和 observeOn()。

1 subscribeOn

subscribeOn 通过接收一个 Scheduler 参数，来指定对数据的处理运行在特定的线程调度器 Scheduler上。

若多次执行 subscribeOn ，则只有一次起作用。

在RxJava 链式操作中，数据的处理是自下而上的，这点与数据发射正好相反。如果多次调用 subcribeOn()，则最上面的线程切换最晚 ,所以就变成了只有第一次切换线程才有效。

2 onbserveOn

observeOn 同样接收一个 Scheduler 参数，用来指定下游操作运行在特定的线程调度器 Scheduler 上。

若多次执行 observeOn()，则每次都起作用，线程会一直切换。

若下游多次调用observeOn(),则线程会一直切换。每次切换线程，都会把对应的Observer对象的各个方法的处理执行在指定的线程中。