Android LiveData : Not receiving all notifications

我正在尝试使用Android的LiveData。我只是试图向观察LiveData对象的观察者推送很多通知。我让线程在后台运行，并在while循环中通过LiveData的postValue方法不断推送随机值。在观察者中观察实时数据的接收到的通知数(onChanged()回调数)比后台线程中postValue的调用数少得多。

有人可以解释这是什么原因吗？

先感谢您

最佳答案

解释在于postValue和mPostValueRunnable的实现:

protected void postValue(T value) {
    boolean postTask;
    synchronized (mDataLock) {
        //this is true on the first run or right after the observer receives an update
        postTask = mPendingData == NOT_SET;
        mPendingData = value;
    }
    // this statement will be true if the observer hasn't received an update even though it's sent to the main looper
    if (!postTask) {
        return;
    }
    ArchTaskExecutor.getInstance().postToMainThread(mPostValueRunnable);
}

private final Runnable mPostValueRunnable = new Runnable() {
    @Override
    public void run() {
        Object newValue;
        synchronized (mDataLock) {
            newValue = mPendingData;
            mPendingData = NOT_SET;//once this value is reset a new mPostValueRunnable can be sent
        }
        // here the observer will receive the update
        setValue((T) newValue);
    }
};

第一次运行时，在postValue中输入mPendingData = NOT_SET，因此以下if (!postTask)条件是false，因此mPostValueRunnable被发送到主线程。

在第二次运行时，如果尚未执行mPostValueRunnable(由于值的更新非常频繁，可能尚未执行)，因此if是true，因此除了mPendingData设置为新值之外，没有任何内容发送到主线程。

在第三次运行时，它可以与上一次相同，以此类推，以进行一些更新。因此，直到mPostValueRunnable实际运行并将mPendingData重置为NOT_SET为止，所有更新值都将丢失，最后一个更新值除外。在这种情况下，只有Observer会使用最新值进行一次更新。