makrti50/rti13_classref/vl_thread_safe_queue_8h_source.html

 /*******************************************************************************

 ** 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 "internalTypes.h"

 #include <vlutil/vlMutex.h>

 #include <deque>

 #include <memory>


 template < class T >

 class DtThreadSafeQueue

 {

 public:


    DtThreadSafeQueue();


    virtual ~DtThreadSafeQueue();


    virtual inline void push_back(DtUniquePtr<T> elem );


    virtual inline void push_front(DtUniquePtr<T> elem );


    virtual inline DtUniquePtr<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

DtThreadSafeQueue
Very simple wrapper that provides thread-safe access to a basic queue pointers.
Definition: vlThreadSafeQueue.h:29

DtThreadSafeQueue::pop
virtual DtUniquePtr< T > pop()
Pop an element from the front of the queue Returns 0 if queue is empty.

DtThreadSafeQueue::size
virtual size_t size() const

DtThreadSafeQueue::~DtThreadSafeQueue
virtual ~DtThreadSafeQueue()
Dtor.

internalTypes.h
The declaration of internal types.

DtThreadSafeQueue::DtThreadSafeQueue
DtThreadSafeQueue()
Ctor.

DtThreadSafeQueue::myQueue
std::deque< T * > myQueue
Data Members.
Definition: vlThreadSafeQueue.h:55

DtThreadSafeQueue::push_back
virtual void push_back(DtUniquePtr< T > elem)
Push an element onto the back of the queue.

DtThreadSafeQueue::push_front
virtual void push_front(DtUniquePtr< T > elem)
Push an element onto the front of the queue.

DtThreadSafeQueue::myLock
MAKRti::DtMutex myLock
Lock for critical section access.
Definition: vlThreadSafeQueue.h:58