udpate

wangzhengquan

2020-08-05 509cf5db80c1d8919e19e1e061f2014e1ff3caf7

 src/queue/include/shm_queue.h

@@ -40,6 +40,7 @@

  static void remove_queues_exclude(int keys[], size_t length);
  static void remove_queues_include(int keys[], size_t length);
  static void remove_queue(int key);

private:
protected:
@@ -68,6 +69,7 @@
      }
    }
    if (!found) {
      // 销毁共享内存的queue
      mqueue = (LockFreeQueue<ELEM_T, SHM_Allocator> *)hashtable_get(hashtable, *keyItr);
      delete mqueue;
      hashtable_remove(hashtable, *keyItr);
@@ -77,11 +79,13 @@
}



template <typename ELEM_T>
void SHMQueue<ELEM_T>::remove_queues_include(int keys[], size_t length) {
  hashtable_t *hashtable = mm_get_hashtable();
  LockFreeQueue<ELEM_T, SHM_Allocator> *mqueue;
  for(int i = 0; i< length; i++) {
    // 销毁共享内存的queue
    mqueue = (LockFreeQueue<ELEM_T, SHM_Allocator> *)mm_get_by_key(keys[i]);
    delete mqueue;
    hashtable_remove(hashtable, keys[i]);
@@ -89,6 +93,12 @@
}

template <typename ELEM_T>
void SHMQueue<ELEM_T>::remove_queue(int key) {
  int keys[] = {key};
  remove_queues_include(keys, 1);
}

template <typename ELEM_T>
SHMQueue<ELEM_T>::SHMQueue(int key, size_t qsize) : KEY(key) {

  hashtable_t *hashtable = mm_get_hashtable();