vlThreadedObject.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2005 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/
/******************************************************************************
** $RCSfile: vlThreadedObject.h,v $ $Revision: 1.3 $ $State: Exp $
******************************************************************************/



#ifndef vlThreadedObject_H__
#define vlThreadedObject_H__

#include "rtiMsConfig.h"
#include <vlutil/vlSmartPointers.h>
#include <vlutil/vlThread.h>
#include <vlutil/vlRunnable.h>
#include <vlutil/vlMutex.h>
#include <vlutil/vlExceptions.h>
#include <vlutil/vlMachineTypes.h>

typedef std::shared_ptr<MAKRti::DtRunnable> DtRunnableSP;

namespace vrlmod
{





#define typedefException(Name,Value) \
   const int Name##Number = Value;\
   typedef MAKRti::DtTemplatedException<Name##Number> Name;
const int ThreadExceptionBase = 1000;
typedefException(DtThreadAlreadyRunning,ThreadExceptionBase + 1)
typedefException(DtThreadNotStarted,    ThreadExceptionBase + 2)
typedefException(DtThreadCreationError, ThreadExceptionBase + 3)
typedefException(DtThreadWouldDeadlock, ThreadExceptionBase + 4)


class DT_DLL_RTIUTIL DtThreadedObject
{
public:
   DtThreadedObject(); 

   DtThreadedObject(DtRunnableSP ptr); 

   virtual ~DtThreadedObject();

   void start();

   void join(); 

   void stop(bool block);

   bool running() const;

   void setRunnableObject(DtRunnableSP newObject);

   DtRunnableSP runnableObject() const;   

protected:

   DtThreadedObject(const DtThreadedObject&);
   DtThreadedObject& operator=(const DtThreadedObject&);

   void setRunning(bool value);

   bool                          myRunningFlag;
   DtRunnableSP                  myObject;
   MAKRti::DtThread*                     myThread;
   mutable MAKRti::DtMutex               myMutex;   
};




} 


   
#endif