vlThreadSafeQueue.h

Go to the documentation of this file.

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


#ifndef DtThreadSafeQueue_H_
#define DtThreadSafeQueue_H_

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


template < class T >
class DtThreadSafeQueue
{
public:

   DtThreadSafeQueue();

   virtual ~DtThreadSafeQueue();

   virtual inline void push_back( std::auto_ptr<T> elem );

   virtual inline void push_front( std::auto_ptr<T> elem );

   virtual inline std::auto_ptr<T> pop();

   virtual inline size_t size() const;

protected:


   std::deque< T* > myQueue;
   
   mutable MAKRti::DtMutex myLock;
   
};

#define DtThreadSafeQueue_Inl_
#include "vlThreadSafeQueue.inl"
#undef DtThreadSafeQueue_Inl_
   
#endif //! MAKRti::DtThreadSafeQueue_H_