killableActivity.hpp

Go to the documentation of this file.

 
#ifndef IFWSLM_KILLABLE_ACTIVITY_HPP
#define IFWSLM_KILLABLE_ACTIVITY_HPP
 
#include <rad/activity.hpp>
#include <atomic>
#include <string>
#include <thread>
 
namespace ifw::slm {
 
class KillableThreadActivity : public rad::ThreadBaseActivity {
public:
    using ThreadBaseActivity::ThreadBaseActivity;
 
    KillableThreadActivity(const KillableThreadActivity&) = delete;
    KillableThreadActivity& operator=(const KillableThreadActivity&) = delete;
 
    virtual void Run() = 0;
 
    pthread_t GetNativeHandle() const override;
 
    bool IsThreadJoined() const override;
 
protected:
    void StartThread() override;
    void JoinThread() override;
 
    std::atomic<bool> m_killed{false};
    std::atomic<int>  m_thread_generation{0};
 
private:
    std::thread m_thread;
};
 
}  // namespace ifw::slm
 
#endif  // IFWSLM_KILLABLE_ACTIVITY_HPP