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