subscribeOn和observeOn的关系,使用注意事项

在使用Rxjava的过程中,经常碰到切换线程的情况,该如何正确调用该API呢?

这里有一位大神的总结:

下面提到的“操作”包括产生事件、用操作符操作事件以及最终的通过 subscriber 消费事件；只有第一subscribeOn() 起作用（所以多个 subscribeOn() 无意义）；这个 subscribeOn() 控制从流程开始的第一个操作，直到遇到第一个 observeOn()；observeOn() 可以使用多次，每个 observeOn() 将导致一次线程切换()，这次切换开始于这次 observeOn() 的下一个操作；不论是 subscribeOn() 还是 observeOn()，每次线程切换如果不受到下一个 observeOn() 的干预，线程将不再改变，不会自动切换到其他线程。

简单版:

subscribeOn的调用切换之前的线程。observeOn的调用切换之后的线程。observeOn之后，不可再调用subscribeOn 切换线程

例子:

Observable .map // 操作1 .flatMap // 操作2 .subscribeOn(io) .map //操作3 .flatMap //操作4 .observeOn(main) .map //操作5 .flatMap //操作6 .subscribeOn(io) //!!特别注意 .subscribe(handleData)

自我总结:

在上述例子中,操作1234都是运行在IO线程的,56运行在main线程;

参考:

http://blog.csdn.net/jdsjlzx/article/details/51685769