WorkerThread.cpp

Go to the documentation of this file.

 
#include "utilities/WorkerThread.hpp"
#include "utilities/Issues.hpp"
 
#include <memory>
#include <string>
 
dunedaq::utilities::WorkerThread::WorkerThread(std::function<void(std::atomic<bool>&)> do_work)
  : m_thread_running(false)
  , m_working_thread(nullptr)
  , m_do_work(do_work)
{
}
 
void
dunedaq::utilities::WorkerThread::start_working_thread(const std::string& name)
{
  if (thread_running()) {
    throw ThreadingIssue(ERS_HERE,
                         "Attempted to start working thread "
                         "when it is already running!");
  }
  m_thread_running = true;
  m_working_thread = std::make_unique<std::jthread>([&] { m_do_work(std::ref(m_thread_running)); });
  auto handle = m_working_thread->native_handle();
  auto rc = pthread_setname_np(handle, name.c_str());
  if (rc != 0) {
    std::ostringstream s;
    s << "The name " << name << " provided for the thread is too long.";
    ers::warning(ThreadingIssue(ERS_HERE, s.str()));
  }
}
 
void
dunedaq::utilities::WorkerThread::stop_working_thread()
{
  if (!thread_running()) {
    throw ThreadingIssue(ERS_HERE,
                         "Attempted to stop working thread "
                         "when it is not running!");
  }
  m_thread_running = false;
 
  if (m_working_thread->joinable()) {
    try {
      m_working_thread->join();
    } catch (std::system_error const& e) {
      throw ThreadingIssue(ERS_HERE, std::string("Error while joining thread, ") + e.what());
    }
  } else {
    throw ThreadingIssue(ERS_HERE, "Thread not in joinable state during working thread stop!");
  }
}