Jetpack学习-LiveData

LiveData是什么

LiveData是一种可观察的数据存储器类，具有生命周期的感知能力。

简单使用

LiveData一般都是和ViewModel一起使用。定义一个类继承自ViewModel:

public class LiveDataSub extends ViewModel {

    private MutableLiveData<String> infos;

    private int number;

    public MutableLiveData<String> getInfo() {
        if (infos == null) {
            infos = new MutableLiveData<>();
        }
        return infos;
    }

    public int increaseNumber() {
        number++;
        return number;
    }
}

在这个类里定义MutableLiveData类型的属性，并提供外界访问的方法getInfo

在Activity中使用

public class LiveDataActivity extends AppCompatActivity {

    private TextView tv;

    private LiveDataSub viewModel;

    @Override
    protected void onCreate(@Nullable Bundle savedInstanceState) {
        super.onCreate(savedInstanceState);
        setContentView(R.layout.activity_livedata);
        tv = findViewById(R.id.tv);
        viewModel = ViewModelProviders.of(this).get(LiveDataSub.class);
        viewModel.getInfo().observe(this, new Observer<String>() {
            @Override
            public void onChanged(String s) {
                tv.setText(s);
            }
        });
    }

    public void update(View view) {
        String info = "info:" + viewModel.increaseNumber();
        viewModel.getInfo().setValue(info);
    }
}

通过ViewModelProviders.of(this).get(LiveDataSub.class)来实例化刚才定义的ViewModel，然后通过调用LiveData的observe方法添加对当前Activity的观察。

通过LiveData的setValue可以来更新数据，此时界面会自动更新。

原理

从LiveData的observe方法来看

添加observer

@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);
        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方法的调用要求是在主线程。如果Activity对应的lifecycle已经处于DESTROYED状态，则会直接返回，不添加observer。最终还是调用了Lifecycle的addObserver方法。

数据更新

数据更新，是通过LiveData的setValue方法来执行的。

@MainThread
    protected void setValue(T value) {
        assertMainThread("setValue");
        mVersion++;
        mData = value;
        dispatchingValue(null);
    }

这个方法要求在主线程上执行。方法内部调用了dispatchingValue方法

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<? super T>, ObserverWrapper>> iterator =
                        mObservers.iteratorWithAdditions(); iterator.hasNext(); ) {
                    considerNotify(iterator.next().getValue());
                    if (mDispatchInvalidated) {
                        break;
                    }
                }
            }
        } while (mDispatchInvalidated);
        mDispatchingValue = false;
    }

由于之前传入的ObserverWrapper为null,因此会执行下面的迭代里的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);
    }

在这个方法中，最终调用了observer的onChange方法。

时序图：

LiveData时序图.png

数据异步更新

上面的数据更新是在UI线程上执行的，如果想要在子线程上执行，那么则需要通过postValue方法。我们也来看一下这个方法

protected void postValue(T value) {
        boolean postTask;
        synchronized (mDataLock) {
            //判断mPendingData是否已经赋值
            postTask = mPendingData == NOT_SET;
            //给mPendingData赋值
            mPendingData = value;
        }
        //如果已经赋值，则取消发送
        if (!postTask) {
            return;
        }
        ArchTaskExecutor.getInstance().postToMainThread(mPostValueRunnable);
    }

这个方法是通过ArchTaskExecutor的postToMainThread方法来执行的。

先看ArchTaskExecutor.getInstance()方法

public static ArchTaskExecutor getInstance() {
        if (sInstance != null) {
            return sInstance;
        }
        synchronized (ArchTaskExecutor.class) {
            if (sInstance == null) {
                sInstance = new ArchTaskExecutor();
            }
        }
        return sInstance;
    }

再来看下构造方法

private ArchTaskExecutor() {
        mDefaultTaskExecutor = new DefaultTaskExecutor();
        mDelegate = mDefaultTaskExecutor;
    }

在这里实例化了mDefaultTaskExecutor和mDelegate

调用postToMainThread方法

@Override
    public void postToMainThread(Runnable runnable) {
        mDelegate.postToMainThread(runnable);
    }

执行的是DefaultTaskExecutor的postToMainThread方法

public void postToMainThread(Runnable runnable) {
        if (mMainHandler == null) {
            synchronized (mLock) {
                if (mMainHandler == null) {
                    mMainHandler = new Handler(Looper.getMainLooper());
                }
            }
        }
        //noinspection ConstantConditions
        mMainHandler.post(runnable);
    }

可以看到，其实就是post了一个runnable到主线程中。

private final Runnable mPostValueRunnable = new Runnable() {
        @Override
        public void run() {
            Object newValue;
            synchronized (mDataLock) {
                //获取要更新的数据
                newValue = mPendingData;
                //mPendingData重置
                mPendingData = NOT_SET;
            }
            //noinspection unchecked
            setValue((T) newValue);
        }
    };

最终回调run方法里，还是调用的setValue方法。在run方法中，会获取要更新的数据，然后对mPendingData重置。因此，如果调用了多次postValue,如果前面的更新还没有处理，则并不会往主线程发送更新的消息，只会给mPendingData赋值，在run回调中，就会获取到最后一次的数据。