mlSingleThreadedPageRequestProcessor.h

Go to the documentation of this file.

/*************************************************************************************
**
** Copyright 2009, MeVis Medical Solutions AG
**
** The user may use this file in accordance with the license agreement provided with
** the Software or, alternatively, in accordance with the terms contained in a
** written agreement between the user and MeVis Medical Solutions AG.
**
** For further information use the contact form at https://www.mevislab.de/contact
**
**************************************************************************************/
 
#ifndef ML_SINGLE_THREADED_PAGE_REQUEST_PROCESSOR_H
#define ML_SINGLE_THREADED_PAGE_REQUEST_PROCESSOR_H
 
#include "mlInitSystemML.h"
 
#include "mlPageRequestProcessorBase.h"
#include "mlProcessingTimeLine.h"
 
ML_START_NAMESPACE
 
//-------------------------------------------------------------------------------------------
//-------------------------------------------------------------------------------------------
class MLEXPORT SingleThreadedPageRequestProcessor : public PageRequestProcessorBase
{
public:
  SingleThreadedPageRequestProcessor(Host* host = nullptr);
  ~SingleThreadedPageRequestProcessor() override;

  bool supportsMultiThreading() override { return false; }

  void setNumWorkerThreads(std::size_t /*threads*/) override {};

  void addRootTileRequest(TileRequest* tileRequest) override;

  void processAll() override;

  void process(double timeBudget) override;

  bool needsProcessing() override;

  void append(PageRequest* request) override;

  bool processingWasSingleThreaded() const override { return true; }
 
private:
  bool processNextGUIRequest(bool processAll);

  MLErrorCode processRequest(PageRequest* request);

  static void rootTileRequestFinishedCB(void* data, TileRequest* request);

  void rootTileRequestFinished(TileRequest* request);
 
};
 
ML_END_NAMESPACE
 
#endif