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 {
 
// Disable coverage collection LCOV_EXCL_START
ERS_DECLARE_ISSUE(utilities,                           // Namespace
                  ThreadingIssue,                      // Issue Class Name
                  "Threading Issue detected: " << err, // Message
                  ((std::string)err))                  // Message parameters
// Re-enable coverage collection LCOV_EXCL_STOP
 
namespace 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::thread> m_working_thread;
  std::function<void(std::atomic<bool>&)> m_do_work;
};
} // namespace utilities
 
} // namespace dunedaq
 
#endif // UTILITIES_INCLUDE_UTILITIES_WORKERTHREAD_HPP_