diff --git a/src/util/src/.tqueue.c.swp b/src/util/src/.tqueue.c.swp
new file mode 100644
index 0000000000000000000000000000000000000000..40a09d5f638ccd61507bd50661e64d34cccce61c
Binary files /dev/null and b/src/util/src/.tqueue.c.swp differ
diff --git a/src/util/src/tqueue.c b/src/util/src/tqueue.c
index 1ac05556d6a90eb664c0a907f752010bf4ff52f5..bddf68932da310431a5be53ee9d2fed79bd89945 100644
--- a/src/util/src/tqueue.c
+++ b/src/util/src/tqueue.c
@@ -68,10 +68,10 @@ void taosCloseQueue(taos_queue param) {
   STaosQnode *pNode = queue->head;  
   queue->head = NULL;
 
-  pthread_mutex_lock(&queue->mutex);
-
   if (queue->qset) taosRemoveFromQset(queue->qset, queue); 
 
+  pthread_mutex_lock(&queue->mutex);
+
   while (pNode) {
     pTemp = pNode;
     pNode = pNode->next;
@@ -253,33 +253,37 @@ void taosRemoveFromQset(taos_qset p1, taos_queue p2) {
   STaosQueue *queue = (STaosQueue *)p2;
   STaosQset  *qset = (STaosQset *)p1;
  
-  STaosQueue *tqueue;
+  STaosQueue *tqueue = NULL;
 
   pthread_mutex_lock(&qset->mutex);
 
   if (qset->head) {
     if (qset->head == queue) {
       qset->head = qset->head->next;
-      qset->numOfQueues--;
+      tqueue = queue;
     } else {
       STaosQueue *prev = qset->head;
       tqueue = qset->head->next;
       while (tqueue) {
         if (tqueue== queue) {
           prev->next = tqueue->next;
-          if (qset->current == queue) qset->current = tqueue->next;
-          qset->numOfQueues--;
-
-          pthread_mutex_lock(&queue->mutex);
-          atomic_sub_fetch_32(&qset->numOfItems, queue->numOfItems);
-          queue->qset = NULL;
-          pthread_mutex_unlock(&queue->mutex);
+          break;
         } else {
           prev = tqueue;
           tqueue = tqueue->next;
         }
       }
     }
+
+    if (tqueue) {
+      if (qset->current == queue) qset->current = tqueue->next;
+      qset->numOfQueues--;
+
+      pthread_mutex_lock(&queue->mutex);
+      atomic_sub_fetch_32(&qset->numOfItems, queue->numOfItems);
+      queue->qset = NULL;
+      pthread_mutex_unlock(&queue->mutex);
+    }
   } 
   
   pthread_mutex_unlock(&qset->mutex);