Main MRPT website > C++ reference for MRPT 1.5.7
List of all members | Public Member Functions | Protected Attributes
mrpt::utils::CThreadSafeQueue< T > Class Template Reference

Detailed Description

template<class T>
class mrpt::utils::CThreadSafeQueue< T >

A thread-safe template queue for object passing between threads; for a template argument of T, the objects being passed in the queue are "T*".

Usage example:

// Declaration:
CThreadSafeQueue<MyMsgType> tsq;
...
// Thread 1: Write
{
MyMsgType *msg = new MyMsgType;
msg->...
tsq.push(msg); // Insert in the queue
}
// Thread 2: Read
{
MyMsgType *msg = tsq.get();
if (msg)
{
// Process "msg"...
delete msg;
}
}

Note that only dynamically allocated objects can be inserted with push() and that freeing that memory if responsibility of the receiver of this queue as it receives objects with get(). However, elements still in the queue upon destruction will be deleted automatically.

See also
mrpt::utils::CMessageQueue

Definition at line 55 of file CThreadSafeQueue.h.

#include <mrpt/utils/CThreadSafeQueue.h>

Public Member Functions

 CThreadSafeQueue ()
 Default ctor. More...
 
virtual ~CThreadSafeQueue ()
 
void clear ()
 Clear the queue of messages, freeing memory as required. More...
 
void push (T *msg)
 Insert a new message in the queue - The object must be created with "new", and do not delete is after calling this, it must be deleted later. More...
 
T * get ()
 Retrieve the next message in the queue, or NULL if there is no message. More...
 
T * get_lastest_purge_old ()
 Skip all old messages in the queue and directly return the last one (the most recent, at the bottom of the queue), or NULL if there is no message. More...
 
bool empty () const
 Return true if there are no messages. More...
 
size_t size () const
 Return the number of queued messages. More...
 

Protected Attributes

std::queue< T * > m_msgs
 The queue of messages. Memory is freed at destructor or by clients gathering messages. More...
 
mrpt::synch::CCriticalSection m_csQueue
 The critical section. More...
 

Constructor & Destructor Documentation

◆ CThreadSafeQueue()

template<class T>
mrpt::utils::CThreadSafeQueue< T >::CThreadSafeQueue ( )
inline

Default ctor.

Definition at line 62 of file CThreadSafeQueue.h.

◆ ~CThreadSafeQueue()

template<class T>
virtual mrpt::utils::CThreadSafeQueue< T >::~CThreadSafeQueue ( )
inlinevirtual

Definition at line 64 of file CThreadSafeQueue.h.

References mrpt::utils::CThreadSafeQueue< T >::clear().

Member Function Documentation

◆ clear()

template<class T>
void mrpt::utils::CThreadSafeQueue< T >::clear ( )
inline

◆ empty()

template<class T>
bool mrpt::utils::CThreadSafeQueue< T >::empty ( ) const
inline

Return true if there are no messages.

Definition at line 126 of file CThreadSafeQueue.h.

References mrpt::utils::CThreadSafeQueue< T >::m_csQueue, and mrpt::utils::CThreadSafeQueue< T >::m_msgs.

◆ get()

template<class T>
T* mrpt::utils::CThreadSafeQueue< T >::get ( )
inline

Retrieve the next message in the queue, or NULL if there is no message.

The user MUST call "delete" with the returned object after use.

Definition at line 91 of file CThreadSafeQueue.h.

References mrpt::utils::CThreadSafeQueue< T >::m_csQueue, and mrpt::utils::CThreadSafeQueue< T >::m_msgs.

◆ get_lastest_purge_old()

template<class T>
T* mrpt::utils::CThreadSafeQueue< T >::get_lastest_purge_old ( )
inline

Skip all old messages in the queue and directly return the last one (the most recent, at the bottom of the queue), or NULL if there is no message.

Note
The memory of all skipped messages is freed with "delete".
The user MUST call "delete" with the returned object after use.

Definition at line 108 of file CThreadSafeQueue.h.

References mrpt::utils::CThreadSafeQueue< T >::m_csQueue, and mrpt::utils::CThreadSafeQueue< T >::m_msgs.

◆ push()

template<class T>
void mrpt::utils::CThreadSafeQueue< T >::push ( T *  msg)
inline

Insert a new message in the queue - The object must be created with "new", and do not delete is after calling this, it must be deleted later.

Definition at line 82 of file CThreadSafeQueue.h.

References mrpt::utils::CThreadSafeQueue< T >::m_csQueue, and mrpt::utils::CThreadSafeQueue< T >::m_msgs.

◆ size()

template<class T>
size_t mrpt::utils::CThreadSafeQueue< T >::size ( ) const
inline

Return the number of queued messages.

Definition at line 133 of file CThreadSafeQueue.h.

References mrpt::utils::CThreadSafeQueue< T >::m_csQueue, and mrpt::utils::CThreadSafeQueue< T >::m_msgs.

Member Data Documentation

◆ m_csQueue

template<class T>
mrpt::synch::CCriticalSection mrpt::utils::CThreadSafeQueue< T >::m_csQueue
protected

◆ m_msgs

template<class T>
std::queue<T*> mrpt::utils::CThreadSafeQueue< T >::m_msgs
protected



Page generated by Doxygen 1.8.14 for MRPT 1.5.7 Git: 5902e14cc Wed Apr 24 15:04:01 2019 +0200 at lun oct 28 01:39:17 CET 2019