Function ThreadedFunction

Modules/Core/test/mitkITKThreadingTest.cpp:38–87

this will be executed in a thread

// this will be executed in a thread
ITK_THREAD_RETURN_TYPE ThreadedFunction(void *param)
{
  std::cout << "Getting thread info data... ";
  itk::MultiThreader::ThreadInfoStruct *threadInfo = static_cast<itk::MultiThreader::ThreadInfoStruct *>(param);

  if (!threadInfo)
  {
    std::cout << "[FAILED]" << std::endl;
    exit(EXIT_FAILURE);
  }
  std::cout << "[PASSED]" << std::endl;

  std::cout << "Getting user data from thread... ";
  UserData *userData = static_cast<UserData *>(threadInfo->UserData);

  if (!userData)
  {
    std::cout << "[FAILED]" << std::endl;
    exit(EXIT_FAILURE);
  }
  std::cout << "[PASSED]" << std::endl;

  // inc variable FOR main thread
  std::cout << "generate 10000 results";
  for (int i = 1; i <= 10000; ++i)
  {
    userData->mutex->Lock();
    *(userData->intPointer) += 1; // generate one "result"
    userData->mutex->Unlock();
    userData->semaphore->Up(); // signal "work done"
  }
  std::cout << "[PASSED]" << std::endl;

  std::cout << "waiting for main thread's signal... " << std::endl;
  ;
  userData->mayIRun->Down(); // wait for signal
  std::cout << "got main thread's signal... " << std::endl;

  // inc variable TOGETHER WITH main thread
  for (int i = 1; i <= 10000; ++i)
  {
    userData->mutex->Lock();
    *(userData->intPointer) += 1;
    userData->mutex->Unlock();
  }

  userData->semaphore->Up(); // signal "job done"

  return ITK_THREAD_RETURN_VALUE;
}

int mitkITKThreadingTest(int /*argc*/, char * /*argv*/ [])
{