Geant4 LXR

Cross-Referencing   Geant4
Geant4/externals/ptl/src/VUserTaskQueue.cc

   //
   // MIT License
   // Copyright (c) 2020 Jonathan R. Madsen
   // Permission is hereby granted, free of charge, to any person obtaining a copy
   // of this software and associated documentation files (the "Software"), to deal
   // in the Software without restriction, including without limitation the rights
   // to use, copy, modify, merge, publish, distribute, sublicense, and
   // copies of the Software, and to permit persons to whom the Software is
   // furnished to do so, subject to the following conditions:
  // The above copyright notice and this permission notice shall be included in
  // all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED
  // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
  // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
  // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
  // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
  // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
  // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
  //
  // ---------------------------------------------------------------
  //  Tasking class implementation
  //  Class Description:
  //      Abstract base class for creating a task queue used by
  //      ThreadPool
  //  ---------------------------------------------------------------
  //  Author: Jonathan Madsen
  //  ---------------------------------------------------------------
  
  #include "PTL/VUserTaskQueue.hh"
  #include "PTL/TaskRunManager.hh"
  #include <cstdint>  // for intmax_t
  #include <thread>   // for thread
  
  namespace PTL
  {
  //======================================================================================//
  
  VUserTaskQueue::VUserTaskQueue(intmax_t nworkers)
  : m_workers(nworkers)
  {
      if(m_workers < 0)
      {
          TaskRunManager* rm = TaskRunManager::GetMasterRunManager();
          m_workers          = (rm) ? rm->GetNumberOfThreads() + 1  // number of threads + 1
                           : (2 * std::thread::hardware_concurrency()) + 1;
          // hyperthreads + 1
      }
  }
  
  //======================================================================================//
  
  }  // namespace PTL