ThreadPool.h

Go to the documentation of this file.

// Copyright (c) Fraunhofer MEVIS, Germany. All rights reserved.
// **InsertLicense** code
 
#pragma once
 
#include <asio/System.h>
#include <asio/Context.h>
 
#include <FMEThirdPartyWarningsDisable.h>
#include <vector>
#include <thread>
#include <memory>
#include <boost/asio/executor_work_guard.hpp>
#include <FMEThirdPartyWarningsRestore.h>
 
 
namespace asio {
 
  class ASYNCHRONOUSIO_EXPORT ThreadPool
  {
  public:
 
    ThreadPool(std::shared_ptr<Context> context, const unsigned short num_threads);
 
    ~ThreadPool();
 
    ThreadPool(const ThreadPool&) = delete;
 
    ThreadPool& operator=(const ThreadPool&) = delete;
 
  private:
 
    std::shared_ptr<Context> context;
    typedef boost::asio::executor_work_guard<boost::asio::io_context::executor_type> BoostWorkType;
    std::shared_ptr< BoostWorkType > work;
 
    std::vector<std::thread> pool;
  };
 
}