Manager.hpp

Go to the documentation of this file.

#ifndef IFW_CTD_MPTK_MANAGER_HPP_
#define IFW_CTD_MPTK_MANAGER_HPP_

#include "ctd/mptk/Message.hpp"
#include "ctd/mptk/Thread.hpp"

namespace ctd {
namespace mptk {

class Manager {
public:

    Manager();

    ~Manager();

    void StartThreads();

    void PauseThreads();

    void StopThreads();

    int16_t WaitForThreadTerm(const double time_out = ctd::defines::NO_TIMEOUT);

    int16_t NbOfThreadsRunning() const;

    MessageBus& MsgBus();

    std::string Print() const;

    template <class THREAD_TYPE> void CreateThread(const std::string& thread_id,
                                                   MessageBus& message_bus,
                                                   const double period = 0.1) {
        THREAD_TYPE* thread_ptr = new THREAD_TYPE(thread_id, message_bus, period);
        m_threads[thread_id] = thread_ptr;
        MsgBus().RegisterThread(thread_id);
    }

private:
    MessageBus                     m_message_bus;
    std::map<std::string, Thread*> m_threads;
};

} // namespace mptk
} // namespace ctd

#endif // IFW_CTD_MPTK_MANAGER_HPP_