kunfei vor 4 Jahren
Ursprung
Commit
367f026c1f
1 geänderte Dateien mit 14 neuen und 7 gelöschten Zeilen
  1. 14 7
      app/src/main/java/io/legado/app/utils/RegexExtensions.kt

+ 14 - 7
app/src/main/java/io/legado/app/utils/RegexExtensions.kt

@@ -2,32 +2,39 @@ package io.legado.app.utils
 
 
 import io.legado.app.exception.RegexTimeoutException
 import io.legado.app.exception.RegexTimeoutException
 import io.legado.app.help.CrashHandler
 import io.legado.app.help.CrashHandler
+import kotlinx.coroutines.DelicateCoroutinesApi
+import kotlinx.coroutines.Dispatchers.IO
+import kotlinx.coroutines.GlobalScope
+import kotlinx.coroutines.launch
 import kotlinx.coroutines.suspendCancellableCoroutine
 import kotlinx.coroutines.suspendCancellableCoroutine
 import splitties.init.appCtx
 import splitties.init.appCtx
-import kotlin.concurrent.thread
 import kotlin.coroutines.resume
 import kotlin.coroutines.resume
 
 
+/**
+ * 带有超时检测的正则替换
+ * 超时重启apk,线程不能强制结束,只能重启apk
+ */
+@DelicateCoroutinesApi
 suspend fun CharSequence.replace(regex: Regex, replacement: String, timeout: Long): String {
 suspend fun CharSequence.replace(regex: Regex, replacement: String, timeout: Long): String {
+    val charSequence = this
     return suspendCancellableCoroutine { block ->
     return suspendCancellableCoroutine { block ->
-        val thread = thread {
+        val scope = GlobalScope.launch(IO) {
             try {
             try {
-                val result = regex.replace(this, replacement)
+                val result = regex.replace(charSequence, replacement)
                 block.resume(result)
                 block.resume(result)
             } catch (e: Exception) {
             } catch (e: Exception) {
                 block.cancel(e)
                 block.cancel(e)
             }
             }
         }
         }
         mainHandler.postDelayed({
         mainHandler.postDelayed({
-            if (thread.isAlive) {
+            if (scope.isActive) {
                 val timeoutMsg = "替换超时,将在3秒后重启应用\n替换规则$regex\n替换内容:${this}"
                 val timeoutMsg = "替换超时,将在3秒后重启应用\n替换规则$regex\n替换内容:${this}"
                 val exception = RegexTimeoutException(timeoutMsg)
                 val exception = RegexTimeoutException(timeoutMsg)
                 block.cancel(exception)
                 block.cancel(exception)
                 appCtx.longToastOnUi(timeoutMsg)
                 appCtx.longToastOnUi(timeoutMsg)
                 CrashHandler.saveCrashInfo2File(exception)
                 CrashHandler.saveCrashInfo2File(exception)
                 mainHandler.postDelayed({
                 mainHandler.postDelayed({
-                    if (thread.isAlive) {
-                        appCtx.restart()
-                    }
+                    appCtx.restart()
                 }, 3000)
                 }, 3000)
             }
             }
         }, timeout)
         }, timeout)