tsigas_API.h

Go to the documentation of this file.

#ifndef __TSIGAS_BUFFER_H__
#define __TSIGAS_BUFFER_H__

#include <cds/container/tsigas_cycle_queue.h>
#include <cds/init.h>       // for cds::Initialize and cds::Terminate
#include <cds/gc/hp.h>      // for cds::HP (Hazard Pointer) garbage collector

#define USING_CDS_LIB 1

template<class T>
class TestClass {
 public:
  TestClass(size_t capacity, size_t num_threads) {
    queue_ = new TQueue(capacity);
  };

  char * name() {
    return "CDS Tsiagas Cycle Queue";
  }

  void attach_thread() {
    cds::threading::Manager::attachThread();
  };

  void detach_thread() {
    cds::threading::Manager::detachThread();
  };

  bool enqueue(T val) {
    return queue_->enqueue(val);
  };
  bool dequeue(T &val) {
    return queue_->dequeue(val);
  };

 private:
  typedef cds::container::TsigasCycleQueue<T,
      cds::opt::buffer< cds::opt::v::dynamic_buffer<T> >  > TQueue;
  TQueue *queue_;
};

#endif  // __TSIGAS_BUFFER_H__