ThreadedModule.h

#pragma once

namespace AnimatSim
{
        namespace Behavior
        {
                class ANIMAT_PORT ThreadedModule : public NeuralModule
                {
                protected:
                        bool m_bThreadProcessing;

                        bool m_bSetupStarted;

                        bool m_bSetupComplete;

                        bool m_bStopThread;

                        bool m_bPauseThread;
                        
                        bool m_bThreadPaused;

                        float m_fltStepThreadDuration;

                        //Temporary if def to prevent this from showing up in ManagedAnimatTools. Will get rid of this
                        //once I get rid of that library.
        #ifndef STD_DO_NOT_ADD_BOOST
                        boost::thread m_Thread;

                        boost::interprocess::interprocess_mutex m_WaitForSetupMutex;

                        boost::interprocess::interprocess_condition  m_WaitForSetupCond;
        #endif

                        bool m_bWaitingForThreadNotify;

                        virtual void StartThread();
                        virtual void ProcessThread();
                        virtual void ExitThread();
                        virtual void CloseThread();

                        virtual void WaitWhilePaused();
                        virtual void WaitTillPaused();
                        virtual void WaitForThreadNotifyReady();
                        virtual void StartPause();
                        virtual void ExitPause();

                public:
                        ThreadedModule(void);
                        virtual ~ThreadedModule(void);
                                                
                        static ThreadedModule *CastToDerived(AnimatBase *lpBase) {return static_cast<ThreadedModule*>(lpBase);}

                        virtual void PauseThread(bool bVal);
                        virtual bool PauseThread();
                        virtual bool ThreadPaused();

                        virtual float StepThreadDuration();

                        virtual void SetupThread();
                        virtual void StepThread();
                        virtual void ShutdownThread();

                        virtual float *GetDataPointer(const std::string &strDataType);
                        virtual void QueryProperties(CStdPtrArray<TypeProperty> &aryProperties);
                };
        }
}