AsioIoContextRunner.h

Go to the documentation of this file.

 
 
#pragma once
 
#include <asio.hpp>
#include <thread>
 
namespace profinet
{
class IAsioIoContextRunner
{
 public:
  virtual ~IAsioIoContextRunner() = default;
 
  IAsioIoContextRunner() = default;
  IAsioIoContextRunner(const IAsioIoContextRunner&) = delete;
  IAsioIoContextRunner& operator=(const IAsioIoContextRunner&) = delete;
  IAsioIoContextRunner(IAsioIoContextRunner&&) = delete;
  IAsioIoContextRunner& operator=(IAsioIoContextRunner&&) = delete;
};
 
class AsioIoContextRunner : public IAsioIoContextRunner
{
 public:
  explicit AsioIoContextRunner(asio::io_context& ioContext)
      : ioContext(ioContext),
        workGuard(asio::make_work_guard(ioContext)),
        thread([&]
  {
    ioContext.run();
  })
  {
  }
 
  ~AsioIoContextRunner()
  {
    workGuard.reset();
    ioContext.stop();
 
    if (thread.joinable())
    {
      thread.join();
    }
  }
 
  AsioIoContextRunner(const AsioIoContextRunner&) = delete;
  AsioIoContextRunner& operator=(const AsioIoContextRunner&) = delete;
 
 private:
  asio::io_context& ioContext;
  asio::executor_work_guard<asio::io_context::executor_type> workGuard;
  std::jthread thread;
};
 
} // namespace profinet