• Android MVVM LiveData postValue 吞消息


    问题现象:

    连续调用多次 LiveData 的 postValue 方法,结果只有最后一次响应,前面的消息都被吞了
    问题原因:
    postValue 方法实现在
    androidx.lifecycle.LiveData#postValue

    protected void postValue(T value) {
        boolean postTask;
        synchronized(this.mDataLock) {
            postTask = this.mPendingData == NOT_SET;
            this.mPendingData = value;//1
        }
    
        if (postTask) {
            ArchTaskExecutor.getInstance().postToMainThread(this.mPostValueRunnable);//2
        }
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11

    ArchTaskExecutor 本质是一个主线程的 Handler,所以 postValue 方法其实是使用 Handler 的 post 方法来实现在主线程通知 Observer 对象的。
    注释 1 处 mPendingData 用于储存即将修改的值。
    再看 mPostValueRunnable 的定义

    public LiveData() {
        this.mPendingData = NOT_SET;
    
        class NamelessClass_1 implements Runnable {
            NamelessClass_1() {
            }
    
            public void run() {
                Object newValue;
                synchronized(LiveData.this.mDataLock) {
                    newValue = LiveData.this.mPendingData;//1
                    LiveData.this.mPendingData = LiveData.NOT_SET;
                }
    
                LiveData.this.setValue(newValue);
            }
        }
    
        this.mPostValueRunnable = new NamelessClass_1();//2
        this.mData = NOT_SET;
        this.mVersion = -1;
    }
    
    • 1
    • 2
    • 3
    • 4
    • 5
    • 6
    • 7
    • 8
    • 9
    • 10
    • 11
    • 12
    • 13
    • 14
    • 15
    • 16
    • 17
    • 18
    • 19
    • 20
    • 21
    • 22

    可以看到 mPostValueRunnable 本质是 NamelessClass_1 对象,在其 run 方法中,会读取 mPendingData 的值,然后通过调用 setValue 方法使其通知 Observer 对象。
    然而,当短时间内调用多次 postValue 方法时,则容易出现如下时序问题:

    1. 第一次调用 postValue 方法,将 mPendingData 设置为 A,LiveData 发起 handler 的 post 方法,记此次 callback 为 callback-A
    2. 在 post 方法的 callback 执行前,第二次调用了 postValue 方法,将 mPendingData 设置为 B,对应 callback 为 callback-B
    3. callback-A 执行,调用 setValue(),将 mPendingData 的值通知给 Observer 对象,而此时 mPendingData 已经为 B
    4. callback-B 执行,调用 setValue(),将 mPendingData 的值通知给 Observer 对象,此时 mPendingData 已经 B

    综上,此种情况下,Observer 只收到值为 B 的 onChange 回调,值为 A 的onChange 被吞了,所以问题发生了。

    该问题可能发生在同线程也可能发生在不同线程之间,根本原因是,postValue 方法和实际执行通知 Observer 的操作之间存在时间差,这个是 Handler 的机制所导致的

    解决办法

    方案一:在同一个 LiveData 对象需要频繁调用 postValue 方法时,改用 setValue 方法,避免消息丢失
    方案二:优化业务逻辑,将 LiveData 对象的职能分隔开,避免频繁调用 postValue 方法

  • 相关阅读:
    docker compose搭建redis7.0.4高可用一主二从三哨兵集群并整合SpringBoot【图文完整版】
    Docker、Jenkins、Git 自动化部署 SpringBoot 项目(从零到搭建完成)
    【每日一题Day332】LCP 06. 拿硬币 | 模拟
    ABAP中 delete 语句的使用
    B-神经网络模型复杂度分析
    Day58|单调栈part01:739. 每日温度、496. 下一个最大元素
    C语言 sizeof 函数内部进行计算
    多线程(基础)
    汽车SOA-AUTOSAR-IOS架构分析
    机器学习笔记 - 车道检测的几种深度学习方法
  • 原文地址:https://blog.csdn.net/lzs781/article/details/127401257