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_ */