QueueMT.h

Go to the documentation of this file.

#pragma once

#include <queue>
#include <mutex>
#include <condition_variable>


namespace sw
{



template< typename ContentType >
class QueueMT
{
private:

    std::queue< ContentType >       m_queue;
    std::mutex                      m_accesslock;
    std::condition_variable         m_condition;

public:

    void        Push        ( const ContentType& element );
    void        Push        ( ContentType&& element );
    bool        TryPop      ( ContentType& element );
    void        Pop         ( ContentType& element );

    bool        IsEmpty     ();

};

template< typename ContentType >
inline void         QueueMT< ContentType >::Push    ( const ContentType& element )
{
    std::lock_guard< std::mutex > guard( m_accesslock );
    m_queue.push( element );
}

template< typename ContentType >
inline void         QueueMT< ContentType >::Push    ( ContentType&& element )
{
    std::lock_guard< std::mutex > guard( m_accesslock );
    m_queue.push( std::move( element ) );
}


template< typename ContentType >
inline void         QueueMT< ContentType >::Pop     ( ContentType & element )
{
    std::unique_lock< std::mutex > guard( m_accesslock );

    while( m_queue.empty() )
    {
        m_condition.wait( guard );
    }

    element = std::move( m_queue.front() );
    m_queue.pop();
}

template< typename ContentType >
inline bool         QueueMT< ContentType >::TryPop      ( ContentType & element )
{
    std::unique_lock< std::mutex > guard( m_accesslock );

    if( m_queue.empty() )
    {
        return false;
    }

    element = std::move( m_queue.front() );
    m_queue.pop();
    return true;
}

template< typename ContentType >
inline bool         QueueMT< ContentType >::IsEmpty ()
{
    std::lock_guard< std::mutex > guard( m_accesslock );
    return m_queue.empty();
}



}   // sw