如何解决CoroutineWorker 中的实时数据观察者
我有一个定期执行的 Worker。它连接到 BLE 设备并从中同步数据。连接是由观察者完成的。 doWork 调用 syncRides()。 syncRides 创建了一个observeForever,并在建立连接时启动连接,调用 BleClient.runBleSync()。
我担心的是每 15 分钟调用一次“observeForever”(最少的 WorkManager 时间)并且创建未删除的 observeForever。问题是 BleWorker 没有 LifecycleOwner 来创建“BleClient.connectionStatus.observe”而不是“BleClient.connectionStatus.observeForever”。我的问题是我是否应该担心使用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")
}
}
}
}
}
BleClient:
object BleClient {
val connectionStatus = mutablelivedata(ConnectionStatus.NOT_CONNECTED)
fun connect(mac: String) {
//do some magic
connectionStatus.postValue(ConnectionStatus.CONNECTED)
}
}
解决方法
我假设该应用程序通过蓝牙连接到另一台设备上的任何同步数据。如果我的假设是正确的,首先,您应该将同步过程卸载到前台服务,因为该过程需要很长时间。您仍然可以使用 WorkManager 进行调度。在前台服务中,您应该连接 BLE 并同步数据。为此,有不同的选择。如果你需要使用 observable 来观察连接状态,你应该使用 MutableSharedFlow 而不是 MutableLiveData,这样你就可以观察你在 Service 类中创建的生命周期范围的变化。但是,在我看来,更好的做法是将 connect() 函数转换为可挂起的函数。为此,您可以使用 suspendCoroutine builder 进行转换。另外,如果同时从不同的线程调用 connect 函数,则必须使用 lock 来避免多个连接。 Kotlin Coroutines 为此提供了非阻塞锁。将 connect() 函数转换为挂起函数后,您可以以线性方式实现您的逻辑,这很容易且不需要任何类型的观察。
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 dio@foxmail.com 举报,一经查实,本站将立刻删除。