DtJobSplitter.h

Go to the documentation of this file.

/****************************************************************************** 
** Copyright (c) 2020 MAK Technologies, Inc. 
** All rights reserved. 
******************************************************************************/ 


#pragma once

#include <vrvCore/vrvCore.h>
#include <vrvUtil/DtVirtualBaseClass.h>
#include <tbb/tbb.h>

namespace makVrv
{
   // Forward declarations.
   class DtDe;


   struct DT_DLL_VRVCORE DtJobSplitterJob
   {
      DtJobSplitterJob()
         : myData(0)
         , jobFunction(0)
      {
         // intentional nop
      }

      void* myData;
      void(*jobFunction)(void* data);
   };


   class DT_DLL_VRVCORE DtJobSplitterTask
   {
   public:

      DtJobSplitterTask(std::vector<DtJobSplitterJob*>& jobs);

      void operator()(const tbb::blocked_range<size_t>& r) const;

   protected:

      const std::vector<DtJobSplitterJob*>& myJobs;
   };


   class DT_DLL_VRVCORE DtJobSplitter
   {
   public:

      DtJobSplitter();

      virtual ~DtJobSplitter();

   private:

      DtJobSplitter(const DtJobSplitter &other);

      DtJobSplitter &operator=(const DtJobSplitter &other);

   public:

      virtual void addJob(DtJobSplitterJob* job);

      virtual size_t jobCount();

      virtual void runJobs(int threshold);

   protected:
   
      std::vector<DtJobSplitterJob*> myJobs;
   };


   class DT_DLL_VRVCORE DtJobSplitterCreator : public DtVirtualBaseClass
   {
   public:
      DtJobSplitterCreator();

      virtual ~DtJobSplitterCreator();

   private:
      DtJobSplitterCreator(const DtJobSplitterCreator& other);
      DtJobSplitterCreator &operator=(const DtJobSplitterCreator& other);

   public:
      virtual DtJobSplitter* create() const;

      static DtJobSplitterCreator& instance(DtDe& de);

      static const std::string& theClassName();
   };
}