ConcurrencyFlags.h

Go to the documentation of this file.

#ifndef GAUDIKERNEL_CONCURRENCYFLAGS_H
#define GAUDIKERNEL_CONCURRENCYFLAGS_H 1

#include <cstddef>

#include "GaudiKernel/Kernel.h"

class ThreadPoolSvc;
class HiveWhiteBoard;
class SGHiveMgrSvc;
class AthMpEvtLoopMgr;
class EvtStoreSvc;

namespace SG {
  class HiveMgrSvc;
}

namespace Gaudi {

  namespace Concurrency {

    class ConcurrencyFlags {

      friend class ::ThreadPoolSvc;
      friend class ::HiveWhiteBoard;
      friend class ::EvtStoreSvc;
      friend class SG::HiveMgrSvc;    // ATLAS
      friend class ::AthMpEvtLoopMgr; // ATLAS

    public:
      static GAUDI_API std::size_t numThreads() { return n_threads; }

      static GAUDI_API std::size_t numConcurrentEvents() { return n_concEvts; }

      static GAUDI_API std::size_t numProcs() { return n_procs; }

      static GAUDI_API bool concurrent() { return ( n_threads || n_concEvts || n_procs ); }

    private:
      static GAUDI_API void setNumThreads( const std::size_t& nT ) { n_threads = nT; }
      static GAUDI_API void setNumConcEvents( const std::size_t& nE ) { n_concEvts = nE; }
      static GAUDI_API void setNumProcs( const std::size_t& nP ) { n_procs = nP; }

    private:
      static std::size_t n_threads;  // worker threads for MT
      static std::size_t n_concEvts; // concurrent events for MT
      static std::size_t n_procs;    // child processes for MP
    };
  } // namespace Concurrency
} // namespace Gaudi

#endif