From 14c345b38d57fd814f217eb8465963a08ca79f7e Mon Sep 17 00:00:00 2001
From: wangzhengquan <wangzhengquan85@126.com>
Date: 星期五, 05 二月 2021 17:41:09 +0800
Subject: [PATCH] update
---
src/queue/shm_queue.h | 54 +++++++++++++++++++++++++++---------------------------
1 files changed, 27 insertions(+), 27 deletions(-)
diff --git a/src/queue/shm_queue.h b/src/queue/shm_queue.h
index 3a7750e..24a4dfc 100644
--- a/src/queue/shm_queue.h
+++ b/src/queue/shm_queue.h
@@ -61,33 +61,33 @@
};
// @deprecate
-template <typename ELEM_T>
-size_t SHMQueue<ELEM_T>::remove_queues_exclude(int keys[], size_t length) {
- hashtable_t *hashtable = mm_get_hashtable();
- std::set<int> *keyset = hashtable_keyset(hashtable);
- std::set<int>::iterator keyItr;
- LockFreeQueue<ELEM_T, SHM_Allocator> *mqueue;
- bool found;
- size_t count = 0;
- for (keyItr = keyset->begin(); keyItr != keyset->end(); keyItr++) {
- found = false;
- for (size_t i = 0; i < length; i++) {
- if (*keyItr == keys[i]) {
- found = true;
- break;
- }
- }
- if (!found) {
- // 閿�姣佸叡浜唴瀛樼殑queue
- mqueue = (LockFreeQueue<ELEM_T, SHM_Allocator> *)hashtable_get(hashtable, *keyItr);
- delete mqueue;
- hashtable_remove(hashtable, *keyItr);
- count++;
- }
- }
- delete keyset;
- return count;
-}
+// template <typename ELEM_T>
+// size_t SHMQueue<ELEM_T>::remove_queues_exclude(int keys[], size_t length) {
+// hashtable_t *hashtable = mm_get_hashtable();
+// std::set<int> *keyset = hashtable_keyset(hashtable);
+// std::set<int>::iterator keyItr;
+// LockFreeQueue<ELEM_T, SHM_Allocator> *mqueue;
+// bool found;
+// size_t count = 0;
+// for (keyItr = keyset->begin(); keyItr != keyset->end(); keyItr++) {
+// found = false;
+// for (size_t i = 0; i < length; i++) {
+// if (*keyItr == keys[i]) {
+// found = true;
+// break;
+// }
+// }
+// if (!found && *keyItr > 100) {
+// // 閿�姣佸叡浜唴瀛樼殑queue
+// mqueue = (LockFreeQueue<ELEM_T, SHM_Allocator> *)hashtable_get(hashtable, *keyItr);
+// delete mqueue;
+// hashtable_remove(hashtable, *keyItr);
+// count++;
+// }
+// }
+// delete keyset;
+// return count;
+// }
--
Gitblit v1.8.0