RxJava 源码解读分析 just

xiaoxiao2021-02-27  388

来看看RxJava Observable.just 方法,如下图:

可以看出,大部分just()方法是直接调用from()方法,上一篇我们已经讲解过from()内容,这里我们主要看看just(T t)这个方法,如下图:

看清楚了吧,我们这里说说SingleProducer和WeakSingleProducer。

SingleProducer,用了compareAndSet()这样的原子操作,来判断一个flag,用来保证,多线程操作同一个Observable时,是线程安全的,也这是保证onNext(data)被正确的,唯一的触发一次。

WeakSingleProducer,多线程操作同一个Observable时,onNext(data)有可能被触发2次以上,这是错误的。

转载请注明原文地址: https://www.6miu.com/read-5986.html

最新回复(0)