From d258c3fca6d55e2eeb56c46c8a09ef4fbd79f9b7 Mon Sep 17 00:00:00 2001
From: dapan1121 <wpan@taosdata.com>
Date: Tue, 20 Feb 2024 01:06:41 -0800
Subject: [PATCH] fix: windows crash issue

---
 source/libs/scheduler/test/schedulerTests.cpp | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/source/libs/scheduler/test/schedulerTests.cpp b/source/libs/scheduler/test/schedulerTests.cpp
index b73de83a82..c52a8599a0 100644
--- a/source/libs/scheduler/test/schedulerTests.cpp
+++ b/source/libs/scheduler/test/schedulerTests.cpp
@@ -60,6 +60,7 @@ extern "C" int32_t schHandleCallback(void *param, const SDataBuf *pMsg, int32_t
 int64_t insertJobRefId = 0;
 int64_t queryJobRefId = 0;
 
+bool     schtJobDone = false;
 uint64_t schtMergeTemplateId = 0x4;
 uint64_t schtFetchTaskId = 0;
 uint64_t schtQueryId = 1;
@@ -450,6 +451,8 @@ void *schtSendRsp(void *param) {
 
   schReleaseJob(job);
 
+  schtJobDone = true;
+  
   return NULL;
 }
 
@@ -1028,6 +1031,8 @@ TEST(insertTest, normalCase) {
   TdThreadAttr thattr;
   taosThreadAttrInit(&thattr);
 
+  schtJobDone = false;
+
   TdThread thread1;
   taosThreadCreate(&(thread1), &thattr, schtSendRsp, &insertJobRefId);
 
@@ -1045,6 +1050,14 @@ TEST(insertTest, normalCase) {
   code = schedulerExecJob(&req, &insertJobRefId);
   ASSERT_EQ(code, 0);
 
+  while (true) {
+    if (schtJobDone) {
+      break;
+    }
+
+    taosUsleep(10000);
+  }
+
   schedulerFreeJob(&insertJobRefId, 0);
 
   schedulerDestroy();