ioExecutor.hpp

Go to the documentation of this file.

#ifndef RAD_IO_EXECUTOR_HPP_
#define RAD_IO_EXECUTOR_HPP_
// GCOVR_EXCL_START
#include <boost/asio/io_context.hpp>
 
namespace rad {
 
/**
* Adapts boost::asio::io_context into a compatible boost::thread Executor type.
* This must match boost::thread Executor concept.
*/
class IoExecutor {
  public:
    explicit IoExecutor(boost::asio::io_context& ctx) : m_io_context(&ctx) {}
    IoExecutor(IoExecutor&&) = default;
    IoExecutor& operator=(IoExecutor&&) = default;
    IoExecutor(IoExecutor const&) = delete;
    IoExecutor& operator=(IoExecutor&) = delete;
 
 
 
    void close()  { // NOLINT
        m_io_context->stop();
    }
    bool closed() { // NOLINT
        return m_io_context->stopped();
    }
 
    template <typename Closure>
    void submit(Closure&& closure) { // NOLINT
        return m_io_context->post(std::move(closure));
    }
 
    bool try_executing_one()  { // NOLINT
        return m_io_context->poll_one();
    }
 
    /**
     * Not part of the boost::thread::executor concept.
     */
    boost::asio::io_context& get_io_context() noexcept { // NOLINT
        return *m_io_context;
    }
  private:
    boost::asio::io_context* m_io_context;
};
 
}
// GCOVR_EXCL_STOP
#endif // #ifndef RAD_IO_EXECUTOR_HPP_