ThreadPool4.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: ThreadPool4.hxx
//
 
#include "3rd/task_thread_pool.hpp"
 
namespace Utils {

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

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

    virtual ~ThreadPool4() {}

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

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

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

    static char const * Name() { return "ThreadPool4 [task-tp]"; }
 
    char const * name() const override { return Name(); }
 
  };

 
}
 
//
// eof: ThreadPool4.hxx
//