如何调整Kotlin Dispatchers.IO线程池的TTL（存活时间）？

这种情况是否正常？ #

在你使用的kotlinx-coroutines-core 1.6.1版本中，Dispatchers.IO的空闲线程TTL为1分钟是正常的默认行为。它的底层实现依赖Java线程池，默认的空闲线程存活时间就是60秒，和Executors::newCachedThreadPool的默认配置一致，完全符合官方文档中“按需创建和关闭额外线程”的描述——当线程空闲超过TTL时会被销毁，有新任务到来时再创建新线程。

如何调整TTL？ #

默认的Dispatchers.IO无法直接修改线程存活时间，需要自定义一个具备相同特性的调度器，通过ThreadPoolDispatcher来配置参数：

1. 自定义调度器实现：

import kotlinx.coroutines.CoroutineDispatcher
import kotlinx.coroutines.asCoroutineDispatcher
import java.util.concurrent.Executors
import java.util.concurrent.TimeUnit

// 创建自定义IO调度器，设置空闲线程存活时间为5分钟
val customIoDispatcher: CoroutineDispatcher = Executors.newCachedThreadPool { runnable ->
    // 自定义线程名称，便于排查问题
    Thread(runnable, "CustomIO-Worker-${it.id}").apply {
        isDaemon = true // 设置为守护线程，避免阻止应用退出
    }
}.apply {
    // 调整空闲线程存活时间，可根据你的周期负载修改数值和时间单位
    setKeepAliveTime(5, TimeUnit.MINUTES)
}.asCoroutineDispatcher()

2. 使用方式：
   在协程中替换原有的Dispatchers.IO为customIoDispatcher即可：

coroutineScope {
    launch(customIoDispatcher) {
        // 处理你的IO密集型任务
    }
}

3. 注意事项：

• 应用关闭时务必调用customIoDispatcher.close()，释放线程池资源，避免潜在的内存泄漏。
• 根据你的周期性负载调整TTL：比如你的负载周期是1分钟，可将TTL设为1分30秒或更久，确保线程在下次任务到来前不会被销毁，实现线程复用。
• 不要设置过长的TTL，避免大量空闲线程占用系统资源。

内容的提问来源于stack exchange，提问作者kirill.login