vlThread.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 1992-2010 VT MAK
** All rights reserved.
******************************************************************************/
#pragma once

#include "vlMachineTypes.h"
#include "vlThreadSysWrapper.h"
#include "vlMutex.h"
#include "vlSmartPointers.h"

#ifdef DtUSE_UTILITIES_NAMESPACE
namespace DtUSE_UTILITIES_NAMESPACE
{
#endif

   

class DtRunnable;

typedef void (*DtRunnableFunction)(void*,volatile bool*);

class DT_DLL_VLUTIL DtThreadStart
{
public:
   DtThreadStart(DtRunnable* runnable);
   DtThreadStart(DtRunnableFunction function,void* data);   
   
   void execute(volatile bool* stopFlag);

   void stop();

protected:
   DtRunnable* myRunnableObject;  
   DtRunnableFunction myRunnableFunction;
   void* myInitializationData;
};

typedef DtBoost::shared_ptr<DtThreadStart> DtThreadStartSP;

class DT_DLL_VLUTIL DtThread
{
public:

   static DtThreadId GetCurrentThreadHandle();
    
public:
   DtThread(DtThreadStartSP threadStart);
   
   virtual ~DtThread();    

   virtual DtThreadStatus start();
   
   DtThreadStatus startInCurrentThread();
   
   void stop(bool blocking);

   bool hasStarted() const;
   
   bool isRunning() const;

   DtThreadStatus join() const;  
   
   DtThreadHandle threadId() const { return myThreadID; }

   void run();

protected:

   bool stopped();

   DtThreadHandle myThreadID;

private:  
   DtThread(const DtThread& orig);
   DtThread& operator=(const DtThread& orig);
   
private:
   volatile bool myTimeToStop;

   bool myRunning;
   
   DtThreadStartSP myThreadStart;

   mutable DtMutex myMutex;
};

#ifdef DtUSE_UTILITIES_NAMESPACE
} 
#endif