MQMutex.h

/*
 * Copyright (c) 2015 Pavel Vainerman.
 *
 * This program is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, version 2.1.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
 * Lesser General Lesser Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program. If not, see <http://www.gnu.org/licenses/>.
 */
// --------------------------------------------------------------------------
#ifndef MQMutex_H_
#define MQMutex_H_
//--------------------------------------------------------------------------
#include <deque>
#include <list>
#include <memory>
#include "Mutex.h"
#include "MessageType.h"
//--------------------------------------------------------------------------
namespace uniset
{
//--------------------------------------------------------------------------
typedef std::shared_ptr<uniset::VoidMessage> VoidMessagePtr;
//--------------------------------------------------------------------------

class MQMutex
{
    public:
        MQMutex( size_t qsize = 2000 );

        void push( const VoidMessagePtr& msg );

        VoidMessagePtr top() noexcept;

        size_t size();
        bool empty();

        // ----- Настройки  -----
        // неявно подразумевается, что всё настраивается до первого использования
        // ----------------------
        void setMaxSizeOfMessageQueue( size_t s ) noexcept;
        size_t getMaxSizeOfMessageQueue() const noexcept;

        enum LostStrategy
        {
            lostOldData, // default
            lostNewData
        };

        void setLostStrategy( LostStrategy s ) noexcept;

        // ---- Статистика ----
        inline size_t getMaxQueueMessages() const noexcept
        {
            return stMaxQueueMessages;
        }

        inline size_t getCountOfLostMessages() const noexcept
        {
            return stCountOfLostMessages;
        }

    protected:

    private:

        //typedef std::queue<VoidMessagePtr> MQueue;
        typedef std::deque<VoidMessagePtr> MQueue;

        MQueue mqueue;
        std::mutex qmutex;

        LostStrategy lostStrategy = { lostOldData };

        size_t SizeOfMessageQueue = { 2000 };

        // статистическая информация
        size_t stMaxQueueMessages = { 0 };    
        size_t stCountOfLostMessages = { 0 };    
};
// -------------------------------------------------------------------------
} // end of uniset namespace
//---------------------------------------------------------------------------
#endif
//---------------------------------------------------------------------------