mitkStorageThreadDispatcherBase.h

Go to the documentation of this file.

/*============================================================================
 
The Medical Imaging Interaction Toolkit (MITK)
 
Copyright (c) German Cancer Research Center (DKFZ)
All rights reserved.
 
Use of this source code is governed by a 3-clause BSD license that can be
found in the LICENSE file.
 
============================================================================*/
 
#ifndef mitkStorageThreadDispatcherBase_h
#define mitkStorageThreadDispatcherBase_h
 
#include <MitkCoreExports.h>
#include <mitkCommon.h>
#include <itkObject.h>
#include <functional>
 
namespace mitk
{
  class MITKCORE_EXPORT StorageThreadDispatcherBase : public itk::Object
  {
  public:
    mitkClassMacroItkParent(StorageThreadDispatcherBase, itk::Object);
 
    void Execute(std::function<void()> task)
    {
      if (this->IsDispatchThread())
      {
        task();
      }
      else
      {
        this->ExecuteDispatched(task);
      }
    }
 
    virtual bool IsDispatchThread() const = 0;
 
    virtual void Post(std::function<void()> task) = 0;
 
    template <typename R>
    R ExecuteWithResult(std::function<R()> task)
    {
      R result{};
      this->Execute([&result, &task]() { result = task(); });
      return result;
    }
 
  protected:
 
    virtual void ExecuteDispatched(std::function<void()> task) = 0;
 
    StorageThreadDispatcherBase() = default;
    ~StorageThreadDispatcherBase() override = default;
  };
}
 
#endif