无法看到为什么不同的线程无法执行任务

问题描述

我尝试运行以下代码，但无法确定为什么相同的线程而不是不同的线程承担了任务。

fun main() = runBlocking<Unit> {
    launch {
        delay(100L)
        println(Thread.currentThread().name + "Task 1")
    }

    launch {
        delay(100L)
        println(Thread.currentThread().name + "Task 2")
    }

    launch {
        delay(100L)
        println(Thread.currentThread().name + "Task 3")
    }

    println(Thread.currentThread().name + "Main thread is over")
}

输出：

mainMain thread is over
mainTask 1
mainTask 2
mainTask 3

Process finished with exit code 0

PS：我还在学习科特林。如果这是一个天真的问题，请原谅。

解决方法

您正在使用在某个范围内不带参数的启动，在这种情况下为runBlocking

在不带参数的情况下使用启动{...}时，它将继承 来自CoroutineScope的上下文（以及调度程序） 从发射。在这种情况下，它继承了main的上下文 在主线程中运行的runBlocking协程。 https://kotlinlang.org/docs/reference/coroutines/coroutine-context-and-dispatchers.html

用于runBlocking的默认CoroutineDispatcher是专有的内部实现。 https://kotlin.github.io/kotlinx.coroutines/kotlinx-coroutines-core/kotlinx.coroutines/run-blocking.html

您可以做的是使用带有参数的启动，即GlobalScope.launch {}。或者，您可以尝试为runBlocking提供不同的上下文，这将导致在不带参数的情况下调用启动时使用不同的CoroutineDispatcher。

可以在以下位置找到不同上下文的示例：https://kotlinlang.org/docs/reference/coroutines/coroutine-context-and-dispatchers.html

import kotlinx.coroutines.*
fun main() {
    runBlocking<Unit>(Dispatchers.Default) {
    launch {
        delay(100L)
        println(Thread.currentThread().name + " Task 1")
    }

    launch {
        delay(100L)
        println(Thread.currentThread().name + " Task 2")
    }

    launch {
        delay(100L)
        println(Thread.currentThread().name + " Task 3")
    }

    println(Thread.currentThread().name + " Main thread is over")
    }
}