mn_workqueue_multi.hpp

Go to the documentation of this file.

/*
*This file is part of the Mini Thread Library (https://github.com/RoseLeBlood/MiniThread ).
*Copyright (c) 2020 Amber-Sophia Schroeck
*
*The Mini Thread Library 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 3, or (at your option) any later version.
 
*The Mini Thread Library 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 
*General Public License for more details.
*
*You should have received a copy of the GNU Lesser General Public
*License along with the Mini Thread  Library; if not, see
*<https://www.gnu.org/licenses/>.  
*/
#ifndef MINLIB_ESP32_WORK_QUEUE_MULTI_
#define MINLIB_ESP32_WORK_QUEUE_MULTI_
 
#include "mn_workqueue.hpp"
#include <vector>
 
namespace mn {
    namespace queue {
        class basic_work_queue_multi : public basic_work_queue {
        public:
            basic_work_queue_multi(basic_task::priority uiPriority = MN_THREAD_CONFIG_WORKQUEUE_MULTI_PRIORITY,
                        uint16_t usStackDepth = MN_THREAD_CONFIG_WORKQUEUE_MULTI_STACKSIZE,
                        uint8_t uiMaxWorkItems = MN_THREAD_CONFIG_WORKQUEUE_MULTI_MAXITEMS,
                        uint8_t uiMaxWorkers = MN_THREAD_CONFIG_WORKQUEUE_MULTI_WORKER);
 
            ~basic_work_queue_multi();
 
            uint8_t get_num_worker() const;
            uint8_t get_num_max_worker() const;
            std::vector<work_queue_task*>& workers();
        protected:
            int create_engine(int iCore);
 
            void destroy_engine();
 
        private:
            std::vector<work_queue_task*> m_Workers;
            uint8_t m_uiMaxWorkers;
        };
 
        using multi_engine_workqueue_t = basic_work_queue_multi;
    }
}
 
#endif