GaudiParallelizer.h

Go to the documentation of this file.

#ifndef LIB_GAUDIPARALLELIZER_H
#define LIB_GAUDIPARALLELIZER_H 1
// Include files
// from Gaudi
#include "GaudiAlg/GaudiAlgorithm.h"

#include <tbb/task_group.h>
#include <tbb/task_scheduler_init.h>
#include <boost/bind.hpp>

// Forward declarations
class ISequencerTimerTool;

class GaudiParallelizer: public GaudiAlgorithm {
public:
  GaudiParallelizer(const std::string& name, ISvcLocator* pSvcLocator);
  virtual ~GaudiParallelizer(); 

  virtual StatusCode initialize();    
  virtual StatusCode execute   ();    
  virtual StatusCode finalize  ();    

  void membershipHandler( Property& theProp );

protected:
  class AlgorithmEntry {
    public:
      AlgorithmEntry( Algorithm* alg ) {
        m_algorithm = alg;
        m_reverse = false;
        m_timer = 0;
      }

      virtual ~AlgorithmEntry( ) {}; 
      void setReverse( bool flag )         { m_reverse   = flag; }

      Algorithm* algorithm()        const  { return m_algorithm; }
      bool       reverse()          const  { return m_reverse;   }
      void       setTimer( int nb )        { m_timer = nb;       }
      int        timer()            const  { return m_timer;     }

      void       run( GaudiParallelizer& prlzr ) {
        if ( prlzr.m_measureTime ) prlzr.m_timerTool->start( timer() );
        m_returncode = m_algorithm->sysExecute();
        if ( prlzr.m_measureTime ) prlzr.m_timerTool->stop( timer() );
        algorithm()->setExecuted( true );
      }

      StatusCode  m_returncode;  

    private:
      Algorithm*  m_algorithm;   
      bool        m_reverse;     
      int         m_timer;       
    };

  StatusCode decodeNames(  );

private:
  StringArrayProperty   m_names;         
  std::vector<AlgorithmEntry> m_entries; 
  bool m_modeOR;                         

  bool m_measureTime;                    
  bool m_returnOK;                       
  ISequencerTimerTool* m_timerTool;      
  int  m_timer;                          

  tbb::task_group m_task_group;          
  unsigned short m_nthreads;             
};

#endif // LIB_GAUDIPARALLELIZER_H