threadActivity.hpp

Go to the documentation of this file.

 
#ifndef RTCTK_COMPONENTFRAMEWORK_THREADACTIVITY_HPP
#define RTCTK_COMPONENTFRAMEWORK_THREADACTIVITY_HPP
 
#include "rtctk/componentFramework/stopToken.hpp"
#include <scxml4cpp/Activity.h>
#include <functional>
#include <future>
 
namespace rtctk::componentFramework {
 
class ThreadActivity : public scxml4cpp::Activity
{
public:
 
    ThreadActivity(
            std::string const& id,
            std::function<void(StopToken st)> activity,
            std::function<void()> on_success = nullptr,
            std::function<void(const std::runtime_error&)> on_failure = nullptr);
 
    ~ThreadActivity();
 
    ThreadActivity(const ThreadActivity&) = delete;
    ThreadActivity& operator=(const ThreadActivity&) = delete;
 
    void start(scxml4cpp::Context* c) override;
    void stop(scxml4cpp::Context* c) override;
 
private:
    std::function<void(StopToken st)> m_activity_method;
    std::function<void()> m_success_method;
    std::function<void(const std::runtime_error&)> m_failure_method;
 
    StopSource m_stop_source;
    std::future<void> m_thread_observer;
    bool m_is_stopped;
};
 
}
 
#endif