PosixPrioritySharedQueue< T, _Priority > Class Template Reference

Thread-safe FIFO priority queue class. More...

#include <PosixPrioritySharedQueue.hpp>

Public Member Functions
	PosixPrioritySharedQueue ()
	Constructor. Initialize the queue.
	~PosixPrioritySharedQueue ()
	Destructor. Clean up the resources.
void	addQueue (const _Priority &prio)
	Adds new priority.
void	push (const T &data, const _Priority &prio)
	Insert an new element in the queue.
T	pop ()
	Extract an element from the queue.
void	clear ()
	Empties the queue.
size_t	size () const
	The current size of the queue.

Private Member Functions
	PosixPrioritySharedQueue (const PosixPrioritySharedQueue &)
PosixPrioritySharedQueue &	operator= (const PosixPrioritySharedQueue &)

Private Attributes
std::map< _Priority, std::queue< T > >	queues_
pthread_cond_t	empty_
pthread_mutex_t	mutex_
size_t	globalSize_

Detailed Description

template<typename T, typename _Priority = int>
class onposix::PosixPrioritySharedQueue< T, _Priority >

Thread-safe FIFO priority queue class.

No aging techniques are implemented, so that the low priority elements can starve. The class is noncopyable.
The template paramaters are:

• T is the type of the element in the queue
• _Priority is the priority type (shall support the less operator)

Definition at line 24 of file PosixPrioritySharedQueue.hpp.

Constructor & Destructor Documentation

PosixPrioritySharedQueue ( const PosixPrioritySharedQueue< T, _Priority > &  )

private

PosixPrioritySharedQueue

(

)

Constructor. Initialize the queue.

Exceptions

runtime_error

if the initialization fails.

Definition at line 56 of file PosixPrioritySharedQueue.hpp.

                                                                :
        globalSize_(0)
{
        if (pthread_mutex_init(&mutex_, NULL) != 0)
                throw std::runtime_error(std::string("Mutex initialization: ") +
                                                                 strerror(errno));
        if (pthread_cond_init(&empty_, NULL) != 0)
                throw std::runtime_error(
                                std::string("Condition variable initialization: ") +
                                strerror(errno));