DtMainThreadJobsManager.h

Go to the documentation of this file.

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


#pragma once

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

#include <tbb/atomic.h>

#include <vrvCore/DtConcurrencyViewerMacros.h>

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

namespace makVrv
{

  



   class DT_DLL_VRVOSG DtMainThreadJobsManager : public osg::Operation
   {
   public:
      DtMainThreadJobsManager();

      virtual ~DtMainThreadJobsManager() { ; }

      virtual void operator () (osg::Object* obj);

      virtual void startUp();

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

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

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

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

      int getNumberOfTransientJobs() { return myNumberOfTransientJobs; }

   protected:

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

      std::vector<osg::ref_ptr<osg::Operation> > myRepeatedJobs;
      
      // 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<int> myKeepGoing;
      osg::ref_ptr<osg::Operation> myCurrentJob;
    
   private:

      DtMainThreadJobsManager(const DtMainThreadJobsManager & rhs) { ; }
      DtMainThreadJobsManager &operator=(const DtMainThreadJobsManager &rhs) {return *this ; }

   };



   class DT_DLL_VRVOSG DtMainThreadJobsManagerCreator : public DtVirtualBaseClass
   {
   public:
      DtMainThreadJobsManagerCreator(DtDe &de);

      virtual ~DtMainThreadJobsManagerCreator();
   private:
      DtMainThreadJobsManagerCreator(const DtMainThreadJobsManagerCreator &other);
      DtMainThreadJobsManagerCreator &operator=(const DtMainThreadJobsManagerCreator &other);
   public:
      virtual DtMainThreadJobsManager* create() const;

      static DtMainThreadJobsManagerCreator& instance(DtDe& de);

      static const std::string& theClassName();

   protected:
      DtDe& myDe;
   };
};