update

wangzhengquan

2020-07-07 f42ddf22907c681d8b08eeceef160d4566dba437

 squeue/include/queue_factory.h

@@ -32,7 +32,7 @@
         hashtable_put(hashtable,  key, (void *)queue);
      }

      std::cout << "createQueue reference===" << queue->reference << std::endl;
		
      return queue;
   }

@@ -43,6 +43,7 @@
   LockFreeQueue<T>* createQueue(int key, size_t size = 16) {
      LockFreeQueue<T> *queue = _createQueue<T>(key, size);
      queue->reference++; 
      LoggerFactory::getLogger().debug("createQueue reference===%d", queue->reference.load());
      return queue;
   }

@@ -56,7 +57,7 @@
         return;

      queue->reference--;
std::cout << "dropQueue reference===" << queue->reference << std::endl;
      LoggerFactory::getLogger().debug("dropQueue reference===%d", queue->reference.load());
      if(queue->reference == 0) {
         delete queue;
         hashtable_t *hashtable = getHashTable();