ThreadRunnable.hpp

Go to the documentation of this file.

#ifndef IV_SRC_THREADS_THREADRUNNABLE_HPP_
#define IV_SRC_THREADS_THREADRUNNABLE_HPP_
 
#include "core/defines.hpp"
#include "threads/IRunnable.hpp"
 
#include <condition_variable>
#include <cstdint>
 
namespace iv::threads
{
 
class ThreadRunnable : public iv::threads::IRunnable
{
public:
    explicit ThreadRunnable(std::weak_ptr<bool> isEnabledRef);
    ThreadRunnable();
    ~ThreadRunnable() override;
    ThreadRunnable(const ThreadRunnable &other) = delete;
    ThreadRunnable(ThreadRunnable &&other) = delete;
 
    ThreadRunnable &operator=(const ThreadRunnable &other) = delete;
    ThreadRunnable &operator=(ThreadRunnable &&other) = delete;
 
    bool isRunning() override;
    bool isPaused() override;
    bool isStopped() override;
 
    void run() override;
    void pause() override;
    void resume() override;
    void stop() override;
 
protected:
    virtual void runFrame() = 0;
    void sleepFrame(iv::types::pollTime milliseconds);
 
private:
    std::mutex m_mutex;
    std::condition_variable m_cv;
    std::atomic<IRunnable::eRunnableState> m_stateThread;
 
    std::weak_ptr<bool> m_isEnabled;
};
 
}// namespace iv::threads
 
#endif /* IV_SRC_THREADS_THREADRUNNABLE_HPP_ */