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_