ThreadRunnablePeriodic.hpp

Go to the documentation of this file.

#ifndef IV_SRC_THREADS_THREADRUNNABLEPERIODIC_HPP_
#define IV_SRC_THREADS_THREADRUNNABLEPERIODIC_HPP_
 
#include "logs/CLoggerZenity.hpp"
#include "threads/ThreadRunnable.hpp"
 
#include <chrono>
#include <fmt/format.h>
#include <iostream>
 
namespace iv::threads
{
 
class ThreadRunnablePeriodic : public iv::threads::ThreadRunnable
{
public:
    explicit ThreadRunnablePeriodic(const iv::types::pollTime sleepMs) : m_sleepMs(sleepMs)
    {
    }
 
    ThreadRunnablePeriodic(const iv::types::pollTime sleepMs, const std::weak_ptr<bool> &isEnabledRef)
        : ThreadRunnable(isEnabledRef), m_sleepMs(sleepMs)
    {
    }
 
    ~ThreadRunnablePeriodic() override = default;
 
    virtual void periodicTask() = 0;
 
private:
    void runFrame() override
    {
        try
        {
            periodicTask();
            sleepFrame(m_sleepMs);
        }
        catch (const std::exception &e)
        {
            auto errorMessage = fmt::format("ThreadRunnablePeriodic::runFrame() thread name: {} exception: {}",
                                            m_taskName, e.what());
#ifndef NDEBUG
            CLoggerZenity::showErrorDialog(errorMessage);
#else
            std::cerr << errorMessage << std::endl;
#endif
        }
    }
 
    iv::types::pollTime m_sleepMs;
};
 
}// namespace iv::threads
 
#endif /* IV_SRC_THREADS_THREADRUNNABLEPERIODIC_HPP_ */