SequentialSchedulerSvc.h

Go to the documentation of this file.

#ifndef GAUDIHIVE_SEQUENTIALSCHEDULERSVC_H
#define GAUDIHIVE_SEQUENTIALSCHEDULERSVC_H

// Framework include files
#include "GaudiKernel/IScheduler.h"
#include "GaudiKernel/IRunable.h" 
#include "GaudiKernel/Service.h" 
#include "GaudiKernel/IAlgResourcePool.h"

// C++ include files
#include <vector>
#include <string>
#include <unordered_map>
#include <functional>
#include <thread>

// External libs
#include "tbb/concurrent_queue.h"


//---------------------------------------------------------------------------

class SequentialSchedulerSvc: public extends<Service,
                                             IScheduler> {
public:
  SequentialSchedulerSvc( const std::string& name, ISvcLocator* svc );

  ~SequentialSchedulerSvc();

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

  virtual StatusCode pushNewEvent(EventContext* eventContext);

  // Make multiple events available to the scheduler
  virtual StatusCode pushNewEvents(std::vector<EventContext*>& eventContexts);
  
  virtual StatusCode popFinishedEvent(EventContext*& eventContext);  

  virtual StatusCode tryPopFinishedEvent(EventContext*& eventContext);  

  virtual unsigned int freeSlots();


private:
  
  bool m_useTopAlgList;
  
  std::list<IAlgorithm*> m_algList;
  
  EventContext* m_eventContext;
  
  int m_freeSlots;
  
};

#endif // GAUDIHIVE_SEQUENTIALSCHEDULERSVC_H