pool.h

Go to the documentation of this file.

#ifndef GRPPI_NATIVE_POOL_H
#define GRPPI_NATIVE_POOL_H

#include <boost/asio/io_service.hpp>
#include <boost/bind.hpp>
#include <boost/thread/thread.hpp>

namespace grppi {

class thread_pool
{
  private: 
    boost::thread_group threadpool;
    boost::asio::io_service ioService;
    std::vector<boost::asio::io_service::work> works;//(ioService);
    int busy_threads= 0;

  public:
    thread_pool (){
    };
    
    template <typename T> 
     void create_task(T task ) { ioService.post(task); }

    void initialise (int num_threads) {
       works.push_back( std::move(boost::asio::io_service::work(ioService)));
       for(unsigned int nthr= 0; nthr < num_threads; nthr++){
         threadpool.create_thread(
            boost::bind(&boost::asio::io_service::run, &ioService)
         );
       }
    };
  
    ~thread_pool(){
        ioService.stop();
        threadpool.join_all();
     };

};

}

#endif