CoRoutine Async 未并行运行

Question

我有以下代码，我正在尝试并行运行协程。但是，代码不会并行运行。所有股票价格返回需要 30 秒，而不是 10 秒。但是，如果我使用 GlobalScope.launch，它确实可以正常工作。我从文档中收集到我们应该避免使用 GlobalScope 并使用协程范围。你能帮助理解为什么这不是并行运行吗？

import kotlinx.coroutines.*

suspend fun getStockPrice(company: String) : Int{
    println("Fetching Stock Price")
    Thread.sleep(10000)
    return 100
}



fun CoroutineScope.launchCoRoutines() {
    val companies = listOf<String>("Google", "Amazon", "Microsoft")

    launch {

        var startTime = System.currentTimeMillis()
        val sharePrice = mutableListOf<Deferred<Int>>()
        for (company in companies) {
            sharePrice += async {
                getStockPrice(company).toInt()
            }
        }

        for (share in sharePrice) {
            println(share.await())
        }
        var endTime = System.currentTimeMillis()

        println(endTime - startTime)

    }


}

 fun main()  {
     runBlocking{
         launchCoRoutines()
     }
     println("Request Sent")
    Thread.sleep(55000)
}

Answer 1

答案可以在这里找到：

Kotlin: coroutineScope is slower than GlobalScope

如前所述：

coroutineScope 没有定义自己的调度器，所以你继承它 来自调用者，在本例中是由 runBlocking 创建的。它用 调用它的单线程。

编辑： 你可以使用这个功能

fun launchCoRoutines() {
    val companies = listOf<String>("Google", "Amazon", "Microsoft")

    launch(Dispatchers.Default) { // will get dispatched to DefaultDispatcher 

        var startTime = System.currentTimeMillis()
        val sharePrice = mutableListOf<Deferred<Int>>()
        for (company in companies) {
            sharePrice += async {
                getStockPrice(company).toInt()
            }
        }

        for (share in sharePrice) {
            println(share.await())
        }
        var endTime = System.currentTimeMillis()

        println(endTime - startTime)
    }
}

编辑 2： 见@Animesh Sahu 评论，这是最好的答案