Android Jetpack全家桶(四)之LiveData数据维持

前言

Android Jetpack是Google在18年IO大会上推荐的一整套组件库，它的出现填补了之前Android中自带的一些缺陷，例如Handler的内存泄露、Camera的不易用性、后台调度难以管理等等。所以我打算把整个架构组件系统性的学习一下，在这里和大家分享，希望能帮助到其他学习者。本系列文章包含十篇：

介绍

LiveData与常规Observable不同，LiveData是具有生命周期感知的。它在生命周期中扮演观察者的角色，监听生命周期。

官方说，生命周期处于onStart()或onResume状态，则LiveData会将其视为处于活跃状态。但是根据源码来看，LiveData的活跃状态其实是在onPause()和onStart()前后的，在这一期间LiveData可以对活动观察者进行数据更新。

class LifecycleBoundObserver extends ObserverWrapper implements GenericLifecycleObserver {

    ...

    @Override
    boolean shouldBeActive() {
        return mOwner.getLifecycle().getCurrentState().isAtLeast(STARTED); //onStart开始为活跃状态
    }

}

private void considerNotify(ObserverWrapper observer) {
    
    if (!observer.shouldBeActive()) {//判断是否为活跃状态
        observer.activeStateChanged(false);
        return;
    }

    observer.mObserver.onChanged((T) mData);
}

通常我们实现LifecycleOwner接口的对象配对的观察者，之后生命周期在onDestroy()时通过LiveData.observer()调用LifecycleBoundObserver中的removeObserver()回收资源，避免内存泄漏。

一句话概括，它主要是以观察者模式实现数据驱动，并在生命周期结束时回收资源避免内存泄漏。

如何使用？

添加依赖

// lifecycle
def lifecycle_version = "2.2.0-alpha02"
implementation "androidx.lifecycle:lifecycle-extensions:$lifecycle_version"
annotationProcessor "android.arch.lifecycle:compiler:$lifecycle_version"
kapt "android.arch.lifecycle:compiler:$lifecycle_version"

监听LiveData数据

class MainActivity : AppCompatActivity() {

    private lateinit var mLiveData: MutableLiveData<String>

    override fun onCreate(savedInstanceState: Bundle?) {
        super.onCreate(savedInstanceState)
        setContentView(R.layout.activity_main)

        mLiveData = MutableLiveData()

        mLiveData.observe(this, Observer<String> {
            updateText ->
            System.out.println("update new text ---> " + updateText)
        })

    }

    override fun onStart() {
        super.onStart()
        mLiveData.value = "start text from MainThread"
    }

    override fun onResume() {
        super.onResume()
        Thread(Runnable {
            mLiveData.postValue("resume text from BranchThread")
        }).run()
    }

}

分析LiveData

数据更新

LiveData.setValue

LiveData的setValue()方法只能在主线程中调用。

@MainThread //约定主线程运行
protected void setValue(T value) {
    assertMainThread("setValue"); //判断是否在主线程，否则return异常
    mVersion++;
    mData = value;
    dispatchingValue(null);
}

LiveData.postValue

LiveData的postValue()方法则只能在子线程中调用，这种做法是为了区分调用场景。

protected void postValue(T value) {
    boolean postTask;
    synchronized (mDataLock) {
        postTask = mPendingData == NOT_SET;
        mPendingData = value;
    }
    if (!postTask) { //判断是否在子线程，否则return，更新数据失败
        return;
    }
    ArchTaskExecutor.getInstance().postToMainThread(mPostValueRunnable); //ArchTaskExecutor内则是调用了Handler去更新数据
}

资源回收

LiveData在注册observer的时候，会绑定当前的Lifecycle，注册LifecycleOwner接口并实例LifecycleBoundObserver对象。

@MainThread
public void observe(@NonNull LifecycleOwner owner, @NonNull Observer<? super T> observer) {
    assertMainThread("observe");
    if (owner.getLifecycle().getCurrentState() == DESTROYED) {
        // ignore
        return;
    }
    LifecycleBoundObserver wrapper = new LifecycleBoundObserver(owner, observer); //实例LifecycleBoundObserver
    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);
}

而当Lifecycle调用onDestroy时，会被LifecycleBoundObserver监听到，并通过Lifecycle.removeObserver对资源进行回收，从而避免内存泄露。

class LifecycleBoundObserver extends ObserverWrapper implements GenericLifecycleObserver {
    
    ...

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

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

结语

最后，希望大家可以结合demo深入源码进行学习。