Android Room无法在主线程上访问数据库，因为它可能会长时间锁定UI

Question

我正在使用Hilt和coroutine Worker请求API，并且在获取数据后，我想将其提升到我的房间存储库，这里的问题即使我使用withContext（dispatchers.io）

无法在主线程上访问数据库，因为它可能可能有可能 锁定UI长时间。

顺便说一句，我不想​​在房间上启用 lastermainthreadqueries（），仍然想在io线程

和工作代码中更新我的回购：

@HiltWorker
class CheckForNewProfilePhotos @AssistedInject constructor(
    @Assisted appContext: Context,
    @Assisted workerParams: WorkerParameters,
    private val usersAPI: UsersAPI,
    private val rUserRepository: RUserRepository
) :
    CoroutineWorker(appContext, workerParams) {
    override suspend fun doWork(): Result {
        withContext(Dispatchers.IO) {

            val usersIdsToFetch = inputData.getLongArray("usersIdsToFetch")

            val response = usersIdsToFetch?.let {
                usersAPI.getMultipleUsers(
                    GetMultipleUsers(it.toList())
                )
            }

            response?.enqueue(object : Callback<List<User>> {
                override fun onResponse(
                    call: Call<List<User>>,
                    response: Response<List<User>>
                ) {

                    response.body()?.let {
                        rUserRepository.upsert(it.toMutableList())
                        //                      conversationRepository.updateUserData(it)
                    }
                }

                override fun onFailure(call: Call<List<User>>, t: Throwable) {
                    Result.retry()
                }
            })

            return@withContext Result.success()
        }

        return Result.success()
    }
}

Answer 1

您可以使用使用使用使用使用使用suppendCoroutine或suppendCancellableCoroutine Builder functions suppend supperd supper supperd supper Bualder函数然后调用并将结果主体插入数据插入DB之后：

private suspend fun makeRequest() = suspendCoroutine { continuation ->
    val usersIdsToFetch = inputData.getLongArray("usersIdsToFetch")

    val response = usersIdsToFetch?.let {
        usersAPI.getMultipleUsers(GetMultipleUsers(it.toList()))
    } 

    response?.enqueue(object : Callback<List<User>> {
            override fun onResponse(
                call: Call<List<User>>,
                response: Response<List<User>>
            ) {
                continuation.resume(response.body()) // resumes suspended coroutine
            }

            override fun onFailure(call: Call<List<User>>, t: Throwable) {
                Result.retry()
                continuation.resume(null) // or continuation.resumeWithException(t) if you want to handle Exceptions
            }
    })
}

override suspend fun doWork(): Result {
    return withContext(Dispatchers.IO) {
        val body = makeRequest()
        return@withContext if (body != null) {
            rUserRepository.upsert(it.toMutableList())
            // conversationRepository.updateUserData(it)
            Result.success()
        } else {
            Result.retry()
        }
    }
}