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 59 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 nullptr 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 nullptr 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. More...
std::mutex	m_csQueue
	The critical section. More...

Constructor & Destructor Documentation

CThreadSafeQueue()

template<class T>

mrpt::utils::CThreadSafeQueue< T >::CThreadSafeQueue ( )

inline

Default ctor.

Definition at line 70 of file CThreadSafeQueue.h.

~CThreadSafeQueue()

template<class T>

virtual mrpt::utils::CThreadSafeQueue< T >::~CThreadSafeQueue ( )

inlinevirtual

Definition at line 71 of file CThreadSafeQueue.h.

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

Here is the call graph for this function:

Member Function Documentation

clear()

template<class T>

void mrpt::utils::CThreadSafeQueue< T >::clear ( )

inline

Clear the queue of messages, freeing memory as required.

Definition at line 73 of file CThreadSafeQueue.h.

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

Referenced by mrpt::utils::CThreadSafeQueue< T >::~CThreadSafeQueue().

Here is the caller graph for this function:

empty()

template<class T>

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

inline

Return true if there are no messages.

Definition at line 135 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 nullptr if there is no message.

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

Definition at line 96 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 nullptr 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 115 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 86 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 142 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>

std::mutex mrpt::utils::CThreadSafeQueue< T >::m_csQueue

mutableprotected

The critical section.

Definition at line 66 of file CThreadSafeQueue.h.

Referenced by mrpt::utils::CThreadSafeQueue< T >::clear(), mrpt::utils::CThreadSafeQueue< T >::empty(), mrpt::utils::CThreadSafeQueue< T >::get(), mrpt::utils::CThreadSafeQueue< T >::get_lastest_purge_old(), mrpt::utils::CThreadSafeQueue< T >::push(), and mrpt::utils::CThreadSafeQueue< T >::size().

m_msgs

template<class T>

std::queue<T*> mrpt::utils::CThreadSafeQueue< T >::m_msgs

protected

The queue of messages.

Memory is freed at destructor or by clients gathering messages.

Definition at line 64 of file CThreadSafeQueue.h.

Referenced by mrpt::utils::CThreadSafeQueue< T >::clear(), mrpt::utils::CThreadSafeQueue< T >::empty(), mrpt::utils::CThreadSafeQueue< T >::get(), mrpt::utils::CThreadSafeQueue< T >::get_lastest_purge_old(), mrpt::utils::CThreadSafeQueue< T >::push(), and mrpt::utils::CThreadSafeQueue< T >::size().