ThreadPool::Config

[jrmadsen]

Overview

• New ThreadPool::Config class
  • avoids having several overloads to ThreadPool constructor
• Improved static configuration of ThreadPool
• Support for thread scheduling priorities
  • via pthread_setschedprio
  • Default value is 0
  • Lower values, e.g. -10, are higher priority
  • Higher values, e.g. 10, are lower priority
• Threading::SetPinAffinity(<cpu-id>) overload which applies to current thread
• Threading::SetThreadPriority(<cpu-id>) overload
• Threading::SetThreadPriority(<cpu-id>, Threading::NativeThread&) overload
• Threading::GetNumberOfPhysicalCpus()
• Fixed issue with default thread-pool deadlock

Example ThreadPool::Config

intmax_t ncores = PTL::Threading::GetNumberOfCores();
auto     _init  = []() { printf("Started thread %i\n", PTL::Threading::GetThreadId()); };
auto     _fini  = []() { printf("Stopped thread %i\n", PTL::Threading::GetThreadId()); };
auto     _pin   = [ncores](intmax_t i) { return i % ncores; };

PTL::ThreadPool::Config _config{};
_config.init         = true;   // initialize during construction
_config.use_tbb      = false;  // disable tbb
_config.use_affinity = true;   // pin the threads to the cpus
_config.verbose      = 3;      // verbosity
_config.priority     = 0;      // set the thread scheduling priority
_config.pool_size    = 4;      // number of threads
_config.set_affinity = _pin;   // functor for deciding which
                               // cpu to pin threads to
_config.initializer = _init;   // execute when thread starts
_config.finalizer   = _fini;   // execute when thread finalizes

PTL::ThreadPool _tp{ _config };