pthreadActivity.hpp

Go to the documentation of this file.

#ifndef RAD_ACTIVITY_PTHREAD_HPP
#define RAD_ACTIVITY_PTHREAD_HPP

#include <rad/activity.hpp>

#include <scxml4cpp/Activity.h>
#include <scxml4cpp/Event.h>

#include <pthread.h>

#include <atomic>
#include <string>

namespace rad {

class PthreadActivity : public ThreadBaseActivity {
   public:
    explicit PthreadActivity(const std::string& id, const int cpu = -1, const int priotity = -1);

    virtual ~PthreadActivity();

    virtual void Run() = 0;

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

    int GetCPU() const;
    int GetConfiguredCPU() const;
    void SetConfiguredCPU(const int cpu);
    int GetPriority();
    int GetConfiguredPriority() const;
    void SetConfiguredPriority(const int priority);

    pthread_t GetNativeHandle() const override;

    PthreadActivity(const PthreadActivity&) = delete;             
    PthreadActivity& operator=(const PthreadActivity&) = delete;  

   protected:
    void StartThread() override;
    void JoinThread() override;
    bool IsThreadJoined() const override;

   private:
    std::atomic<bool> m_thread_id_valid;
    pthread_t m_thread_id;
    int m_cpu;
    int m_priority;

    static void* RunWrapper(void* arg);
};

}  // namespace rad

#endif  // RAD_ACTIVITY_PTHREAD_HPP