src/api/transport/rpc_thread_pool.cpp

Namespaces

Name
sgns
sgns::api

Source code

#include "api/transport/rpc_thread_pool.hpp"

namespace sgns::api {

  RpcThreadPool::RpcThreadPool(std::shared_ptr<Context> context,
                               const Configuration &configuration)
      : context_(std::move(context)), config_(configuration) {
    BOOST_ASSERT(context_);
  }

  void RpcThreadPool::start() {
    threads_.reserve(config_.max_thread_number);
    // Create a pool of threads to run all of the io_contexts.
    for (std::size_t i = 0; i < config_.min_thread_number; ++i) {
      auto thread = std::make_shared<std::thread>(
          [context = context_] { context->run(); });
      thread->detach();
      threads_.emplace_back(std::move(thread));
    }
    logger_->debug("Thread pool started");
  }

  void RpcThreadPool::stop() {
    context_->stop();
    logger_->debug("Thread pool stopped");
  }

}  // namespace sgns::api

---

Updated on 2026-03-04 at 13:10:44 -0800