Intermediate value

Author: dkhalanskyjb

kotlinx-coroutines-core/jvm/src/scheduling/CoroutineScheduler.kt

@@ -951,3 +951,12 @@ internal class CoroutineScheduler(
         TERMINATED
     }
 }
+
+@Suppress("UNUSED")
+@JvmName("isSchedulerWorker")
+internal fun isSchedulerWorker(thread: Thread) = thread is CoroutineScheduler.Worker
+
+@Suppress("UNUSED")
+@JvmName("mayNotBlock")
+internal fun mayNotBlock(thread: Thread) = thread is CoroutineScheduler.Worker &&
+    thread.state == CoroutineScheduler.WorkerState.CPU_ACQUIRED

kotlinx-coroutines-debug/src/internal/BlockHoundIntegration.kt

@@ -1,32 +1,16 @@
+@file:Suppress("INVISIBLE_REFERENCE", "INVISIBLE_MEMBER")
 package kotlinx.coroutines.debug.internal
 
 import reactor.blockhound.BlockHound
-import kotlin.reflect.KClass
-import kotlin.reflect.full.*
+import kotlinx.coroutines.scheduling.*
 
 internal object BlockHoundIntegration {
 
     init {
-        val cls = Class.forName("kotlinx.coroutines.scheduling.CoroutineScheduler\$Worker").kotlin
-        initializerHelper(cls)
-    }
-
-    private fun <T : Any> initializerHelper(cls: KClass<T>) {
-        val field = cls.declaredMemberProperties.find { it.name == "state" }!!
         BlockHound.builder()
-                .addDynamicThreadPredicate(cls::isInstance)
-                .nonBlockingThreadPredicate { p ->
-                    p.or { thread ->
-                        val castThread = cls.safeCast(thread)
-                        if (!enabled || castThread == null) {
-                            false
-                        } else {
-                            val state = field(castThread) as Enum<*>
-                            state.name == "CPU_ACQUIRED"
-                        }
-                    }
-                }
-                .install()
+            .addDynamicThreadPredicate { isSchedulerWorker(it) }
+            .nonBlockingThreadPredicate { p -> p.or { thread -> enabled && mayNotBlock(thread) } }
+            .install()
     }
 
     @Volatile