IoThreadPool.h

Go to the documentation of this file.

 
#pragma once
#include <memory>
#include <string>
 
namespace boost { namespace asio { class io_context; } }
 
namespace catapult { namespace thread {
 
    class IoThreadPool {
    public:
        virtual ~IoThreadPool() = default;
 
    public:
        virtual uint32_t numWorkerThreads() const = 0;
 
        virtual const std::string& tag() const = 0;
 
        virtual boost::asio::io_context& ioContext() = 0;
 
    public:
        virtual void start() = 0;
 
        virtual void join() = 0;
    };
 
    std::unique_ptr<IoThreadPool> CreateIoThreadPool(size_t numWorkerThreads, const char* name = nullptr);
}}