静态编程语言延迟是否在内部使用调度程序来解除屏蔽调用线程？

Question

这是我用来学习kotlin协同程序的一些测试代码。代码按预期工作，大约需要1秒来打印总和，但现在如果我用阻塞调用（如网络请求）替换延迟（1000），那么代码大约需要10秒来打印总和（每个调用大约需要1秒），但如果我将网络调用包装在withContext中并使用IO调度程序，则需要1秒来打印总和，因为它是在不同的线程上运行的。延迟函数是否使用某种调度程序来解除线程阻塞？

suspend fun asyncDoubleFn(num: Int): Int {
    delay(1000)
    return num * 2
}


fun main() = runBlocking {
    launch {
        val tt = measureTimeMillis {
            val results = mutableListOf<Deferred<Int>>()
            for (num in 0..10) {
                val result = async { asyncDoubleFn(num + 1) }
                results.add(result)
            }
            val sum = results.map { it.await() }.reduce { acc, i -> acc + i }
            println("[SUM]: $sum")
        }

        println("[TT]: $tt")
    }


    launch {
        println("Another coroutine")
    }

    println("Main Code")


}

Answer 1

延迟函数是否使用某种调度程序来解除线程阻塞？

不仅仅是延迟。所有可挂起的函数都与调度程序交互。

你应该问的问题是：“这里哪个调度员负责？”

答案是：runBlock安装自己的调度程序，该调度程序调度到它被调用的线程。代码中的启动和async都继承了它。

记住这一点：

如果我用网络请求等阻塞调用替换延迟（1000），那么代码大约需要10秒来打印总和（每个调用大约需要1秒）

每个阻塞调用将保留调度程序的单个线程。它将无法在被阻止时执行任何其他工作。

但是，如果我将网络调用包装在一个带有上下文的容器中，并使用IO调度程序，则需要1秒来打印总和，因为它是在不同的线程上运行的

是的，这改变了调度程序，问题解决了。

那么，延迟做什么呢？它挂起当前协同路由（异步启动的协同路由），并将控制返回给调度程序，调度程序现在可以继续恢复循环并启动下一个协同路由。