From 847b25e5f2ca68cc081c2dfe6c2f365b62401bed Mon Sep 17 00:00:00 2001 From: dapan1121 Date: Tue, 16 Apr 2024 13:37:06 +0800 Subject: [PATCH] fix: task queue quit issue --- source/util/src/tsched.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/source/util/src/tsched.c b/source/util/src/tsched.c index 645910dfbc..603547e30b 100644 --- a/source/util/src/tsched.c +++ b/source/util/src/tsched.c @@ -210,6 +210,7 @@ int taosScheduleTask(void *queueScheduler, SSchedMsg *pMsg) { void taosCleanUpScheduler(void *param) { SSchedQueue *pSched = (SSchedQueue *)param; if (pSched == NULL) return; + if (pSched->stop) return; uDebug("start to cleanup %s schedQsueue", pSched->label); @@ -240,6 +241,7 @@ void taosCleanUpScheduler(void *param) { if (pSched->queue) taosMemoryFree(pSched->queue); if (pSched->qthread) taosMemoryFree(pSched->qthread); + pSched->numOfThreads = 0; // taosMemoryFree(pSched); }