freSetupOptimizationMetricThreadBase.txx

Go to the documentation of this file.

/*=========================================================================

  Program:   F.R.E.E. - flexible registration evaluation engine
  Version:   v.1.0.0
  Date:      $Date: 2006/09/01 12:00:00 $
  Module:    $RCSfile: freSetupOptimizationMetricThreadBase.txx,v $
  Language:  C++



  Copyright (c) 2007 Ralf o Floca (Department of Medical Informatics,
  Institute for Medical Biometry and Informatics, University of Heidelberg,
  Germany). All rights reserved.
  See FREECopyright.txt or http://www.mi.med.uni-hd.de/free/copyright.htm
  for details.

     This software is distributed WITHOUT ANY WARRANTY; without even 
     the implied warranty of MERCHANTABILITY or FITNESS FOR A PARTICULAR 
     PURPOSE.  See the above copyright notices for more information.

=========================================================================*/
#ifndef __freSetupOptimizationMetricThreadBase_txx
#define __freSetupOptimizationMetricThreadBase_txx

#include "freSetupOptimizationMetricThreadBase.h"
#include "freExceptions.h"
#include "freControllerCentral.h"

namespace FREE
{

template <typename TMonitor>
void
SetupOptimizationMetricThreadBase<TMonitor>:: 
SetMonitor(MonitorType* pMonitor)
{
  this->LockExecutionMutex();
    this->m_pMonitor = pMonitor;
  this->UnlockExecutionMutex();
};

template <typename TMonitor>
typename SetupOptimizationMetricThreadBase<TMonitor>::ThreadIDType
SetupOptimizationMetricThreadBase<TMonitor>:: 
GetThreadID() const
{
  return this->m_ThreadID;
};

template <typename TMonitor>
void
SetupOptimizationMetricThreadBase<TMonitor>:: 
SetThreadID(const ThreadIDType& id)
{
  this->LockExecutionMutex();
    this->m_ThreadID = id;
  this->UnlockExecutionMutex();
};

template <typename TMonitor>
void
SetupOptimizationMetricThreadBase<TMonitor>:: 
Execute()
{
  if (!(this->m_pMonitor)) throwExceptionMacro("Error; Cannot execute thread #"<<this->m_ThreadID<<", no monitor is defined.");

  this->LockExecutionMutex();
    //ok no start with the work
    Setup::Pointer smpAdaptedSetup;
    typename MonitorType::AdaptationIDType adaptID;
    
    while (this->m_pMonitor->GetUnevaluatedAdaptedSetup(this->m_ThreadID,adaptID,smpAdaptedSetup))
    { //there is work to do so go on
      //first reset the result
      this->m_Results.Reset();
      //now process the setup
      if (this->ProcessSetup(smpAdaptedSetup))
      { //pass results;
        this->m_pMonitor->EvaluationFinished(this->m_ThreadID,this->m_Results);
      }
      else
      { //notify failure
        this->m_pMonitor->NotifyFailedEvaluation(this->m_ThreadID,this->m_FailureComment);
      }
    }

    //ok all the work of the thread is done.
  this->UnlockExecutionMutex();
};

template <typename TMonitor>
SetupOptimizationMetricThreadBase<TMonitor>:: 
SetupOptimizationMetricThreadBase()
{
  this->m_ThreadID = 0;
  this->m_pMonitor = 0;
  this->m_FailureComment = "";

  this->m_EvaluatedSessionProgressEvent = ProgressEventType::New(this,&Self::OnSessionProgress);
};

template <typename TMonitor>
SetupOptimizationMetricThreadBase<TMonitor>:: 
~SetupOptimizationMetricThreadBase()
{
  ControllerCentral::RemoveOnProgressEvent(m_EvaluatedSessionProgressEvent);
};

template <typename TMonitor>
void
SetupOptimizationMetricThreadBase<TMonitor>:: 
LockExecutionMutex()
{
  this->m_ExecutionMutex.Lock();
};

template <typename TMonitor>
void
SetupOptimizationMetricThreadBase<TMonitor>:: 
UnlockExecutionMutex()
{
  this->m_ExecutionMutex.Unlock();
};

template <typename TMonitor>
void
SetupOptimizationMetricThreadBase<TMonitor>:: 
OnSessionProgress(const IDPath& senderID,
                  const ProgressCtrlEventBase::StatusID status,
                  const std::string& sComment,
                  SessionComponentCache* pSender,
                  long threadID)
{
  this->m_pMonitor->NotifyProgress(this->m_ThreadID, status, sComment);
}

} // end namespace FREE

#endif

---