又是大早上被多线程折磨的一天

先简单讲一下功能框架吧

flowchart TD
    A(用户发起查询操作) --> B{查询cache}
    B -- 有 --> C[返回cache内容给用户]
    B -- 没有 --> D[请求remote]
    D --> E[remote返回内容]
    E --> F[内容返回给用户]
    E --> G[remote内容写入cache]

简单来说就是从两个数据源获取信息,先查cache,cache没有再查remote,remote得到数据后返回给用户并写入cache

然后就出问题了,具体问题表现为出现重复插入情况

经过排查,发现remote请求返回的数据正常,但是到写入Room数据库的时候出现插入数量正确,但是部分item重复插入,部分item丢失的情况

问了一下ChatGPT,在给出的几个可能性中锁定到多线程并发写入导致的竞态和异常。

不过虽然该保存数据的函数确实是suspend的异步函数,但是我在函数入口明明打了断点,断点只触发一次,不存在多线程的问题

把代码贴上来问了问ChatGPT,结果给我整绷不住了:

问题

不是,也没人给我说呀,怎么kotlin的foreach和for还有这大坑等着我的。。。

然而把foreach改成for后还是一样的问题,继续追问

在众多的可能性中,锁定协程作用域问题

指出确保你的suspend fun saveServiceList()不是在多个协程并发调用!否则即使方法内部串行,外部还是会并发插入,导致竞态。

但是之前说过,我打的断点明明只触发一次,怎么会出现外部多次调用呢?

没办法,按照ChatGPT说的老老实实打Log看输出,在dao的insert方法前后插Log,发现确实是出现竟态问题。

然后ChatGPT再次指出确保整个suspend方法不在多个协程并发调用,提出用Mutex锁包裹整个suspend方法

结果发现居然没问题了???

所以还真是被多个协程调用了???我怎么不知道???

虽然用锁临时解决了该问题,但这个操作本质是不应该被多个协程调用的,说明代码本身有问题

本着不想写屎山的心态,继续问

然后ChatGPT指出:

原因

原因

所以断点在并发协程中并不适用来判断调用次数

我:多线程你太可爱了

给suspend方法第一行插个Log,发现确实日志打印了两遍

然后就是顺藤摸瓜,给所有调用点全部插Log,最后发现在ViewModel中的起始loadService函数被调用了两次

定位到View中发现在UI里有两处调用,一看代码就发现问题了。

一个来自ViewModel中的loadServiceState在View中监听,当State由Idle变为Loading后触发loadService,加载数据

然后一个手动刷新按钮,首先清除数据,然后更改loadServiceState的State为Loading,最后手动调用loadService

因此当手动刷新时,就会出现loadServiceState改变而触发的loadService以及按钮自身调用的loadService。。。

代码一多自己都忘记原来写的逻辑了,又是被多线程折腾的一天