worker.hpp

Go to the documentation of this file.

 
#ifndef WORKER_HPP_INCLUDED
#define WORKER_HPP_INCLUDED
 
#include <thread>
 
#include <exception>
#include <iostream>
 
#include "asio/io_context.hpp"
#include "asio/any_io_executor.hpp"
#include "asio/executor_work_guard.hpp"
 
namespace chops {
namespace net {
 
class worker {
private:
  asio::io_context                                           m_ioc;
  asio::executor_work_guard<asio::io_context::executor_type> m_wg;
  std::thread                                                m_run_thr;
 
public:
  worker() : m_ioc(), m_wg(asio::make_work_guard(m_ioc)), m_run_thr() { }
 
  asio::io_context& get_io_context() { return m_ioc; }
 
  void start() {
    m_run_thr = std::thread([this] () {
        try {
          m_ioc.run();
        }
        catch (const std::exception& e) {
          std::cerr << "std::exception caught in worker::start: " << e.what() << std::endl;
        }
        catch (...) {
          std::cerr << "Unknown exception caught in worker::start" << std::endl;
        }
      }
    );
  }
 
  void stop() {
    m_ioc.stop();
    m_run_thr.join();
  }
 
  void reset() {
    m_wg.reset();
    m_run_thr.join();
  }
 
};
 
 
}  // end net namespace
}  // end chops namespace
 
#endif