fix the remove queue bug

This commit is contained in:
Jeff Tao 2020-03-31 18:53:56 +08:00
parent e217738f70
commit 94935818ce
2 changed files with 1 additions and 1 deletions

BIN
src/util/src/.tqueue.c.swp Normal file

Binary file not shown.

View File

@ -282,7 +282,7 @@ void taosRemoveFromQset(taos_qset p1, taos_queue p2) {
pthread_mutex_lock(&queue->mutex);
atomic_sub_fetch_32(&qset->numOfItems, queue->numOfItems);
queue->qset = NULL;
pthread_mutex_lock(&queue->mutex);
pthread_mutex_unlock(&queue->mutex);
}
}