Kotlin：不使用runBlocking如何衔接阻塞与异步代码？

你的问题核心在于协程上下文的调度器选择——runBlocking默认使用当前线程作为单线程调度器，而你原代码中的async继承了这个单线程上下文，导致任务只能串行执行。只要给计算密集型任务指定多线程调度器，就能在runBlocking中保持并行能力。

正确实现方式 #

方式1：给async指定计算型调度器 #

直接在async块中指定Dispatchers.Default（Kotlin专门为计算密集型任务设计的调度器，线程数默认等于CPU核心数）：

suspend fun tasks() {
    coroutineScope {
        val result = List(10) {
            async(Dispatchers.Default) { 
                // 执行计算密集型任务
                println("Task ${it} running on thread ${Thread.currentThread().name}")
                // 示例计算：模拟耗时运算
                Thread.sleep(1000)
                it * 2
            }
        }.awaitAll()
        // 处理结果
        println("All results: $result")
    }
}

方式2：给整个coroutineScope指定调度器 #

如果所有子任务都是计算密集型，可以直接给coroutineScope设置上下文，让内部所有async自动继承：

suspend fun tasks() {
    coroutineScope(Dispatchers.Default) {
        val result = List(10) {
            async { 
                // 计算密集型任务
            }
        }.awaitAll()
    }
}

在常规同步函数中调用 #

用runBlocking衔接同步代码即可，此时内部协程会在多线程调度器上并行执行：

fun regularFunction() {
    // 这里runBlocking会阻塞当前线程，直到tasks执行完成
    runBlocking {
        tasks()
    }
}

关键说明 #

• Dispatchers.Default是计算密集型任务的最优选择：它的线程数与CPU核心数匹配，避免过多线程上下文切换导致性能损耗。
• 不要用Dispatchers.IO处理计算任务：IO调度器针对IO密集型场景设计，线程数远多于CPU核心，会增加不必要的资源开销。
• runBlocking本身不会导致串行：它只是阻塞当前线程等待协程完成，并行能力由内部协程使用的调度器决定。

内容的提问来源于stack exchange，提问作者Jannik