Вызов await () для функций приостановки работает неправильно

1
private val coroutineSupervisor = SupervisorJob()
protected val dispatcherProvider = CoroutineDispatcherProvider()
protected val viewModelScope = CoroutineScope(dispatcherProvider.main + coroutineSupervisor)

class CoroutineDispatcherProvider {

    val main: CoroutineDispatcher
        get() = Dispatchers.Main

    val background: CoroutineDispatcher
        get() = Dispatchers.IO
}

viewModelScope.launch {
    ...
    runBlocking {
        async { firstNumber() }.await()
        async { secondNumber() }.await()
        async { test() }.await()
        async { thirdNumber() }.await()
    }
}

suspend fun firstNumber(): Int {
    delay(3_000) // 3 seconds delay
    return 5
}
suspend fun secondNumber(): Int {
    delay(5_000) // 5 seconds delay
    return 8
}
suspend fun thirdNumber(): Int {
    delay(7_000) // 7 seconds delay
    return 10
}

suspend fun test() {
    withContext(dispatcherProvider.background) {
        ...
    }
}

Начал изучать сопрограммы несколько дней назад, и я увидел что-то странное. Функции firstNumber, secondNumber и thirdNumber выполняются как следует - задержка выполняется, а затем выполняется следующая функция - в правильной последовательности, а test() - нет. Это возвращает значение намного позже, и runBlocking уже сделан, когда это произойдет. Я хотел бы убедиться, что он получит результат, а затем каким-то образом использовать его в другом запросе. Это потому, что я там использую какой-то неправильный диспетчер или как?

Теги:
kotlin
coroutine

1 ответ

0

Вот эта вещь. То, что вы ожидаете, когда вызываете метод test() через async и ждете, - это дождитесь его завершения.

Но так как у вас есть обратный поток (apiclient call) внутри тестового метода, он возвращается непосредственно перед получением ответа от сервера и выходит из тестового метода. Позже обратный вызов лямбда вызывается, когда ответ готов. К этому времени блокировка запуска уже выполнена.

Таким образом, вы должны конвертировать ваш обратный вызов в сопрограмму. Codelabs-пример

И вы можете создать список отложенных объектов из вызова API и ожидать каждого из них.

Ещё вопросы

Сообщество Overcoder
Наверх
Меню