update

wangzhengquan

2020-07-25 48ae739d196e8a1ad681e5a54ad992302119bd83

 src/queue/include/shm_queue.h

@@ -99,12 +99,12 @@
{
    SemUtil::dec( queue->mutex);
    queue->reference--;
    LoggerFactory::getLogger().debug("SHMQueue destructor  reference===%d", queue->reference.load());
//LoggerFactory::getLogger().debug("SHMQueue destructor  reference===%d", queue->reference.load());
    if(queue->reference.load() == 0) {
        delete queue;
        hashtable_t *hashtable = mm_get_hashtable();
        hashtable_remove(hashtable, KEY);
printf("SHMQueue destructor delete queue\n");
// LoggerFactory::getLogger().debug("SHMQueue destructor delete queue\n");
    } else {
        SemUtil::inc(queue->mutex);
    }