WorkerThread.hpp

Go to the documentation of this file.

 
#ifndef UTILITIES_INCLUDE_UTILITIES_WORKERTHREAD_HPP_
#define UTILITIES_INCLUDE_UTILITIES_WORKERTHREAD_HPP_
 
#include "ers/ers.hpp"
#include "logging/Logging.hpp" // NOTE: if ISSUES ARE DECLARED BEFORE include logging/Logging.hpp, TLOG_DEBUG<<issue wont work.
 
#include <functional>
#include <future>
#include <list>
#include <memory>
#include <string>
 
namespace dunedaq::utilities {
class WorkerThread
{
public:
  explicit WorkerThread(std::function<void(std::atomic<bool>&)> do_work);

  void start_working_thread(const std::string& name = "noname");
  void stop_working_thread();

  bool thread_running() const { return m_thread_running.load(); }
 
  WorkerThread(const WorkerThread&) = delete;            
  WorkerThread& operator=(const WorkerThread&) = delete; 
  WorkerThread(WorkerThread&&) = delete;                 
  WorkerThread& operator=(WorkerThread&&) = delete;      
 
private:
  std::atomic<bool> m_thread_running;
  std::unique_ptr<std::jthread> m_working_thread;
  std::function<void(std::atomic<bool>&)> m_do_work;
};
} // namespace dunedaq::utilities
 
#endif // UTILITIES_INCLUDE_UTILITIES_WORKERTHREAD_HPP_