更新无锁队列

importcpp · importcpp · commit 6298e07eaeba · 2020-08-08T20:16:40.000+08:00
diff --git a/webserver/lock/KLockFreeQueue.h b/webserver/lock/KLockFreeQueue.h
@@ -30,10 +30,14 @@ class LockFreeQueue
     LockFreeQueue() : head_(new Node()), tail_(head_) {}
     ~LockFreeQueue()
     {
-        // Todo： 完成队列的析构
-        // 暂时好像没有必要
-        // 1. 任务队列与程序生命期相同
-        // 2. 肯定是要完成队列里面所有任务的
+        Node *tmp;
+        while (head_ != nullptr) {
+            tmp = head_;
+            head_ = head_->next_;
+            delete tmp;
+        }
+        tmp = nullptr;
+        tail_ = nullptr;
     }
 
     bool Try_Dequeue(T &data)
@@ -127,4 +131,4 @@ class LockFreeQueue
         // 重置尾节点, (也有可能已经被别的线程重置，那么当前线程就不用管了
         ::__sync_bool_compare_and_swap(&tail_, old_tail, enqueue_node);
     }
-};
+};
