Intermediate value

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