taskPoll.hpp

Go to the documentation of this file.

 
#ifndef CORE_PROTOCOL_OPEN62541_TASK_POLL_H_
#define CORE_PROTOCOL_OPEN62541_TASK_POLL_H_
 
#include <string>
#include <thread>
#include <atomic>
#include <chrono>
 
namespace ifw::core::protocol::opcua {

    class TaskPoll {
    public:

      TaskPoll(std::chrono::milliseconds period);

      virtual ~TaskPoll();

      void Run();
 
      void StartThread();
      void StopThread();
      bool IsRunning();
 
      TaskPoll(const TaskPoll&) = delete;              
      TaskPoll& operator= (const TaskPoll&) = delete;  
 
    private:
 
      std::chrono::milliseconds m_period;  

      std::thread m_poll_thread;

      std::atomic<bool> m_stopped {false};
 
    };
 
}  // namespace
 
#endif  // CORE_PROTOCOL_OPEN62541_TASK_POLL_H_