DtThreadSafeQueue< T > Class Template Reference

Very simple wrapper that provides thread-safe access to a basic queue pointers. More...

Inheritance diagram for DtThreadSafeQueue< T >:

Collaboration diagram for DtThreadSafeQueue< T >:

Public Member Functions
	DtThreadSafeQueue ()
	Ctor.
virtual	~DtThreadSafeQueue ()
	Dtor.
virtual void	push_back (std::auto_ptr< T > elem)
	Push an element onto the back of the queue.
virtual void	push_front (std::auto_ptr< T > elem)
	Push an element onto the front of the queue.
virtual std::auto_ptr< T >	pop ()
	Pop an element from the front of the queue Returns 0 if queue is empty.
virtual size_t	size () const

Protected Attributes
std::deque< T * >	myQueue
	Data Members.
MAKRti::DtMutex	myLock
	Lock for critical section access.

Detailed Description

template<class T>
class DtThreadSafeQueue< T >

Very simple wrapper that provides thread-safe access to a basic queue pointers.

Queue always assumes ownership of pointed to objects. This implies that when the queue is deleted all objects on the queue are deleted as well. This also implies that this queue may not be used to store arrays.

Warning

This class is definitely not an STL compliant template, and it is

not 100% exception safe (lock may remain locked)

Constructor & Destructor Documentation

template<class T>

DtThreadSafeQueue< T >::DtThreadSafeQueue

(

)

Ctor.

template<class T>

virtual DtThreadSafeQueue< T >::~DtThreadSafeQueue ( )

virtual

Dtor.

Member Function Documentation

template<class T>

virtual std::auto_ptr<T> DtThreadSafeQueue< T >::pop ( )

inlinevirtual

Pop an element from the front of the queue Returns 0 if queue is empty.

Referenced by DtAsyncFileDistributorRunnable::executeCommand(), DtAsyncFileDistributorRunnable::getNextEvent(), DtAsyncFileDistributorRunnable::processInternalCommands(), and DtExtendedRtiMsgForwarder::refreshConnectionList().

template<class T>

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

inlinevirtual

Push an element onto the back of the queue.

Referenced by DtAsyncFileDistributorRunnable::executeCommand(), DtAsyncFileDistributorRunnable::fedFileUploaded(), DtAsyncFileDistributorRunnable::postCommand(), DtAsyncFileDistributorRunnable::processTakeFileCmd(), DtAsyncFileDistributorRunnable::registerFedFileRequestsEvent(), DtAsyncFileDistributorRunnable::registerPushFedFileToFederatesEvent(), DtAsyncFileDistributorRunnable::registerPushFedFileToSingleFederateEvent(), DtAsyncFileDistributorRunnable::registerRequestedModulesArrivedEvent(), DtAsyncFileDistributorRunnable::registerTakeFileEvent(), DtAsyncFileDistributorRunnable::registerUploadFedFileToExecEvent(), DtAsyncFileDistributorRunnable::requestFedFileUploadToExec(), DtAsyncFileDistributorRunnable::run(), DtAsyncFileDistributorRunnable::sendFedFile(), DtAsyncFileDistributorRunnable::setOnExitHandler(), DtExtendedRtiMsgForwarder::tcpSocketAdditionCb(), and DtExtendedRtiMsgForwarder::tcpSocketRemovalCb().

template<class T>

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

inlinevirtual

Push an element onto the front of the queue.

template<class T>

virtual size_t DtThreadSafeQueue< T >::size ( ) const

inlinevirtual

Member Data Documentation

template<class T>

MAKRti::DtMutex DtThreadSafeQueue< T >::myLock

mutableprotected

Lock for critical section access.

template<class T>

std::deque< T* > DtThreadSafeQueue< T >::myQueue

protected

Data Members.

---

The documentation for this class was generated from the following file:

• vlThreadSafeQueue.h