Merge pull request #8635 from 1d7500/fix-issue-8591

Fix issue 8591

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

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);
 }