原创

RxAndroid深入理解

注:本文的分析基于RxAndroid 1.2.1

现在项目里面大多都已经使用了rxjava, 因此对于很多rxjava的扩展库,也都可以使用在项目里了。

RxAndroid 已经成为标配了,基本只要使用了Rxjava, 你肯定能看见RxAndroid的身影。

使用场景:

Observable.just("one", "two", "three", "four", "five")
        .subscribeOn(Schedulers.newThread())
        .observeOn(AndroidSchedulers.mainThread())
        .subscribe(/* an Observer */);

很简单,就是指定到主线程上,即UI线程上,所以subscribe里的内容就会执行在主线程上。

或者其他线程的Looper

Looper backgroundLooper = // ...
Observable.just("one", "two", "three", "four", "five")
        .observeOn(AndroidSchedulers.from(backgroundLooper))
        .subscribe(/* an Observer */)

这种使用方式,就是把后台线程所绑定的Looper作为AndroidSchedulers的参数, 那么这时实际上等同于 :

...
observeOn(Scheduler.io());

因此这种方式下,subscribe 里的代码是执行在backgroundLooper所绑定的线程。

代码结构:

RxAndroid深入理解

Paste_Image.png

实现分析:

既然使用的入口是AndroidScheduler 那就重这里开始分析。

首先看看AndroidScheduler的创建:

RxAndroid深入理解

Paste_Image.png

搭眼一看,饿汉式的单例, 并且这个单例是使用AtomicReference的,原子操作,保证多线程情况下,线程获取的值都是最新的,正确的。实例化用到了RxAndroidPlugins, 看下:

RxAndroid深入理解

Paste_Image.png

同样是AtomicReference ,同样是单例。

RxAndroid深入理解

Paste_Image.png

又引用到RxAndroidSechedulersHook

RxAndroid深入理解

Paste_Image.png

这是个什么鬼,搞了半天最后getMainThreadScheduler() 返回null. 再回头看看前面AndroidScheduler实例化的地方。

RxAndroid深入理解

Paste_Image.png

soga, 空的话直接返回一个LooperScheduler, 否则直接使用。

这就是问题了,为什么要绕这么大一圈?

我觉得秘密在RxAndroidSchedulersHook里的一个方法,如下:

RxAndroid深入理解

Paste_Image.png

那么这个方法在哪里被调用了呢? 这个问题先放着,后面会讲到。

先来看看注释,大概的意思是,该方法在把action 交给Scheduler处理之前被执行, 可以用于

包装/装饰/日志记录(翻译过来好别扭!), 默认值只是传递作用,直接返回。

如果你仔细看看Rxjava RxJavaSchedulersHook 类,你会发现如出一辙, 一模一样!!!

连注释都长一样!

这里是把UI线程的Looper作为参数创建了一个LoopScheduler.

再进去看看LooperScheduler:

RxAndroid深入理解

Paste_Image.png

LooperScheduler 继承自Scheduler, 因此必须实现createWorker方法。

Worker是个什么东东?

RxAndroid深入理解

Paste_Image.png

实际上是Scheduler里 的一个静态抽象类,实现了Subscription接口,因此也就有unSubscriber方法。

可以取消订阅,但是Worker并没有实现取消订阅方法,而是交给子类去实现,比如这里的HandlerWorker就实现了Worker抽象类,下面是截取的核心部分:

RxAndroid深入理解

Paste_Image.png

HandlerWorker实现了schedule方法,一个是有延时的,一个是无延时的。 从代码看首先判断了是否被取消订阅了, 取消了则直接返回,不做任何处理,否者接着走。

哎呦喂! 哎呦喂! 这不是RxAndroidSchedulersHook 里的那个我们之前放着的方法吗?

在这里被调用了。

接着走这里又跳出来个ScheduledAction, 贴出代码!

RxAndroid深入理解

Paste_Image.png

RxAndroid深入理解

Paste_Image.png

从代码中不难看出, 在LooperScheduler 中创建的handler, 交给HandlerWorker后又交给了ScheduledAction。 该类实现了Runnable 接口,run方法里面调用了action.call() ;看来这里才是真正调用的地方,然后如果发生异常就调用RxjavaPlugin 触发错误处理。

ScheduledAction同样实现了Subscription接口, 取消也很简单,handler removeCallbacks(this).。

看完了ScheduledAction是不是感觉一目了然了,接着上面HandlerWorker的schedule方法讲,

后面从Message池中获取了一个Message并且把message的Callback参数设置为ScheduledAction的实例, 然后后面handler.sendMessageDelayed(message, unit.toMillis(delayTime)); 延时发送这条消息。 看到这你应该明白了,就是利用handler把消息发送到了looper所在的线程! 因此你传递进去的Looper绑定在什么线程, 我们的action(订阅者)就在哪个线程执行!

而我们平时都是使用AndroidScheduler.mainThread(); 默认传递的就是UI线程的Looper!

有的小伙伴说,不对吧,我没看到接收处理消息的地方啊! 楼主你个坑!

实际上这就是handler你了解的不够细:

(Handler.java)

RxAndroid深入理解

Paste_Image.png

看到了吗? 这里是handler接收到Looper分配的消息的处理, 先是判断了msg有没有callback, 有的话就不会调用handleMessage(msg)了,而是调用了handlerCallback(msg); 从而调用了runnable的run方法,也就是ScheduledAction的run()方法.

RxAndroid深入理解

Paste_Image.png

RxAndroid中还有一个类没讲 MainThreadSubscription, 下篇文章会讲下RxBinding,里面会讲到,这里就不多说了。

 

 

来自:http://www.jianshu.com/p/8292ea39c38e

 

正文到此结束
Loading...