Блог

 import kotlinx.coroutines.*
import kotlin.system.measureTimeMillis

private val started = System.currentTimeMillis()

suspend fun main(args: Array<String>) {
    debug("Start run blocking")
    debug("starting")
    coroutineScope {
        debug("Inside runBlocking")
        val time = measureTimeMillis {
            val one = launch { doSomethingUsefulOne() }
            val two = launch { doSomethingUsefulTwo() }
            debug("awaiting")
//            two.await()
//            one.await()
            debug("Finished")
        }
        debug("time = $time")
    }
    debug("ending")
    debug("End run blocking")
}

suspend fun doSomethingUsefulOne(): Int {
    debug("Inside doSomethingUsefulOne")
    delay(3000L)
    debug("first")
    return 13
}

suspend fun doSomethingUsefulTwo(): Int {
    debug("Inside doSomethingUsefulTwo")
    delay(1000L)
    debug("second")
    return 29
}
private fun debug(s: String) {
    val elapsed = System.currentTimeMillis() - started
    println("[time elapsed : $elapsed] $s  --  ${Thread.currentThread()}")
}
 

Я работаю с приведенным выше кодом, чтобы изучить поведение сопрограмм. Я получаю ожидаемое поведение следующим образом:

 [time elapsed : 15] Start run blocking  --  Thread[main,5,main]
[time elapsed : 16] starting  --  Thread[main,5,main]
[time elapsed : 34] Inside runBlocking  --  Thread[main,5,main]
[time elapsed : 77] Inside doSomethingUsefulOne  --  Thread[DefaultDispatcher-worker-1,5,main]
[time elapsed : 80] awaiting  --  Thread[main,5,main]
[time elapsed : 80] Finished  --  Thread[main,5,main]
[time elapsed : 80] Inside doSomethingUsefulTwo  --  Thread[DefaultDispatcher-worker-2,5,main]
[time elapsed : 80] time = 46  --  Thread[main,5,main]
[time elapsed : 1089] second  --  Thread[DefaultDispatcher-worker-2,5,main]
[time elapsed : 3088] first  --  Thread[DefaultDispatcher-worker-2,5,main]
[time elapsed : 3089] ending  --  Thread[DefaultDispatcher-worker-2,5,main]
[time elapsed : 3089] End run blocking  --  Thread[DefaultDispatcher-worker-2,5,main]
 

Здесь я не могу следить за тем, как запускались запуски в другом потоке, поскольку он должен использовать основной поток(если я здесь). Кроме того, за пределами сопрограммы работает поток, который выводит последние 2 инструкции, поскольку это должно выполняться основным потоком.

Я хочу знать, в чем я ошибаюсь ?

Вы никогда не указываете диспетчера сопрограмм для запуска своих сопрограмм здесь. Это suspend fun main дает вам пустой контекст (без диспетчера), а coroutineScope также не добавляет никакого диспетчера.

Затем вы используете запуск без аргументов, чтобы запустить 2 сопрограммы. Как говорит доктор:

Если в контексте нет ни диспетчера, ни какого-либо другого интерпретатора продолжения, то Диспетчеры.Используется значение по умолчанию.

Это означает, что ваши сопрограммы будут отправлены с помощью диспетчеров.По умолчанию, который предоставляет несколько рабочих потоков в зависимости от количества имеющихся у вас ядер процессора.

Если вы хотите запустить эти сопрограммы в основном потоке, вы можете использовать launch(Dispatchers.Main) их вместо этого (но они доступны только в специальных средах, таких как Android и JavaFX AFAIK).