add desub

wangzhengquan

2020-08-06 203df24a403a8c0cd8e93d0f33eaf10de2788969

 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:
@@ -78,6 +79,7 @@
}



template <typename ELEM_T>
void SHMQueue<ELEM_T>::remove_queues_include(int keys[], size_t length) {
  hashtable_t *hashtable = mm_get_hashtable();
@@ -91,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();