From 453ed4c39d4a58cb11f0109ac03a094f94a01ee7 Mon Sep 17 00:00:00 2001
From: renwj <renwenjie@zhidaoauto.com>
Date: Thu, 8 Sep 2022 17:59:05 +0800
Subject: [PATCH] =?UTF-8?q?[=E7=8A=B6=E6=80=81=E6=A0=8F]=E4=BB=A3=E7=A0=81?=
 =?UTF-8?q?=E9=80=BB=E8=BE=91=E4=BC=98=E5=8C=96?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../mogo_core_function_devatools/status/flow/can/CanImpl.kt   | 2 +-
 .../mogo_core_function_devatools/status/flow/nets/NetsImpl.kt | 2 +-
 .../mogo_core_function_devatools/status/flow/rtk/RTKImpl.kt   | 4 ++--
 3 files changed, 4 insertions(+), 4 deletions(-)

diff --git a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/can/CanImpl.kt b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/can/CanImpl.kt
index 0e254a00b2..cfebc1ad24 100644
--- a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/can/CanImpl.kt
+++ b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/can/CanImpl.kt
@@ -97,7 +97,7 @@ internal class CanImpl(ctx: Context): IFlow<CanStatus>(ctx), IMoGoAutopilotVehic
 
     private fun timeOutCheck() {
         job?.safeCancel()
-        launch(Dispatchers.Default) {
+        launch(Dispatchers.Unconfined) {
             delay(4000)
             send(CanStatus(isCanEnabled()))
         }.also { job = it  }
diff --git a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/nets/NetsImpl.kt b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/nets/NetsImpl.kt
index 0adb0bee7c..89564cb8e0 100644
--- a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/nets/NetsImpl.kt
+++ b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/nets/NetsImpl.kt
@@ -79,7 +79,7 @@ internal class NetsImpl(ctx: Context): IFlow<NetStatus>(ctx) {
 
     private fun checkAndSend() {
         loopCheckAndSendJob?.safeCancel()
-        launch(Dispatchers.Default) {
+        launch(Dispatchers.Unconfined) {
             val connectionInfo = wifiMgr.connectionInfo
             val enabled = isNetConnected()
             val name =
diff --git a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/rtk/RTKImpl.kt b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/rtk/RTKImpl.kt
index b5108cb4c9..c5663854b5 100644
--- a/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/rtk/RTKImpl.kt
+++ b/core/function-impl/mogo-core-function-devatools/src/main/java/com/zhjt/mogo_core_function_devatools/status/flow/rtk/RTKImpl.kt
@@ -44,7 +44,7 @@ internal class RTKImpl(ctx: Context): IFlow<RTKStatus>(ctx), IMoGoAutopilotStatu
             return
         }
         check?.takeIf { it.isActive }?.cancel()
-        launch {
+        launch(Dispatchers.Unconfined) {
             CallerAutoPilotManager.sendStatusQueryReq()
             delay(5000)
             isOldVersion.set(true)
@@ -82,7 +82,7 @@ internal class RTKImpl(ctx: Context): IFlow<RTKStatus>(ctx), IMoGoAutopilotStatu
             if (isRTKEnabled()) {
                 send(RTKStatus("RTK", 0))
                 timeOutCheck?.takeIf { it.isActive }?.cancel()
-                launch {
+                launch(Dispatchers.Unconfined) {
                     delay(4000)
                     send(RTKStatus("", -1))
                 }.also {