albaAgentThreaded.h

Go to the documentation of this file.

/*=========================================================================
 
 Program: ALBA (Agile Library for Biomedical Applications)
 Module: albaAgentThreaded
 Authors: Marco Petrone
 
 Copyright (c) BIC
 All rights reserved. See Copyright.txt or
 
 
 This software is distributed WITHOUT ANY WARRANTY; without even
 the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR
 PURPOSE.  See the above copyright notice for more information.
 
=========================================================================*/
 
#ifndef __albaAgentThreaded_h
#define __albaAgentThreaded_h
 
#include "albaAgentEventQueue.h"
#include "albaMultiThreader.h"
 
//------------------------------------------------------------------------------
// Forward declarations:
//------------------------------------------------------------------------------
class albaMutexLock;
 
class ALBA_EXPORT albaAgentThreaded : public albaAgentEventQueue
{
public:
  //------------------------------------------------------------------------------
  // Events
  //------------------------------------------------------------------------------
  ALBA_ID_DEC(AGENT_ASYNC_DISPATCH);
 
  albaTypeMacro(albaAgentThreaded,albaAgentEventQueue);
 
  int GetThreaded() {return m_Threaded;}
 
  void SetThreaded(int flag){m_Threaded=flag;} 
 
  int Update() {return IsInitialized()?InternalUpdate():-1;}
 
  virtual void OnEvent(albaEventBase *event);
  
  void AsyncSendEvent(albaObserver *target,albaEventBase *event, albaID channel=MCH_UP);
  void AsyncSendEvent(albaObserver *target, void *sender, albaID id, albaID channel=MCH_UP,void *data=NULL);
 
  void AsyncInvokeEvent(albaEventBase *event, albaID channel=MCH_UP);
  void AsyncInvokeEvent(albaID id, albaID channel=MCH_UP,void *data=NULL);
 
protected:
  albaAgentThreaded();
  virtual ~albaAgentThreaded();
 
  virtual void RequestForDispatching();
  void StopThread();
  virtual int InternalInitialize();
  virtual void InternalShutdown();
 
  virtual int InternalUpdate();
 
  static void UpdateLoop(mmuThreadInfoStruct *data);
    
  int GetActiveFlag();
 
  void SignalNewMessage();
  void WaitForNewMessage();
 
  albaMultiThreader*     m_Threader;
  mmuThreadInfoStruct*  m_ThreadData;
 
  int                   m_ThreadId;
  int                   m_Threaded;
  int                   m_ActiveFlag;
 
#ifdef _WIN32
 
  HANDLE        m_MessageSignal;
#else
  
  albaMutexLock* m_Gate;
#endif
 
private:
  albaAgentThreaded(const albaAgentThreaded&);  // Not implemented.
  void operator=(const albaAgentThreaded&);  // Not implemented.
};
 
#endif