Android架构组件之LiveData源码解析

LiveData是Google发布的一个架构组件,它是一个数据持有类,并且数据可以被观察。区别于普通的被观察者,LiveData最大的特点是具备生命周期感知能力,即它仅更新处于活动生命周期状态的应用程序组件观察者(例如Activity/Fragment)。因此,LiveData可以很好的解决内存泄漏问题,以及常见的view空指针异常。

一、LiveData如何感知生命周期

Android架构组件之Lifecycle源码解析一文中,我们了解到Lifecycle-Aware组件的核心就是生命周期感知,要明白LiveData为什么能感知生命周期,就要以Lifecycle-Aware组件的原理为基础。由于26.1.0及更高版本Support支持库中的Activity和Fragment已经实现了LifecycleOwner接口,因此Activity/Fragment就是LifecycleOwner,而且它们内部都会有一个LifecycleRegistry来存放生命周期State、Event等。通过Lifecycle-Aware源码分析,我们可以知道在初始化Lifecycle组件时会为每个Activity/Fragment添加一个ReportFragment(无UI界面的Fragment),当Activity执行相应生命周期方法的时候,也会同步的执行ReportFragment的生命周期方法。因此,Lifecycle组件的核心就是通过无UI界面的Fragment来实现生命周期的监听,它会在执行其生命周期方法的时候更新LifecycleRegistry里的生命周期State、Event,,并且通过handleLifecycleEvent()方法来通知对应的观察者。

基于Lifecycle组件生命周期感知原理,那么只要让LiveData注册对Activity/Fragment的生命周期的监听,那么LiveData自然也就拥有了生命周期感知能力。具体看一下LiveData的源码实现:

    public void observe(@NonNull LifecycleOwner owner, @NonNull Observer<T> observer) {
        if (owner.getLifecycle().getCurrentState() == DESTROYED) {
            // ignore
            return;
        }
        ... ...
        owner.getLifecycle().addObserver(wrapper);
    }

由源码可知,如果当前的LifecycleOwner处于DESTROYED状态,则忽略。否则,将传入的观察者做一个封装,然后添加到Activity/Fragment的LifecycleRegistry中去,当Activity/Fragment的什么周期发生变化时,就会通知这个封装的观察者,即LiveData拥有了生命周期感知能力。

二、LiveData注册观察者

    @MainThread
    public void observe(@NonNull LifecycleOwner owner, @NonNull Observer<T> observer) {
        if (owner.getLifecycle().getCurrentState() == DESTROYED) {
            // ignore
            return;
        }
        LifecycleBoundObserver wrapper = new LifecycleBoundObserver(owner, observer);
        ObserverWrapper existing = mObservers.putIfAbsent(observer, wrapper);
        if (existing != null && !existing.isAttachedTo(owner)) {
            throw new IllegalArgumentException("Cannot add the same observer"
                    + " with different lifecycles");
        }
        if (existing != null) {
            return;
        }
        owner.getLifecycle().addObserver(wrapper);
    }

由源码可知,observe()注册观察者方法运行在主线程。同时,observe()方法会将传入的观察者对象封装成一个LifecycleBoundObserver对象,之后再将这个wrapper对象添加到Activity/Fragment的LifecycleRegistry中去。因此,对于Activity/Fragment而言,这个wrapper对象是观察者,Activity/Fragment生命周期的变化都会通知到wrapper。

那么,紧接着我们一起来看一下LifecycleBoundObserver的源码,而且配合上LifecycleRegistry静态内部类ObserverWithState的源码看效果更佳:

    // LifecycleRegistry # ObserverWithState
    static class ObserverWithState {
        State mState;
        GenericLifecycleObserver mLifecycleObserver;

        ObserverWithState(LifecycleObserver observer, State initialState) {
            mLifecycleObserver = Lifecycling.getCallback(observer);
            mState = initialState;
        }

        void dispatchEvent(LifecycleOwner owner, Event event) {
            State newState = getStateAfter(event);
            mState = min(mState, newState);
            mLifecycleObserver.onStateChanged(owner, event);
            mState = newState;
        }
    }
    // LiveData # LifecycleBoundObserver
    class LifecycleBoundObserver extends ObserverWrapper implements GenericLifecycleObserver {
        @NonNull final LifecycleOwner mOwner;

        LifecycleBoundObserver(@NonNull LifecycleOwner owner, Observer<T> observer) {
            super(observer);
            mOwner = owner;
        }

        @Override
        boolean shouldBeActive() {
            return mOwner.getLifecycle().getCurrentState().isAtLeast(STARTED);
        }

        @Override
        public void onStateChanged(LifecycleOwner source, Lifecycle.Event event) {
            if (mOwner.getLifecycle().getCurrentState() == DESTROYED) {
                removeObserver(mObserver);
                return;
            }
            activeStateChanged(shouldBeActive());
        }

        @Override
        boolean isAttachedTo(LifecycleOwner owner) {
            return mOwner == owner;
        }

        @Override
        void detachObserver() {
            mOwner.getLifecycle().removeObserver(this);
        }
    }

由源码可知,当Activity/Fragment生命周期发生变化时,最终会去回调观察者的onStateChanged()方法。因此,我们先看一下LifecycleBoundObserver的onStateChanged()方法。很明显,如果Activity/Fragment的当前状态是DESTROYED,那么就将这个观察者移除,也就意味着解除了与Activity/Fragment的关联,这就是LiveData可以避免内存泄漏的原因。接着,会调用activeStateChanged()方法。

    void activeStateChanged(boolean newActive) {
            if (newActive == mActive) {
                return;
            }
            // immediately set active state, so we'd never dispatch anything to inactive
            // owner
            mActive = newActive;
            boolean wasInactive = LiveData.this.mActiveCount == 0;
            LiveData.this.mActiveCount += mActive ? 1 : -1;
            if (wasInactive && mActive) {
                onActive();
            }
            if (LiveData.this.mActiveCount == 0 && !mActive) {
                onInactive();
            }
            if (mActive) {
                dispatchingValue(this);
            }
        }

可以看到,当LifecycleOwner的状态处于STARTED或RESUMED时,传入newActive的值为true,即LifecycleBoundObserver会被标记为激活状态,生命周期变化将会通知处于激活状态的观察者。

三、LiveData通知观察者

在上面的分析中,我们可以知道当Activity/Fragment生命周期变化时,如果Activity/Fragment处于活动状态,则会将生命周期变化通知观察者。
其次,我们也可以通过改变LiveData里面的数据内容,然后再将数据的变化通知观察者。具体主要体现在setValue()和postValue()这两个方法上。

    @MainThread
    protected void setValue(T value) {
        assertMainThread("setValue");
        mVersion++;
        mData = value;
        dispatchingValue(null);
    }
    protected void postValue(T value) {
        boolean postTask;
        synchronized (mDataLock) {
            postTask = mPendingData == NOT_SET;
            mPendingData = value;
        }
        if (!postTask) {
            return;
        }
        ArchTaskExecutor.getInstance().postToMainThread(mPostValueRunnable);
    }

由源码可知,setValue()方法只能运行在主线程上,而postValue()方法可以运行在任意线程上,但是Observer的OnChange回调最终会执行在主线程上。

我们注意到,不管是哪种通知观察者的方式,都会调用到dispatchingValue()这个方法,下面就具体来看一下:

    private void dispatchingValue(@Nullable ObserverWrapper initiator) {
        if (mDispatchingValue) {
            mDispatchInvalidated = true;
            return;
        }
        mDispatchingValue = true;
        do {
            mDispatchInvalidated = false;
            if (initiator != null) {
                considerNotify(initiator);
                initiator = null;
            } else {
                for (Iterator<Map.Entry<Observer<T>, ObserverWrapper>> iterator =
                        mObservers.iteratorWithAdditions(); iterator.hasNext(); ) {
                    considerNotify(iterator.next().getValue());
                    if (mDispatchInvalidated) {
                        break;
                    }
                }
            }
        } while (mDispatchInvalidated);
        mDispatchingValue = false;
    }

由源码可知,mDispatchingValue和mDispatchInvalidated只在dispatchingValue方法中使用,显然这两个变量是为了防止重复分发相同的内容。接下来,我们注意到,无论传入的initiator是否为空,都会走到considerNotify()这个方法:

    private void considerNotify(ObserverWrapper observer) {
        if (!observer.mActive) {
            return;
        }
        // Check latest state b4 dispatch. Maybe it changed state but we didn't get the event yet.
        //
        // we still first check observer.active to keep it as the entrance for events. So even if
        // the observer moved to an active state, if we've not received that event, we better not
        // notify for a more predictable notification order.
        if (!observer.shouldBeActive()) {
            observer.activeStateChanged(false);
            return;
        }
        if (observer.mLastVersion >= mVersion) {
            return;
        }
        observer.mLastVersion = mVersion;
        //noinspection unchecked
        observer.mObserver.onChanged((T) mData);
    }

    @Override
    boolean shouldBeActive() {
        return mOwner.getLifecycle().getCurrentState().isAtLeast(STARTED);
    }

由源码可知,如果Activity/Fragment处于非活动状态,则忽略。也就是说,如果当前界面是不可见的,那么就不会去通知观察者,因此可以解决常见的view空指针异常问题。如果当前界面处于活动状态,则会去回调注册进来的观察者的onChanged()方法,之后进行相应的逻辑操作。

©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 203,456评论 5 477
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 85,370评论 2 381
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 150,337评论 0 337
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 54,583评论 1 273
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 63,596评论 5 365
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 48,572评论 1 281
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 37,936评论 3 395
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 36,595评论 0 258
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 40,850评论 1 297
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,601评论 2 321
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,685评论 1 329
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 33,371评论 4 318
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 38,951评论 3 307
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,934评论 0 19
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,167评论 1 259
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 43,636评论 2 349
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 42,411评论 2 342

推荐阅读更多精彩内容