| | |
|---|
| | | |
|---|
| | | #include <usg_common.h> |
|---|
| | | #include <assert.h> // assert() |
|---|
| | | #include "mem_pool.h" |
|---|
| | | #include "shm_mm.h" |
|---|
| | | #include "sem_util.h" |
|---|
| | | #include "logger_factory.h" |
|---|
| | | #include "shm_allocator.h" |
|---|
| | |
|---|
| | | ~LockFreeQueue(); |
|---|
| | | |
|---|
| | | inline void close(); |
|---|
| | | inline bool isClosed(); |
|---|
| | | |
|---|
| | | // std::atomic_uint reference; |
|---|
| | | /// @brief constructor of the class |
|---|
| | |
|---|
| | | closeTime = time(NULL); |
|---|
| | | } |
|---|
| | | |
|---|
| | | template< |
|---|
| | | typename ELEM_T, |
|---|
| | | typename Allocator, |
|---|
| | | template<typename T, typename AT> class Q_TYPE> |
|---|
| | | inline bool LockFreeQueue<ELEM_T, Allocator, Q_TYPE>::isClosed() { |
|---|
| | | return status == LOCK_FREE_Q_ST_CLOSED; |
|---|
| | | } |
|---|
| | | |
|---|
| | | |
|---|
| | | template< |
|---|
| | | typename ELEM_T, |
|---|
