Android Kotlin 在继续之前如何等待这个协程完成

将发生在协程中的代码移入其中.协程(launch Lambda)中的代码是同步的.启动的协程本身与外部的代码是异步的.

而且，假设您使用这个协程来处理视图，您需要使用viewLifecycleOwner‘S lifecycleScope，而不是片段的.(如果您不是在这个协程中处理视图，那么它可能从一开始就不应该在片段中.)

override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
    super.onViewCreated(view, savedInstanceState)
    viewModel.currentStock.observe(viewLifecycleOwner) { stock ->
        viewLifecycleOwner.lifecycleScope.launch {
            val companyName = withContext(Dispatchers.IO) {
                getCompanyName(stock)
            }
            deleteTable()
            getData(companyName) 
        }
    }
}

如果getCompanyName是暂停功能(并正确实现)，则不需要withContext:

override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
    super.onViewCreated(view, savedInstanceState)
    viewModel.currentStock.observe(viewLifecycleOwner) { stock ->
        viewLifecycleOwner.lifecycleScope.launch {
            val companyName = getCompanyName(stock)
            deleteTable()
            getData(companyName) 
        }
    }
}

对于嵌套/重复较少的代码，您可以考虑使用中间流.这也将防止可能的竞争条件.如果两个值连续快速到达，则从LiveData观察器启动的协同 routine 可能会并行运行，这可能会导致错误，具体取决于您在该协同 routine 中所做的操作.但流运算符是按顺序处理的，因此不会发生这种情况.根据您具体在做什么，您可能会进一步优化这一点，以避免将时间浪费在过时的项目上，将onEach替换为transformLatest.这将导致它在新项目快速到达时提前取消对前一项目所做的工作.

override fun onViewCreated(view: View, savedInstanceState: Bundle?) {
    super.onViewCreated(view, savedInstanceState)
    viewModel.currentStock.asFlow()
        .onEach { stock ->
            val companyName = getCompanyName(stock)
            deleteTable()
            getData(companyName) 
        }
        .launchIn(viewLifecycleOwner.lifecycleScope)
}

我不熟悉Volley，只是简单地浏览了一下文档.在我看来，您正在使用StringRequest子类直接处理被覆盖的parseNetworkResponse()函数中的响应.因此，要将其转换为挂起函数，我认为它应该如下所示:

suspend fun RequestQueue.awaitNetworkResponse(method: Int, url: String): NetworkResponse = suspendCancellableCoroutine { continuation ->
    val request = object: StringRequest(
        method,
        url,
        {},
        { continuation.resumeWithException(it) }
    ) {
         override fun  parseNetworkResponse(response : NetworkResponse) : Response<String> {
             continuation.resume(response)
             return super.parseNetworkResponse(response)
         }
    }
    add(request)
    continuation.invokeOnCancellation {
        request.cancel()
    }
}

现在，您可以在协程中同步使用此函数:

private suspend fun finraGetCfruid(companyName: String): String {
    val url = "https://www.finra.org/finra-data/fixed-income/corp-and-agency"

    val queue = Volley.newRequestQueue(requireActivity())
    val response = try {
        queue.awaitNetworkResponse(Request.Method.GET, url)
    } catch (e: VolleyError) {
        Log.e("Error", error.toString())
        return "" // or some other behavior?
    }
    val cookies = HttpCookie.parse(response.headers?.get("Set-Cookie"))
    val indexOfEqualSign = cookies[0].toString().indexOf('=')
    val cfruid = cookies[0].toString().substring(indexOfEqualSign + 1)
    datainterface.getMoreData(companyName, cfruid)
    return cfruid
}