Add scheduler name to ExperimentalCoroutineDispatcher

Fixes Kotlin#661

Author: qwwdfsad

core/kotlinx-coroutines-core/src/scheduling/Dispatcher.kt

@@ -36,15 +36,18 @@ internal object DefaultScheduler : ExperimentalCoroutineDispatcher() {
 open class ExperimentalCoroutineDispatcher(
     private val corePoolSize: Int,
     private val maxPoolSize: Int,
-    private val idleWorkerKeepAliveNs: Long
+    private val idleWorkerKeepAliveNs: Long,
+    private val schedulerName: String = "CoroutineScheduler"
 ) : ExecutorCoroutineDispatcher() {
     constructor(
         corePoolSize: Int = CORE_POOL_SIZE,
-        maxPoolSize: Int = MAX_POOL_SIZE
+        maxPoolSize: Int = MAX_POOL_SIZE,
+        schedulerName: String = DEFAULT_SCHEDULER_NAME
     ) : this(
         corePoolSize,
         maxPoolSize,
-        IDLE_WORKER_KEEP_ALIVE_NS
+        IDLE_WORKER_KEEP_ALIVE_NS,
+        schedulerName
     )
 
     override val executor: Executor
@@ -106,7 +109,7 @@ open class ExperimentalCoroutineDispatcher(
             DefaultExecutor.execute(coroutineScheduler.createTask(block, context))
         }
 
-    private fun createScheduler() = CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveNs)
+    private fun createScheduler() = CoroutineScheduler(corePoolSize, maxPoolSize, idleWorkerKeepAliveNs, schedulerName)
 
     // fot tests only
     @Synchronized

core/kotlinx-coroutines-core/test/scheduling/CoroutineDispatcherTest.kt

@@ -168,4 +168,21 @@ class CoroutineDispatcherTest : SchedulerTestBase() {
         outerJob.join()
         finish(5)
     }
+
+    @Test
+    fun testThreadName() = runBlocking {
+        val initialCount = Thread.getAllStackTraces().keys.asSequence()
+            .count { it is CoroutineScheduler.Worker && it.name.contains("SomeTestName") }
+        assertEquals(0, initialCount)
+        val dispatcher = ExperimentalCoroutineDispatcher(1, 1, IDLE_WORKER_KEEP_ALIVE_NS, "SomeTestName")
+        dispatcher.use {
+            launch(dispatcher) {
+            }.join()
+
+            val count = Thread.getAllStackTraces().keys.asSequence()
+                .count { it is CoroutineScheduler.Worker && it.name.contains("SomeTestName") }
+            assertEquals(1, count)
+        }
+
+    }
 }