update

wangzhengquan

2021-02-08 bc2afe32e8db4318f2a2adea49d85b10d0d4cc97

 src/queue/lock_free_queue.h

@@ -13,7 +13,7 @@
#include "psem.h"
#include "bus_error.h"
#include "bus_def.h"
#include "read_write_lock.h"

// default Queue size
#define LOCK_FREE_Q_DEFAULT_SIZE 16

@@ -83,9 +83,10 @@
  sem_t slots;
  sem_t items;

  time_t createTime;

public:
  sem_t mutex;
  // sem_t mutex;


  LockFreeQueue(size_t qsize = LOCK_FREE_Q_DEFAULT_SIZE);
@@ -95,7 +96,7 @@
  /// template
  ~LockFreeQueue();

  std::atomic_uint reference;
  // std::atomic_uint reference;
  /// @brief constructor of the class


@@ -118,6 +119,10 @@
  inline bool empty();

  inline ELEM_T &operator[](unsigned i);

  time_t getCreateTime() {
    return createTime;
  }

  /// @brief push an element at the tail of the queue
  /// @param the element to insert in the queue
@@ -153,15 +158,14 @@
  typename ELEM_T,
  typename Allocator,
  template<typename T, typename AT> class Q_TYPE>
LockFreeQueue<ELEM_T, Allocator, Q_TYPE>::LockFreeQueue(size_t qsize): reference(0), m_qImpl(qsize) {
LockFreeQueue<ELEM_T, Allocator, Q_TYPE>::LockFreeQueue(size_t qsize): m_qImpl(qsize) {
  // std::cout << "LockFreeQueue init reference=" << reference << std::endl;
  if (sem_init(&slots, 1, qsize) == -1)
    err_exit(errno, "LockFreeQueue sem_init");
  if (sem_init(&items, 1, 0) == -1)
    err_exit(errno, "LockFreeQueue sem_init");
  if (sem_init(&mutex, 1, 1) == -1)
    err_exit(errno, "LockFreeQueue sem_init");

  
  createTime = time(NULL);

}

@@ -178,9 +182,9 @@
  if (sem_destroy(&items) == -1) {
    err_exit(errno, "LockFreeQueue sem_destroy");
  }
  if (sem_destroy(&mutex) == -1) {
    err_exit(errno, "LockFreeQueue sem_destroy");
  }
  // if (sem_destroy(&mutex) == -1) {
  //   err_exit(errno, "LockFreeQueue sem_destroy");
  // }
}

template<