ThreadPool3.hxx

Go to the documentation of this file.

/*--------------------------------------------------------------------------*\
 |                                                                          |
 |  Copyright (C) 2025                                                      |
 |                                                                          |
 |         , __                 , __                                        |
 |        /|/  \               /|/  \                                       |
 |         | __/ _   ,_         | __/ _   ,_                                |
 |         |   \|/  /  |  |   | |   \|/  /  |  |   |                        |
 |         |(__/|__/   |_/ \_/|/|(__/|__/   |_/ \_/|/                       |
 |                           /|                   /|                        |
 |                           \|                   \|                        |
 |                                                                          |
 |      Enrico Bertolazzi                                                   |
 |      Dipartimento di Ingegneria Industriale                              |
 |      Università degli Studi di Trento                                    |
 |      email: enrico.bertolazzi@unitn.it                                   |
 |                                                                          |
\*--------------------------------------------------------------------------*/
 
//
// file: ThreadPool3.hxx
//
 
#include "3rd/BS_thread_pool.hpp"
 
namespace Utils {

 
  /*\
   |   _____ _                        _ ____             _
   |  |_   _| |__  _ __ ___  __ _  __| |  _ \ ___   ___ | |
   |    | | | '_ \| '__/ _ \/ _` |/ _` | |_) / _ \ / _ \| |
   |    | | | | | | | |  __/ (_| | (_| |  __/ (_) | (_) | |
   |    |_| |_| |_|_|  \___|\__,_|\__,_|_|   \___/ \___/|_|
  \*/
  class ThreadPool3 : public ThreadPoolBase {
 
    BS::light_thread_pool m_pool;
 
  public:

    ThreadPool3(
      unsigned nthread = std::max(
        unsigned(1),
        unsigned(std::thread::hardware_concurrency()-1)
      )
    ) : m_pool( nthread ) {}

    virtual ~ThreadPool3() {}

    void exec( FUN && fun ) override { m_pool.detach_task( std::move(fun) ); }

    void wait() override { m_pool.wait(); }

    unsigned thread_count() const override { return unsigned( m_pool.get_thread_count() ); }

    static char const * Name() { return "ThreadPool3 [BS]"; }
 
    char const * name() const override { return Name(); }
 
  };

 
}
 
//
// eof: ThreadPool3.hxx
//