mn_msg_task.hpp

Go to the documentation of this file.

 
#ifndef MINLIB_ESP32_MESSAGE_TASK_
#define MINLIB_ESP32_MESSAGE_TASK_
 
#include "mn_config.hpp"
#if MN_THREAD_CONFIG_CONDITION_VARIABLE_SUPPORT == MN_THREAD_CONFIG_YES
 
 
#include "mn_convar.hpp"
#include "mn_convar_task.hpp"
#include "queue/mn_queue.hpp"
 
namespace mn {
    namespace ext {
        struct task_message {
            using message_id = int;
 
            message_id id;              
            void* message;              
            task_message(message_id _id, void* _message = nullptr)
                : id(_id), message(_message) { }
        };
        class basic_message_task : public basic_convar_task  {
        public:
            using message_id = typename task_message::message_id;
 
            explicit basic_message_task(std::string strName = "message_task",
                                        basic_task::priority uiPriority = priority::Normal,
                                        unsigned short  usStackDepth = MN_THREAD_CONFIG_MINIMAL_STACK_SIZE);
 
            void post_msg(task_message* msg, unsigned int timeout);
 
            void post_msg(message_id msg_id, unsigned int timeout) {
                post_msg(new task_message(msg_id, nullptr), timeout );
            }
            void post_msg(message_id msg_id, void* message_data, unsigned int timeout) {
                post_msg(new task_message(msg_id, message_data), timeout );
            }
 
            basic_message_task(const basic_message_task&) = delete;
            basic_message_task& operator=(const basic_message_task&) = delete;
        protected:
            virtual void on_message(id_t id, void* message) = 0;
        private:
            int  on_task();
        protected:
            mutex_t m_ltMessageQueueLock;
            queue::queue_t m_qeMessageQueue;
            convar_t m_cvMessage;
        };
 
        using message_task_t = basic_message_task;
    }
}
#endif
 
#endif