DtLockedBufferedQueue.h

Go to the documentation of this file.

/****************************************************************************** 
** Copyright (c) 2007 MAK Technologies, Inc. 
** All rights reserved. 
******************************************************************************/ 
/****************************************************************************** 
** $RCSfile: DtLockedBufferedQueue.h,v $ $Revision: 1.11 $ $State: Exp $ 
******************************************************************************/ 
 
 
#ifndef DtLockedBufferedQueue_H_ 
#define DtLockedBufferedQueue_H_ 
 
#include <vrvUtil/vrvUtil.h> 
#include <vlutil/vlMutex.h>
#include <vector>

namespace makVrv 
{ 
   template <typename T>
   class DtLockedBufferedQueue
   {
   public:
      DtLockedBufferedQueue();

      ~DtLockedBufferedQueue();


      unsigned int push(T value);

      unsigned int push( std::vector<T>& valueVector );

      void getForReading(std::vector<T>*& output);

      void deleteAllPointers();

      void clearBuffers();

   protected:

      void swapBuffers();

      std::vector<T> myFirstBuffer;
      std::vector<T> mySecondBuffer;   
      std::vector<T>* myCurrentBuffer;

      DtMutex myBufferMutex;
   };

} 

#define DtLockedBufferedQueue_INL_
#include <vrvUtil/DtLockedBufferedQueue.inl>
#undef DtLockedBufferedQueue_INL_


#endif