activity.hpp

Go to the documentation of this file.

 
#ifndef RAD_ACTIVITY_HPP
#define RAD_ACTIVITY_HPP
 
#include <scxml4cpp/Activity.h>
 
#include <atomic>
#include <string>
#include <thread>
#include <mutex>
 
namespace rad {
 
class ThreadBaseActivity : public scxml4cpp::Activity {
   public:
    using Activity::Activity;
 
    ThreadBaseActivity(ThreadBaseActivity const&) = delete;
 
    void start(scxml4cpp::Context* c) override;
 
    void stop(scxml4cpp::Context* c) override;
 
    virtual pthread_t GetNativeHandle() const = 0;
 
    inline bool IsStopRequested() const { return m_stop_requested.load(std::memory_order_acquire); }
 
    virtual bool IsThreadJoined() const = 0;
 
   protected:
    // @todo Add error code?
    virtual void StartThread() = 0;
    virtual void JoinThread() = 0;
    // returns true if thread is joined == not running.
    // @}
 
   private:
    std::atomic<bool> m_stop_requested;  // Flag indicating whether the activity should stop.
};
 
class ThreadActivity : public ThreadBaseActivity {
   public:
    using ThreadBaseActivity::ThreadBaseActivity;
 
    ThreadActivity(const ThreadActivity&) = delete;
    ThreadActivity& operator=(const ThreadActivity&) = delete;
 
    virtual void Run() = 0;
 
    pthread_t GetNativeHandle() const override;
 
    bool IsThreadJoined() const override;
 
   protected:
    void StartThread() override;
    void JoinThread() override;
 
    std::string GetPthreadName();
 
    int SetPthreadName(const std::string& name);
 
   private:
    std::thread m_thread;
};
 
}  // namespace rad
 
#endif  // RAD_ACTIVITY_HPP