Reduce IO worker thread count

james58899 · james58899 · commit 143ec3261f89 · 2025-10-16T02:46:20.000+08:00
diff --git a/src/main/kotlin/one/oktw/galaxy/util/KotlinCoroutineTaskExecutor.kt b/src/main/kotlin/one/oktw/galaxy/util/KotlinCoroutineTaskExecutor.kt
@@ -29,7 +29,7 @@ import java.util.concurrent.atomic.AtomicInteger
 class KotlinCoroutineTaskExecutor(queueCount: Int, name: String) : PrioritizedConsecutiveExecutor(queueCount, null, name), CoroutineScope {
     companion object {
         private var index = 0
-        private val dispatcher = Executors.newFixedThreadPool(16) { r -> Thread(r, "IO-Kotlin-${index++}").apply { isDaemon = true } }.asCoroutineDispatcher()
+        private val dispatcher = Executors.newFixedThreadPool(8) { r -> Thread(r, "IO-Kotlin-${index++}").apply { isDaemon = true } }.asCoroutineDispatcher()
     }
 
     private val job = SupervisorJob()

Original file line number	Diff line number	Diff line change
`@@ -29,7 +29,7 @@ import java.util.concurrent.atomic.AtomicInteger`
`29`	`29`	`class KotlinCoroutineTaskExecutor(queueCount: Int, name: String) : PrioritizedConsecutiveExecutor(queueCount, null, name), CoroutineScope {`
`30`	`30`	`companion object {`
`31`	`31`	`private var index = 0`
`32`		`- private val dispatcher = Executors.newFixedThreadPool(16) { r -> Thread(r, "IO-Kotlin-${index++}").apply { isDaemon = true } }.asCoroutineDispatcher()`
	`32`	`+ private val dispatcher = Executors.newFixedThreadPool(8) { r -> Thread(r, "IO-Kotlin-${index++}").apply { isDaemon = true } }.asCoroutineDispatcher()`
`33`	`33`	`}`
`34`	`34`
`35`	`35`	`private val job = SupervisorJob()`