android - 如何在不等待结果的情况下在另一个内部运行挂起功能？

Question

我有一个场景，我的代码必须发送一个 api 调用并继续其工作(其中包含另一个 api 调用)，而无需等待第一次调用的结果。
现在我在我的 View 模型中这样做

fun showItem(id:Int) {
   launch{
       repo.markItemRead(id)
   }
   launch {
       try {
           val item = repo.getItemById(id).getOrThrow
           commands.postValue(ShowItemCommand(item))
       } catch (t:Throwable) {
           commands.postValue(ShowError(R.string.error_retrieve_item))
           repo.logError(t)
       }
   }
}

这调用了具有这两个功能的存储库

suspend fun markItemRead(id) {
    try {
        service.markItemAsRead(id)
    } catch(ignored:Throwable) {
    }
}

suspend fun getItemById(id) : Result<ItemData> {
    return try {
       val response : ItemEntity = service.getItemById(id)
       val item  = response.toData()
       Result.Success(item)
    } catch (t:Throwable) {
        Result.Failure(t)
    }
}

如果存储库完成所有这些工作，我会更喜欢它，因为每次都必须遵循另一个。
不幸的是，当我尝试在我的存储库中做这样的事情时:

suspend fun getItemById(id:Int) : Result<ItemData> {
    try {
        service.markItemAsRead(id)
    } catch(ignored:Throwable) {
    }
    return try {
       val response : ItemEntity = service.getItemById(id)
       val item  = response.toData()
       Result.Success(item)
    } catch (t:Throwable) {
        Result.Failure(t)
    }
}

它等待 markItemAsRead在继续之前完成的功能
除了定义存储库的范围并将 markItemAsRead在 launch 内调用(我已经读过在挂起函数中执行此操作是不正确的)在存储库中是否有另一种方法？

Answer 1

您可以使用 coroutineScope 或 supervisorScope 在存储库中，具体取决于您的需要。这两个函数都是为并行分解工作而设计的。一旦给定 block 及其所有子协程完成，这些函数就会返回。
当 coroutineScope 中的任何子协程失败，这个范围失败，所有其余的 child 都被取消。不像 coroutineScope ，supervisorScope 中的子协程失败不会导致此范围失败并且不会影响其其他子级，因此可以实现用于处理其子级故障的自定义策略。
请选择最适合您的需求。使用示例:

suspend fun getItemByIdAndMarkRead(id: Int) : Result<ItemData> = supervisorScope {
    launch {
        try {
            service.markItemAsRead(id)
        } catch(ignored:Throwable) { }
    }

    return@supervisorScope withContext(Dispatchers.Default) {
        try {
            val response : ItemEntity = service.getItemById(id)
            val item  = response.toData()
            Result.Success(item)
        } catch (t: Throwable) {
            Result.Failure(t)
        }
    }
}

service.markItemAsRead(id)和 service.getItemById(id)将并行执行。