时间戳

首页 > 解决方案 > CoroutineWorker 中的实时数据观察者

android - CoroutineWorker 中的实时数据观察者

问题描述

我有一个定期执行的 Worker。它连接到 BLE 设备并从中同步数据。连接由观察者完成。doWork 调用 syncRides()。syncRides 创建了一个 observeForever，并开始连接，当连接建立时调用 BleClient.runBleSync()。

我担心的是每 15 分钟（最短 WorkManager 时间）调用一次“observeForever”，并创建未删除的 observeForever。问题是 BleWorker 没有用于创建“BleClient.connectionStatus.observe”而不是“BleClient.connectionStatus.observeForever”的 LifecycleOwner。我的问题是我是否应该担心使用 observeForever 并每 15 分钟触发一次。或者，也许您可​​以建议更好的选择，例如添加和删除观察者。

此外，在没有 GlobalScope.launch(Dispatchers.Main) 的情况下运行时，会出现此函数无法在后台线程上运行的错误。那么在Worker中运行时Dispatchers.Main是什么意思呢？

class BleWorker(appContext: Context, workerParams: WorkerParameters) : CoroutineWorker(appContext, workerParams) {

override suspend fun doWork(): Result {

    return try {
        try {
            RLog.d("Run work manager")
            syncRides()
            val output: Data = workDataOf("KEY_RESULT" to 1)
            Result.success(output)
        } catch (e: Exception) {
            RLog.d("exception in doWork ${e.message}")
            Result.failure()
        }
    } catch (e: Exception) {
        RLog.d("exception in doWork ${e.message}")
        Result.failure()
    }
}


private suspend fun syncRides() {

    GlobalScope.launch(Dispatchers.Main) {

        val bleDevice = SharedPreferenceHelper.getBleMac()
        if (bleDevice != null && BleClient.connectionStatus.value == BleClient.ConnectionStatus.NOT_CONNECTED) {
            BleClient.connect(bleDevice)
        }

        BleClient.connectionStatus.observeForever {
            RLog.d("Observing $it")

            when (it) {
                BleClient.ConnectionStatus.CONNECTED -> {
                    GlobalScope.launch(Dispatchers.IO) {
                        RLog.d("Running sync")
                        BleClient.runBleSync()
                    }
                }
                else -> {
                    RLog.d("No status")
                }
            }
        }
    }
}

客户端：

 object BleClient {

 val connectionStatus = MutableLiveData(ConnectionStatus.NOT_CONNECTED)

 fun connect(mac: String) {
//do some magic         
 connectionStatus.postValue(ConnectionStatus.CONNECTED)
 }
}

标签： androidkotlinkotlin-coroutinesandroid-workmanager

解决方案

我假设该应用程序通过蓝牙连接到另一台设备的任何同步数据。如果我的假设是正确的，首先，您应该将同步过程卸载到前台服务，因为该过程需要很长时间。您仍然可以使用 WorkManager 进行调度。在前台服务中，您应该连接 BLE 并同步数据。为此，有不同的选择。如果您需要使用 observable 来观察连接状态，则应该使用 MutableSharedFlow 而不是 MutableLiveData，这样您就可以使用在 Service 类中创建的生命周期范围来观察变化。但是，在我看来，更好的做法是将您的 connect() 函数转换为可暂停函数。为此，您可以使用 suspendCoroutine 构建器进行转换。此外，如果您同时从不同线程调用连接函数，你必须使用锁来避免多重连接。Kotlin Coroutines 对此有非阻塞锁。将 connect() 函数转换为挂起函数后，您可以以线性方式实现逻辑，这很简单，不需要任何观察。

推荐阅读