Measurement.h

Go to the documentation of this file.

/*
 * Measurement.h
 *
 *  Created on: May 17, 2018
 *      Author: mschefer
 */
 
#ifndef _SEFRAMEWORK_PIPELINE_MEASUREMENT_H_
#define _SEFRAMEWORK_PIPELINE_MEASUREMENT_H_
 
 
#include "SEFramework/Pipeline/PipelineStage.h"
#include "SEFramework/Source/SourceGroupInterface.h"
#include "SEFramework/Task/TaskProvider.h"
 
namespace SourceXtractor {
 
class Measurement : public PipelineReceiver<SourceGroupInterface>, public PipelineEmitter<SourceGroupInterface> {
public:
 
  ~Measurement() override = default;
 
  virtual void startThreads() = 0;
  virtual void stopThreads() = 0;
  virtual void synchronizeThreads() = 0;
};
 
}
 
 
#endif /* _SEFRAMEWORK_PIPELINE_MEASUREMENT_H_ */