Dispatchers — 关键概念，调度器类型及其工作原理

什么是Dispatchers？

Dispatchers — 是CoroutineDispatcher接口的实现，是CoroutineContext的元素。它们决定协程在哪个线程或线程池上执行。通过launch或async创建协程时，调度器可以作为第一个参数传递：launch(Dispatchers.IO) { ... }。如果未指定调度器，则从外部CoroutineScope继承。

Kotlin提供了四个内置调度器：Main、IO、Default、Unconfined。每个调度器使用自己的线程池，针对特定操作类型进行了优化。正确选择调度器决定了应用程序的性能：错误选择会导致界面卡顿、CPU核心闲置或线程消耗效率低下。

Dispatchers.Main：UI线程

Dispatchers.Main — 在Android主线程上执行协程的调度器。它专用于与界面相关的操作：更新TextView、调用notifyDataSetChanged、使用LiveData和StateFlow。在Android中，此调度器通过Handler（Looper.getMainLooper()）实现。

// 正确切换到Main以更新UI
viewModelScope.launch(Dispatchers.IO) {
    val data = repository.fetchData()
    withContext(Dispatchers.Main) {
        _uiState.value = data
    }
}

如果协程已经在Main调度器上，额外的withContext(Dispatchers.Main)不会产生开销——调度器检查当前线程并跳过切换。withContext是在调度器之间切换的首选方式。

Dispatchers.IO：网络和磁盘操作

Dispatchers.IO — 针对输入输出操作优化的调度器：HTTP请求（Ktor、OkHttp）、读写文件、使用Room或SQLDelight。默认使用64个线程的池，可随负载扩展。每个新的IO请求可以创建一个额外的线程，直到达到限制。

限制并行度

要控制同时IO操作的数量，请使用limitedParallelism()。此函数创建一个新的调度器，限制并行线程数量，防止批量操作时池耗尽。

val limitedIo = Dispatchers.IO.limitedParallelism(4)

// 加载100个文件，限制4个并发操作
coroutineScope {
    val files = (1..100).map { index ->
        async(limitedIo) {
            downloadFile("file_$index")
        }
    }
    files.awaitAll()
}

对所有协程花费时间等待（I/O-bound）的操作使用IO调度器。在IO调度器上执行CPU密集型任务效率低下——它们占用本应用于输入输出的线程，降低了系统的吞吐量。

Dispatchers.Default：CPU密集型任务

Dispatchers.Default — 用于处理器密集型计算操作的调度器：排序、过滤、JSON解析（Moshi、Kotlinx Serialization）、图像处理、计算。池的大小等于处理器核心数（但不少于2）。这确保了CPU最大负载且无需上下文切换。

suspend fun processData(input: List<RawRecord>): List<ProcessedRecord> {
    return withContext(Dispatchers.Default) {
        input
            .parallelStream()
            .map { transform(it) }
            .toList()
    }
}

不要将Dispatchers.Default用于IO操作——这会阻塞本可以处理计算任务的CPU池线程。IO和Default的分离实现了系统资源的最优利用：IO线程等待输入输出，CPU线程持续忙于计算。

Dispatchers.Unconfined：当前线程

Dispatchers.Unconfined — 一个特殊的调度器，不将协程绑定到任何池。协程在调用launch/async的同一线程中开始执行，暂停后在被调用resume的线程中继续。这种行为适用于不需要固定上下文的中间操作。

fun main() = runBlocking {
    launch(Dispatchers.Unconfined) {
        println("延迟前：${Thread.currentThread().getName()}")
        delay(500L)
        println("延迟后：${Thread.currentThread().getName()}")
    }
}

在生产代码中，Dispatchers.Unconfined很少使用。主要场景：轻量转换在将数据传递给另一个调度器之前以及测试。对于生产负载，请使用显式调度器——Unconfined不可预测，因为执行线程取决于resume的实现。

如何选择调度器

调度器的选择由任务类型决定：UI操作→Main、I/O-bound→IO、CPU-bound→Default、中间操作→从scope继承。对于Android，建议在完成主要工作的调度器上启动协程，在UI更新前通过withContext切换到Main。

• 不要在Main调度器上运行IO操作——这会阻塞UI
• 不要在IO调度器上运行CPU密集型任务——这会低效消耗IO池的线程
• 使用limitedParallelism控制批量IO操作中的并行度
• 使用withContext切换调度器，而不是创建新的scope
• 从scope继承调度器，如果协程不需要特定池

对于复杂场景，使用+运算符组合调度器：Dispatchers.IO + SupervisorJob() + CoroutineExceptionHandler。这将创建一个具有指定调度器、错误处理和隔离Job层次结构的CoroutineContext。