diff --git a/src/util/src/tqueue.c b/src/util/src/tqueue.c
index 6a37f11ecef376e70f4eefbf6446150bd350cf07..1ffa94b0df6b63dac914649c7003d37bbedbdb24 100644
--- a/src/util/src/tqueue.c
+++ b/src/util/src/tqueue.c
@@ -258,9 +258,9 @@ void taosCloseQset(taos_qset param) {
   pthread_mutex_unlock(&qset->mutex);
 
   pthread_mutex_destroy(&qset->mutex);
+  uTrace("qset:%p is closed", qset);
   tsem_destroy(&qset->sem);
   free(qset);
-  uTrace("qset:%p is closed", qset);
 }
 
 // tsem_post 'qset->sem', so that reader threads waiting for it
diff --git a/src/util/src/tworker.c b/src/util/src/tworker.c
index 8b4053bccd1ce8d9d3f58328d838f4ba5132a100..55604b417ee7d32dd174df01ef4f170923ddb327 100644
--- a/src/util/src/tworker.c
+++ b/src/util/src/tworker.c
@@ -91,6 +91,6 @@ void *tWorkerAllocQueue(SWorkerPool *pPool, void *ahandle) {
 }
 
 void tWorkerFreeQueue(SWorkerPool *pPool, void *pQueue) {
-  taosCloseQueue(pQueue);
   uDebug("worker:%s, queue:%p is freed", pPool->name, pQueue);
+  taosCloseQueue(pQueue);
 }