vlLockfreeQueue.h

Go to the documentation of this file.

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

#ifdef WIN32
#if _MSC_VER < 1400 // MSVC++ 8.0 2005
#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 DtLockfreeQueueImpl
{
public:
   DtLockfreeQueueImpl(size_t sizeToUse);

   virtual ~DtLockfreeQueueImpl();

   size_t _size() const;

   bool _push(void* const & t);

   size_t _pop(void* & ret);

   bool _empty();

   size_t _read_available() const;

   size_t _write_available() const;

private:
   void* myQueue;
   size_t mySize;
};

template<class T>
class DtLockfreeQueue : public DtLockfreeQueueImpl
{

public:

   DtLockfreeQueue(size_t sizeToUse) : DtLockfreeQueueImpl(sizeToUse)
   {
   }
   
   ~DtLockfreeQueue()
   {

   }

   inline size_t size() const
   {
      return _size();
   }

   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();
   }

   inline size_t readAvailableForConsumption() const
   {
      return _read_available();
   }

   inline size_t writeAvailableForProduction() const
   {
      return _write_available();
   }

   inline size_t writtenAvailableForConsumption() const
   {
      return size() - writeAvailableForProduction();
   }
};


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

#endif