MessageQueue< T > Class Template Reference

#include <MessageQueue.h>

Inheritance diagram for MessageQueue< T >:

Collaboration diagram for MessageQueue< T >:

Public Member Functions
void	push (T value)
T	pop ()
bool	try_pop (T &value)

Private Attributes
std::queue< T >	queue_
std::mutex	mutex_
std::condition_variable	condition_

Detailed Description

template<typename T>
class MessageQueue< T >

Definition at line 8 of file MessageQueue.h.

Member Function Documentation

pop()

template<typename T >

T MessageQueue< T >::pop ( )

inline

Definition at line 24 of file MessageQueue.h.

    {
        std::unique_lock<std::mutex> lock(mutex_);
        condition_.wait(lock, [this]
                        { return !queue_.empty(); });
        T value = std::move(queue_.front());
        queue_.pop();
        return value;
    }

push()

template<typename T >

void MessageQueue< T >::push ( T value )

inline

Definition at line 16 of file MessageQueue.h.

    {
        std::unique_lock<std::mutex> lock(mutex_);
        queue_.push(std::move(value));
        lock.unlock();
        condition_.notify_one();
    }

Here is the caller graph for this function:

try_pop()

template<typename T >

bool MessageQueue< T >::try_pop ( T & value )

inline

Definition at line 34 of file MessageQueue.h.

    {
        std::unique_lock<std::mutex> lock(mutex_);
        if (queue_.empty())
        {
            return false;
        }
        value = std::move(queue_.front());
        queue_.pop();
        return true;
    }

Here is the caller graph for this function:

Member Data Documentation

condition_

template<typename T >

std::condition_variable MessageQueue< T >::condition_

private

Definition at line 13 of file MessageQueue.h.

mutex_

template<typename T >

std::mutex MessageQueue< T >::mutex_

private

Definition at line 12 of file MessageQueue.h.

queue_

template<typename T >

std::queue<T> MessageQueue< T >::queue_

private

Definition at line 11 of file MessageQueue.h.

---

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

• include/network/MessageQueue.h