Geant4 Cross Reference

Cross-Referencing   Geant4
Geant4/externals/ptl/include/PTL/TaskRunManager.hh

Version: [ ReleaseNotes ] [ 1.0 ] [ 1.1 ] [ 2.0 ] [ 3.0 ] [ 3.1 ] [ 3.2 ] [ 4.0 ] [ 4.0.p1 ] [ 4.0.p2 ] [ 4.1 ] [ 4.1.p1 ] [ 5.0 ] [ 5.0.p1 ] [ 5.1 ] [ 5.1.p1 ] [ 5.2 ] [ 5.2.p1 ] [ 5.2.p2 ] [ 6.0 ] [ 6.0.p1 ] [ 6.1 ] [ 6.2 ] [ 6.2.p1 ] [ 6.2.p2 ] [ 7.0 ] [ 7.0.p1 ] [ 7.1 ] [ 7.1.p1 ] [ 8.0 ] [ 8.0.p1 ] [ 8.1 ] [ 8.1.p1 ] [ 8.1.p2 ] [ 8.2 ] [ 8.2.p1 ] [ 8.3 ] [ 8.3.p1 ] [ 8.3.p2 ] [ 9.0 ] [ 9.0.p1 ] [ 9.0.p2 ] [ 9.1 ] [ 9.1.p1 ] [ 9.1.p2 ] [ 9.1.p3 ] [ 9.2 ] [ 9.2.p1 ] [ 9.2.p2 ] [ 9.2.p3 ] [ 9.2.p4 ] [ 9.3 ] [ 9.3.p1 ] [ 9.3.p2 ] [ 9.4 ] [ 9.4.p1 ] [ 9.4.p2 ] [ 9.4.p3 ] [ 9.4.p4 ] [ 9.5 ] [ 9.5.p1 ] [ 9.5.p2 ] [ 9.6 ] [ 9.6.p1 ] [ 9.6.p2 ] [ 9.6.p3 ] [ 9.6.p4 ] [ 10.0 ] [ 10.0.p1 ] [ 10.0.p2 ] [ 10.0.p3 ] [ 10.0.p4 ] [ 10.1 ] [ 10.1.p1 ] [ 10.1.p2 ] [ 10.1.p3 ] [ 10.2 ] [ 10.2.p1 ] [ 10.2.p2 ] [ 10.2.p3 ] [ 10.3 ] [ 10.3.p1 ] [ 10.3.p2 ] [ 10.3.p3 ] [ 10.4 ] [ 10.4.p1 ] [ 10.4.p2 ] [ 10.4.p3 ] [ 10.5 ] [ 10.5.p1 ] [ 10.6 ] [ 10.6.p1 ] [ 10.6.p2 ] [ 10.6.p3 ] [ 10.7 ] [ 10.7.p1 ] [ 10.7.p2 ] [ 10.7.p3 ] [ 10.7.p4 ] [ 11.0 ] [ 11.0.p1 ] [ 11.0.p2 ] [ 11.0.p3, ] [ 11.0.p4 ] [ 11.1 ] [ 11.1.1 ] [ 11.1.2 ] [ 11.1.3 ] [ 11.2 ] [ 11.2.1 ] [ 11.2.2 ] [ 11.3.0 ]

  1 //
  2 // MIT License
  3 // Copyright (c) 2020 Jonathan R. Madsen
  4 // Permission is hereby granted, free of charge, to any person obtaining a copy
  5 // of this software and associated documentation files (the "Software"), to deal
  6 // in the Software without restriction, including without limitation the rights
  7 // to use, copy, modify, merge, publish, distribute, sublicense, and
  8 // copies of the Software, and to permit persons to whom the Software is
  9 // furnished to do so, subject to the following conditions:
 10 // The above copyright notice and this permission notice shall be included in
 11 // all copies or substantial portions of the Software. THE SOFTWARE IS PROVIDED
 12 // "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR IMPLIED, INCLUDING BUT NOT
 13 // LIMITED TO THE WARRANTIES OF MERCHANTABILITY, FITNESS FOR A PARTICULAR
 14 // PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT
 15 // HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
 16 // ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN CONNECTION
 17 // WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE SOFTWARE.
 18 //
 19 // class description:
 20 //   This is a class for run control in Tasking for multi-threaded runs
 21 //   It extends RunManager re-implementing multi-threaded behavior in
 22 //   key methods. See documentation for RunManager
 23 //   Users initializes an instance of this class instead of RunManager
 24 //   to start a multi-threaded simulation.
 25 
 26 #pragma once
 27 
 28 #include "PTL/ThreadPool.hh"
 29 
 30 #include <cstddef>
 31 #include <cstdint>
 32 #include <thread>
 33 
 34 namespace PTL
 35 {
 36 class TaskManager;
 37 class VUserTaskQueue;
 38 
 39 //======================================================================================//
 40 
 41 class TaskRunManager
 42 {
 43 public:
 44     using pointer = TaskRunManager*;
 45 
 46 public:
 47     // Parameters:
 48     //      m_task_queue: provide a custom task queue
 49     //      useTBB: only relevant if PTL_USE_TBB defined
 50     //      grainsize:  0 = auto
 51     explicit TaskRunManager(bool useTBB = false);
 52     virtual ~TaskRunManager();
 53 
 54 public:
 55     virtual int GetNumberOfThreads() const
 56     {
 57         return (m_thread_pool) ? (int)m_thread_pool->size() : 0;
 58     }
 59     virtual size_t GetNumberActiveThreads() const
 60     {
 61         return (m_thread_pool) ? m_thread_pool->size() : 0;
 62     }
 63 
 64 public:
 65     // Inherited methods to re-implement for MT case
 66     virtual void Initialize(uint64_t n = std::thread::hardware_concurrency());
 67     virtual void Terminate();
 68     ThreadPool*  GetThreadPool() const { return m_thread_pool; }
 69     TaskManager* GetTaskManager() const { return m_task_manager; }
 70     bool         IsInitialized() const { return m_is_initialized; }
 71 
 72 public:  // with description
 73     // Singleton implementing master thread behavior
 74     static TaskRunManager* GetInstance(bool useTBB = false);
 75     static TaskRunManager* GetMasterRunManager(bool useTBB = false);
 76 
 77 private:
 78     static pointer& GetPrivateMasterRunManager();
 79     static pointer& GetPrivateMasterRunManager(bool init, bool useTBB = false);
 80 
 81 protected:
 82     // Barriers: synch points between master and workers
 83     bool            m_is_initialized = false;
 84     uint64_t        m_workers        = 0;
 85     bool            m_use_tbb        = false;
 86     VUserTaskQueue* m_task_queue     = nullptr;
 87     ThreadPool*     m_thread_pool    = nullptr;
 88     TaskManager*    m_task_manager   = nullptr;
 89 };
 90 
 91 }  // namespace PTL
 92