threadActivity.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_THREADACTIVITY_HPP
#define RTCTK_COMPONENTFRAMEWORK_THREADACTIVITY_HPP
 
#include "rtctk/componentFramework/logger.hpp"
#include "rtctk/componentFramework/stopToken.hpp"
 
#include <functional>
#include <future>
#include <scxml4cpp/Activity.h>
 
namespace rtctk::componentFramework {

class ThreadActivity : public scxml4cpp::Activity {
public:
    using ActivityMethod = std::function<void(StopToken)>;
    using SuccessMethod = std::function<void()>;
    using FailureMethod = std::function<void(std::exception_ptr)>;
 
    ThreadActivity(const std::string& id,
                   ActivityMethod activity,
                   SuccessMethod on_success = nullptr,
                   FailureMethod on_failure = nullptr);
 
    ~ThreadActivity() override;
 
    ThreadActivity(const ThreadActivity&) = delete;
    ThreadActivity& operator=(const ThreadActivity&) = delete;
 
    void start(scxml4cpp::Context* c) override;
    void stop(scxml4cpp::Context* c) override;
 
private:
    log4cplus::Logger& m_logger;
    ActivityMethod m_activity_method;
    SuccessMethod m_success_method;
    FailureMethod m_failure_method;
 
    StopSource m_stop_source;
    std::future<void> m_thread_observer;
    std::atomic<bool> m_is_stopped;
    std::thread m_thread;
};
 
}  // namespace rtctk::componentFramework
 
#endif  // RTCTK_COMPONENTFRAMEWORK_THREADACTIVITY_HPP