withContext(Dispatchers.IO) 如何使用房间

Question

在我们的应用程序中有很多查询，现在我们正在使用 ROOM，我想确认在我们这样使用之前使用 Coroutine 的正确方法是什么

在道

  @Query("SELECT * FROM VISITS")
    suspend fun getAllVisits(): List<Visits>

我们正在变成这样

fun getAll(visit: Visits?) = runBlocking {
        Log.i(TAG, "addOrUpdateRecord")
        try {

val list = ArrayList<Visits>()
                list.addAll(async {
                    visitsDao.getAllVisits()
                }.await())

}

但是在一些文章中我读到运行阻塞仅用于测试而不是生产请指导我正确的方式谢谢

Answer 1

如果您需要一个协程范围来启动一个协程，您可以根据需要使用lifecycleScope 或viewModelScope。

在 Activity 内部：

fun myMethod() {
    lifecycleScope.launch {
        val list = visitsDao.getAllVisits()
        //Do something with list here
            ...
    }
}

片段内部：

fun myMethod() {
    viewLifecycleOwner.lifecycleScope.launch {
        val list = visitsDao.getAllVisits()
        //Do something with list here
            ...
    }
}

在 ViewModel 中：

fun myMethod() {
    viewModelScope.launch {
        val list = visitsDao.getAllVisits()
        //Do something with list here
        ...
    }
}

在普通班级内：

class MyPresenter: CoroutineScope {
    private val myJob = Job()
    override val coroutineContext: CoroutineContext
        get() = Dispatchers.Default + myJob
    
    ...

    fun myMethod() {
        launch {
            val list = visitsDao.getAllVisits()
            //Do something with list here
            ...
        }
    }
    
    ...

    //Call clear when required
    fun clear() {
        this.myJob.cancel()
    }
}

Answer 2

你可以使用这样的东西

GlobalScope.launch { 
            withContext(Dispatchers.IO){
                // your query
            }
        }

Answer 3

在视图模型中：

viewmodelScope.launch(Dispatchers.IO){
  visitsDao.getAllVisits()
}

或者另一个挂起函数

suspend fun addAll() {
    visitsDao.getAllVisits().run{
     ArrayList<Visits>().addAll(this)

   }
}

甚至更多，只需使用流，您可以使用 livedata builder/map/asLiveData 等。