vlThreadSafeBufferQueue.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2005 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: vlThreadSafeBufferQueue.h,v $ $Revision: 1.3 $ $State: Exp $
*******************************************************************************/


#ifndef DtThreadSafeBufferQueue_H_
#define DtThreadSafeBufferQueue_H_

#include <vlutil/vlMutex.h>
#include <deque>
#include <memory>


template< class T >
class DtThreadSafeBufferQueue
{
public:

   typedef std::vector<T>      Buffer;
   typedef std::deque<Buffer*> BufferQueue; 
   
   DtThreadSafeBufferQueue( unsigned int initialBufferSize = 1000,
                            unsigned int initialBufferCount = 10 );

   virtual ~DtThreadSafeBufferQueue();

   virtual inline void push( const T* buff, unsigned int size );

   virtual inline void push( Buffer buff );

   virtual inline DtUniquePtr< Buffer > pop();

   virtual inline void releaseBuffer(DtUniquePtr< Buffer > buff );
   
   virtual inline size_t size() const;

protected:

   BufferQueue myQueue;
   BufferQueue myFreeBuffers;
   
   mutable MAKRti::DtMutex myLock;
   
};

#define DtThreadSafeBufferQueue_Inl_
#include "vlThreadSafeBufferQueue.inl"
#undef DtThreadSafeBufferQueue_Inl_
   
#endif