上次说的两个例子，事件的发出和消费都是在同一个线程的。如果只用上面的方法，实现出来的只是一个同步的观察者模式。观察者模式本身的目的就是异步机制，因此异步对于 RxJava 是至关重要的。而要实现异步，则需要用到 RxJava 的另一个概念： Scheduler
。本文就来介绍一下Scheduler的用法：
- 线程控制 —— Scheduler (一)
默认情况下， RxJava 遵循的是线程不变的原则，即：在哪个线程调用 subscribe()
，就在哪个线程生产事件；在哪个线程生产事件，就在哪个线程消费事件。如果需要切换线程，就需要用到 Scheduler
（调度器）。
- Scheduler 的 API (一)
在RxJava 中，Scheduler
——调度器，相当于线程控制器，RxJava 通过它来指定每一段代码应该运行在什么样的线程。RxJava 已经内置了几个 Scheduler
，它们已经适合大多数的使用场景：
Schedulers.immediate()
: 直接在当前线程运行，相当于不指定线程。这是默认的 Scheduler
。
Schedulers.newThread()
: 总是启用新线程，并在新线程执行操作。
Schedulers.io()
: I/O 操作（读写文件、读写数据库、网络信息交互等）所使用的 Scheduler
。行为模式和 newThread()
差不多，区别在于 io()
的内部实现是是用一个无数量上限的线程池，可以重用空闲的线程，因此多数情况下 io()
比 newThread()
更有效率。不要把计算工作放在 io()
中，可以避免创建不必要的线程。
Schedulers.computation()
: 计算所使用的 Scheduler
。这个计算指的是 CPU 密集型计算，即不会被 I/O 等操作限制性能的操作，例如图形的计算。这个 Scheduler
使用的固定的线程池，大小为 CPU 核数。不要把 I/O 操作放在 computation()
中，否则 I/O 操作的等待时间会浪费 CPU。
另外， Android 还有一个专用的 AndroidSchedulers.mainThread()
，它指定的操作将在 Android 主线程运行。
有了这几个 Scheduler
，就可以使用 subscribeOn()
和 observeOn()
两个方法来对线程进行控制了。 * subscribeOn()
: 指定 subscribe()
所发生的线程，即 Observable.OnSubscribe
被激活时所处的线程。或者叫做事件产生的线程。 * observeOn()
: 指定 Subscriber
所运行在的线程。或者叫做事件消费的线程。
有了这几个 Scheduler
，就可以使用 subscribeOn()
和 observeOn()
两个方法来对线程进行控制了。 * subscribeOn()
: 指定 subscribe()
所发生的线程，即 Observable.OnSubscribe
被激活时所处的线程。或者叫做事件产生的线程。 * observeOn()
: 指定 Subscriber
所运行在的线程。或者叫做事件消费的线程。
上面这段代码中，由于 subscribeOn(Schedulers.io())
的指定，被创建的事件的内容 1到11
将会在 IO 线程发出；而由于 observeOn(AndroidScheculers.mainThread()
) 的指定，因此 subscriber
数字的打印将发生在主线程 。事实上，这种在 subscribe()
之前写上两句 subscribeOn(Scheduler.io())
和 observeOn(AndroidSchedulers.mainThread())
的使用方式非常常见，它适用于多数的 『后台线程取数据，主线程显示』的程序策略。
然后会在最后显示在textview主线程上。
图片是是一样道理
- 变换
RxJava 提供了对事件序列进行变换的支持，这是它的核心功能之一，也是大多数人说『RxJava 真是太好用了』的最大原因。所谓变换，就是将事件序列中的对象或整个序列进行加工处理，转换成不同的事件或事件序列。概念说着总是模糊难懂的，来看 API。
这里出现了一个叫做 Func1
的类。它和 Action1
非常相似，也是 RxJava 的一个接口，用于包装含有一个参数的方法。 Func1
和 Action
的区别在于， Func1
包装的是有返回值的方法。另外，和 ActionX
一样， FuncX
也有多个，用于不同参数个数的方法。FuncX
和 ActionX
的区别在 FuncX
包装的是有返回值的方法。
可以看到，map()
方法将参数中的 String
对象转换成一个 Bitmap
对象后返回，而在经过 map()
方法后，事件的参数类型也由 String
转为了 Bitmap
。这种直接变换对象并返回的，是最常见的也最容易理解的变换。不过 RxJava 的变换远不止这样，它不仅可以针对事件对象，还可以针对整个事件队列，这使得 RxJava 变得非常灵活。我列举几个常用的变换：
● map()
: 事件对象的直接变换，具体功能上面已经介绍过。它是 RxJava 最常用的变换
● flatMap()
: 这是一个很有用但非常难理解的变换，因此我决定花多些篇幅来介绍它。
首先假设这么一种需求：假设有一个数据结构『学生』，现在需要打印出一组学生的名字。实现方式很简单：
image.png
很简单。那么再假设：如果要打印出每个学生所需要修的所有课程的名称呢？（需求的区别在于，每个学生只有一个名字，但却有多个课程。）首先可以这样实现：
image.png
依然很简单。那么如果我不想在 Subscriber
中使用 for 循环，而是希望 Subscriber
中直接传入单个的 Course
对象呢（这对于代码复用很重要）？用 map()
显然是不行的，因为 map()
是一对一的转化，而我现在的要求是一对多的转化。那怎么才能把一个 Student 转化成多个 Course 呢？
这个时候，就需要用 flatMap()
了：
image.png
关注微信公众号获得更多内容：
