From 879db08f432c3a9c16bf2027721f953d15d8b3c5 Mon Sep 17 00:00:00 2001
From: HapeLee <1321903405@qq.com>
Date: Sat, 15 Nov 2025 17:11:34 +0800
Subject: [PATCH] =?UTF-8?q?=E5=90=8C=E6=AD=A5=E4=B8=8A=E6=B8=B8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../io/legado/app/help/DispatchersMonitor.kt  | 59 +++++++++++++++++++
 1 file changed, 59 insertions(+)
 create mode 100644 app/src/main/java/io/legado/app/help/DispatchersMonitor.kt

diff --git a/app/src/main/java/io/legado/app/help/DispatchersMonitor.kt b/app/src/main/java/io/legado/app/help/DispatchersMonitor.kt
new file mode 100644
index 000000000..465715d58
--- /dev/null
+++ b/app/src/main/java/io/legado/app/help/DispatchersMonitor.kt
@@ -0,0 +1,59 @@
+package io.legado.app.help
+
+import io.legado.app.help.config.AppConfig
+import io.legado.app.utils.LogUtils
+import kotlinx.coroutines.CoroutineDispatcher
+import kotlinx.coroutines.CoroutineScope
+import kotlinx.coroutines.Dispatchers.Default
+import kotlinx.coroutines.Dispatchers.IO
+import kotlinx.coroutines.Dispatchers.Main
+import kotlinx.coroutines.ExperimentalCoroutinesApi
+import kotlinx.coroutines.asCoroutineDispatcher
+import kotlinx.coroutines.cancelChildren
+import kotlinx.coroutines.delay
+import kotlinx.coroutines.isActive
+import kotlinx.coroutines.launch
+import kotlinx.coroutines.selects.onTimeout
+import kotlinx.coroutines.selects.select
+import kotlinx.coroutines.withContext
+import java.util.concurrent.Executors
+
+object DispatchersMonitor {
+
+    private const val TAG = "DispatchersMonitor"
+
+    private val dispatcher by lazy {
+        Executors.newSingleThreadExecutor {
+            Thread(it, TAG)
+        }.asCoroutineDispatcher()
+    }
+
+    private val scope = CoroutineScope(dispatcher)
+
+    fun init() {
+        scope.coroutineContext.cancelChildren()
+        if (!AppConfig.recordLog) {
+            return
+        }
+        monitor(IO)
+        monitor(Default)
+        monitor(Main)
+    }
+
+    @OptIn(ExperimentalCoroutinesApi::class)
+    private fun monitor(dispatcher: CoroutineDispatcher) {
+        scope.launch {
+            while (isActive) select {
+                launch {
+                    withContext(dispatcher) {
+                        delay(3000)
+                    }
+                }.onJoin {}
+                onTimeout(5000) {
+                    LogUtils.d(TAG, "Dispatcher $dispatcher is timed out waiting for for 5000ms.")
+                }
+            }
+        }
+    }
+
+}
\ No newline at end of file