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>

namespace rad {

class ThreadBaseActivity : public scxml4cpp::Activity {
   public:
    using Activity::Activity;

    ThreadBaseActivity(ThreadBaseActivity const&) = delete;
    void start() override;
    void stop() override;

    std::string GetName() const;

    int SetName(const std::string& name);

    virtual pthread_t GetNativeHandle() const = 0;

    // @{
    // Method used by child classes to check whether they should be stopping
    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;
};

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;

   private:
    std::thread m_thread;
};

}  // namespace rad

#endif  // RAD_ACTIVITY_HPP