ActivityPthread.hpp

Go to the documentation of this file.

#ifndef RAD_ACTIVITY_PTHREAD_HPP
#define RAD_ACTIVITY_PTHREAD_HPP

#include <rad/AnyEvent.hpp>
#include <rad/SMAdapter.hpp>

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

#include <pthread.h>

#include <string>


namespace rad {

class ActivityPthread : public scxml4cpp::Activity
{
public:
    ActivityPthread(const std::string& id,
                    rad::SMAdapter& sm,
                    const int cpu = -1,
                    const int priotity = -1);

    virtual ~ActivityPthread();

    virtual void start();
    virtual void stop();
    virtual void run() = 0;

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

    int                 GetCPU() const;
    int                 GetConfiguredCPU() const;
    int                 GetPriority();
    int                 GetConfiguredPriority() const;
    rad::SMAdapter&     GetSM();

    void TriggerInternalEvent(UniqueEvent&& e);

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

private:
    pthread_t           mThreadId;
    rad::SMAdapter&     mSM;
    int                 mCPU;
    int                 mPriority;

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

}  // namespace rad

#endif  // RAD_ACTIVITY_PTHREAD_HPP