Thread.hpp

Go to the documentation of this file.

#ifndef IFW_CTD_MPTK_THREAD_HPP_
#define IFW_CTD_MPTK_THREAD_HPP_

#include <string>
#include <thread>

#include "rad/Logger.hpp"
#include "rad/Exceptions.hpp"

#include "ctd/mptk/MessageBus.hpp"

namespace ctd {
namespace mptk {

class Thread {
public:
    static std::map<std::string, Thread*> s_thread_registry;
    static const std::string THREAD_REGISTRY;

    typedef enum {
        THREAD_EXEC_STOPPED = 1,
        THREAD_EXEC_RUNNING,
        THREAD_EXEC_PAUSED
    } ThreadExecControl;

    Thread(const std::string& thread_id,
           MessageBus& message_bus,
           const double period = 0.1);

    virtual ~Thread();

    std::string Id();

    void Loop();

    virtual void UserLogic();

    void Start();

    void Stop();

    void Pause();

    bool CheckExecFlag();

    ThreadExecControl GetExecFlag() const;

    bool Terminated() const;

    MessageBus& MsgBus();

    std::string Print() const;

private:
    std::string       m_thread_id;
    double            m_period;
    ThreadExecControl m_exec_flag;
    double            m_start_time;
    double            m_previous_start_time;
    double            m_next_execution;
    bool              m_thread_terminated;

    std::shared_ptr<std::thread> m_sys_thread;
    MessageBus*       m_message_bus;
};

} // namespace mptk
} // namespace ctd

#endif // IFW_CTD_MPTK_THREAD_HPP_