DtMainThreadJobsManager.h

Go to the documentation of this file.

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


#pragma once

#include <vrvOsg/vrvOsg.h>
#include <vrvOsg/DtOsgThreadingUtils.h>

#include <vrvCore/DtVirtualBaseClassCreator.h>

#include <osgUtil/IncrementalCompileOperation>
#include <osgUtil/SceneView>
#include <osg/OperationThread>

#include <tbb/atomic.h>


namespace makVrv
{
   class DtMainThreadJobsManager;

   typedef DtVirtualBaseClassCreator<DtMainThreadJobsManager> DtMainThreadJobsManagerCreator;

   template <>
   inline const char* creatorTypeName<DtMainThreadJobsManager>(void) { return "DtMainThreadJobsManagerCreator"; }
  



   class DT_DLL_VRVOSG DtMainThreadJobsManager : public osg::Operation
   {
   public:
      DtMainThreadJobsManager(DtDe& de);

      virtual ~DtMainThreadJobsManager();
   public:
      virtual void operator () (osg::Object* obj) override;

      virtual void startUp();

      virtual void release();
      
      virtual void setIco(osgUtil::IncrementalCompileOperation* ico);

      virtual void addPersistantJob(osg::Operation* job);

      virtual void removePersistantJob(osg::Operation* job);

      virtual void addTransientJob(osg::Operation* job);

      virtual void addRequiredTransientJob(osg::Operation* job);

      virtual int numberOfTransientJobs() const;

      virtual void finishFrameTime(double budget, osg::Object* obj);

      virtual double lastFrameTime() const;

   protected:
      virtual void runTransientJobs(osgUtil::SceneView* sceneView);

   protected:
      std::vector<osg::ref_ptr<osg::Operation> > myPersistantJobs;
      
      std::vector<osg::ref_ptr<osg::Operation> > myRequiredTransientJobs;
      // transient jobs
      tbb::atomic<int> myNumberOfTransientJobs;
      std::vector<osg::ref_ptr<osg::Operation> > myTransientJobs;
      std::vector<osg::ref_ptr<osg::Operation> > myNextFrameJobs;

      osgUtil::IncrementalCompileOperation* myIco;
      OpenThreads::Mutex myMutex;
      OpenThreads::Condition myRunThreadWaitCond;
      tbb::atomic<bool> myKeepGoing;
      osg::ref_ptr<osg::Operation> myCurrentJob;
      
      double myLastFrameTime;

      DtDe& myDe;

   private:
      DtMainThreadJobsManager(const DtMainThreadJobsManager& rhs) = delete;
      DtMainThreadJobsManager& operator=(const DtMainThreadJobsManager& rhs) = delete;
   };
};