From e0aea3742aed09a0a9ed384ccd7db203b6efc650 Mon Sep 17 00:00:00 2001 From: wangzhengquan <wangzhengquan85@126.com> Date: 星期六, 20 二月 2021 14:43:52 +0800 Subject: [PATCH] update --- src/queue/lock_free_queue.h | 36 +++++++++++++++++++++++++++++++----- 1 files changed, 31 insertions(+), 5 deletions(-) diff --git a/src/queue/lock_free_queue.h b/src/queue/lock_free_queue.h index 425d9f8..d66ee8c 100644 --- a/src/queue/lock_free_queue.h +++ b/src/queue/lock_free_queue.h @@ -17,6 +17,11 @@ // default Queue size #define LOCK_FREE_Q_DEFAULT_SIZE 16 + +#define LOCK_FREE_Q_ST_OPENED 0 + +#define LOCK_FREE_Q_ST_CLOSED 1 + // static Logger *logger = LoggerFactory::getLogger(); // define this macro if calls to "size" must return the real size of the // queue. If it is undefined that function will try to take a snapshot of @@ -84,10 +89,10 @@ sem_t items; time_t createTime; + time_t closeTime; + int status; public: - // sem_t mutex; - LockFreeQueue(size_t qsize = LOCK_FREE_Q_DEFAULT_SIZE); @@ -95,6 +100,8 @@ /// Note it is not virtual since it is not expected to inherit from this /// template ~LockFreeQueue(); + + inline void close(); // std::atomic_uint reference; /// @brief constructor of the class @@ -120,8 +127,18 @@ inline ELEM_T &operator[](unsigned i); + + time_t getCreateTime() { return createTime; + } + + time_t getCloseTime() { + return closeTime; + } + + int getStatus() { + return status; } /// @brief push an element at the tail of the queue @@ -166,7 +183,18 @@ err_exit(errno, "LockFreeQueue sem_init"); createTime = time(NULL); + status = LOCK_FREE_Q_ST_OPENED; +} + + +template< + typename ELEM_T, + typename Allocator, + template<typename T, typename AT> class Q_TYPE> +inline void LockFreeQueue<ELEM_T, Allocator, Q_TYPE>::close() { + status = LOCK_FREE_Q_ST_CLOSED; + closeTime = time(NULL); } @@ -182,9 +210,7 @@ if (sem_destroy(&items) == -1) { err_exit(errno, "LockFreeQueue sem_destroy"); } - // if (sem_destroy(&mutex) == -1) { - // err_exit(errno, "LockFreeQueue sem_destroy"); - // } + } template< -- Gitblit v1.8.0