albaMultiThreader.h

Go to the documentation of this file.

/*=========================================================================
 
 Program: ALBA (Agile Library for Biomedical Applications)
 Module: albaMultiThreader
 Authors: Based on vtkMultiThreader (www.vtk.org), adapted by 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 __albaMultiThreader_h
#define __albaMultiThreader_h
 
#include "albaDefines.h"
#include "albaBase.h"
#include "albaIncludeWIN32.h"
 
#define ALBA_MAX_THREADS 16
 
#ifdef CMAKE_USE_SPROC_INIT
#include <sys/types.h>   Needed for unix implementation of sproc
#include <unistd.h>   Needed for unix implementation of sproc
#endif
 
#if defined(CMAKE_USE_PTHREADS_INIT) || defined(CMAKE_HP_PTHREADS_INIT)
#include <pthread.h>   //Needed for PTHREAD implementation of mutex
#include <sys/types.h>   //Needed for unix implementation of pthreads
#include <unistd.h>   //Needed for unix implementation of pthreads
#endif
#ifdef CMAKE_USE_SPROC_INIT
typedef int mmuThreadProcessIDType;
#endif
 
 
#ifdef CMAKE_USE_PTHREADS_INIT
typedef void *(*mmuInternalThreadFunctionType)(void *);
typedef pthread_t mmuThreadProcessIDType;
#endif
 
#ifdef CMAKE_USE_WIN32_THREADS_INIT
typedef LPTHREAD_START_ROUTINE mmuInternalThreadFunctionType;
typedef HANDLE mmuThreadProcessIDType;
#endif
 
#if !defined(CMAKE_USE_PTHREADS_INIT) && !defined(CMAKE_USE_WIN32_THREADS_INIT)
typedef void (*mmuInternalThreadFunctionType)(void *);
typedef int mmuThreadProcessIDType;
#endif
 
 
class albaMutexLock;
 
class ALBA_EXPORT albaMultiThreader: public albaBase
{
public:
  albaMultiThreader();
  ~albaMultiThreader();
 
  void Print(std::ostream& os, const int tabs);
 
#define mmuThreadInfoStruct albaMultiThreader::mmuThreadInfo
  class mmuThreadInfo
  {
  public:
    int                 m_ThreadID;
    int                 m_NumberOfThreads;
    int*                m_ActiveFlag;
    albaMutexLock*       m_ActiveFlagLock;
    void*               m_UserData;
  };
 
  typedef void (*albaThreadFunctionType)(mmuThreadInfoStruct *);
 
  int SpawnThread( albaThreadFunctionType, void *UserData );
 
  void TerminateThread( int thread_id );
 
protected:
 
  mmuThreadInfo               m_ThreadInfoArray[ALBA_MAX_THREADS];
 
  int                        m_SpawnedThreadActiveFlag[ALBA_MAX_THREADS];
  albaMutexLock*              m_SpawnedThreadActiveFlagLock[ALBA_MAX_THREADS];
  mmuThreadProcessIDType     m_SpawnedThreadProcessID[ALBA_MAX_THREADS];
  mmuThreadInfo              m_SpawnedThreadInfoArray[ALBA_MAX_THREADS];
};
 
#endif