Dispatchers.IO effective parallelism is MAX_POOL_SIZE

dovchinnikov · dkhalanskyjb · web-flow · commit b142539ac082 · 2022-12-29T14:57:03.000+01:00
Co-authored-by: Dmitry Khalanskiy &lt;52952525+dkhalanskyjb@users.noreply.github.com&gt;
diff --git a/kotlinx-coroutines-core/jvm/src/scheduling/Dispatcher.kt b/kotlinx-coroutines-core/jvm/src/scheduling/Dispatcher.kt
@@ -50,7 +50,7 @@ private object UnlimitedIoScheduler : CoroutineDispatcher() {
     @ExperimentalCoroutinesApi
     override fun limitedParallelism(parallelism: Int): CoroutineDispatcher {
         parallelism.checkParallelism()
-        if (parallelism == Int.MAX_VALUE) return this
+        if (parallelism >= MAX_POOL_SIZE) return this
         return super.limitedParallelism(parallelism)
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -50,7 +50,7 @@ private object UnlimitedIoScheduler : CoroutineDispatcher() {`
`50`	`50`	`@ExperimentalCoroutinesApi`
`51`	`51`	`override fun limitedParallelism(parallelism: Int): CoroutineDispatcher {`
`52`	`52`	`parallelism.checkParallelism()`
`53`		`- if (parallelism == Int.MAX_VALUE) return this`
	`53`	`+ if (parallelism >= MAX_POOL_SIZE) return this`
`54`	`54`	`return super.limitedParallelism(parallelism)`
`55`	`55`	`}`
`56`	`56`	`}`