sycronized

wangzhengquan

2020-07-23 6da3e92dab82554db8492d2bd7981ecd9ef3fd65

 src/queue/include/lock_free_queue.h

@@ -78,7 +78,7 @@
    int items;
   
public:
    // int mutex;
    int mutex;
    LockFreeQueue(size_t qsize = LOCK_FREE_Q_DEFAULT_SIZE);
    
    /// @brief destructor of the class. 
@@ -151,7 +151,7 @@
// std::cout << "LockFreeQueue init reference=" << reference << std::endl;
    slots = SemUtil::get(IPC_PRIVATE, qsize);
    items = SemUtil::get(IPC_PRIVATE, 0);
    // mutex = SemUtil::get(IPC_PRIVATE, 1);
    mutex = SemUtil::get(IPC_PRIVATE, 1);
}

template <
@@ -163,6 +163,7 @@
    LoggerFactory::getLogger().debug("LockFreeQueue desctroy");
    SemUtil::remove(slots);
    SemUtil::remove(items);
    SemUtil::remove(mutex);
}

template <