vlLockfreeMpmcQueue.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2014 VT MAK
** All rights reserved.
*********************************************************************/
#pragma once

#ifdef WIN32
#if _MSC_VER < 1400
#define LOCKFREEQUEUE_UNSUPPORTED
#endif
#endif

#ifndef LOCKFREEQUEUE_UNSUPPORTED

#include <vlutil/vlMachineTypes.h>

#ifdef DtUSE_UTILITIES_NAMESPACE
namespace DtUSE_UTILITIES_NAMESPACE
{
#endif


class DT_DLL_VLUTIL DtLockfreeMpmcQueueImpl
{
public:
   DtLockfreeMpmcQueueImpl(unsigned int size);

   virtual ~DtLockfreeMpmcQueueImpl();

   bool _push(void* const & t);

   size_t _pop(void* & ret);

   bool _empty();

private:
   void* myQueue;
};

template<class T>
class DtLockfreeMpmcQueue : public DtLockfreeMpmcQueueImpl
{

public:

   DtLockfreeMpmcQueue(unsigned int size) : DtLockfreeMpmcQueueImpl(size)
   {
   }
   
   ~DtLockfreeMpmcQueue()
   {

   }

   inline bool push(T const & t)
   {
      return _push(reinterpret_cast<void*>(t));
   }

   inline size_t pop(T & ret)
   {
      return _pop(reinterpret_cast<void* &>(ret));
   }

   inline bool empty(void)
   {
      return _empty();
   }
};


#ifdef DtUSE_UTILITIES_NAMESPACE
} // end of namespace DtUSE_UTILITIES_NAMESPACE
#endif

#endif