Function mitkITKThreadingTest

Modules/Core/test/mitkITKThreadingTest.cpp:89–158

}

int mitkITKThreadingTest(int /*argc*/, char * /*argv*/ [])
{
  itk::MultiThreader::Pointer threader = itk::MultiThreader::New();

  int localInt(0); // this will be modified by both threads

  itk::Semaphore::Pointer m_ResultAvailable = itk::Semaphore::New();
  m_ResultAvailable->Initialize(0); // no pieces left (thread has to create one)

  itk::Semaphore::Pointer m_RunThreadRun = itk::Semaphore::New();
  m_RunThreadRun->Initialize(0); // no pieces left (thread has to create one)

  itk::FastMutexLock::Pointer m_Mutex = itk::FastMutexLock::New();

  UserData userData;
  userData.intPointer = &localInt;
  userData.mutex = m_Mutex.GetPointer();
  userData.semaphore = m_ResultAvailable.GetPointer();
  userData.mayIRun = m_RunThreadRun.GetPointer();

  itk::ThreadFunctionType pointer = &ThreadedFunction;
  int thread_id = threader->SpawnThread(pointer, &userData);

  // let thread generate 10 results
  for (int i = 1; i <= 10000; ++i)
    m_ResultAvailable->Down();

  std::cout << "signaling by semaphore thread->main ";
  if (localInt == 10000)
    std::cout << "[PASSED]" << std::endl;
  else
  {
    std::cout << "[FAILED] localInt == " << localInt << std::endl;
    return EXIT_FAILURE;
  }

  // increase int simultaneously with thread (coordinated by mutex)
  localInt = 0;
  m_RunThreadRun->Up(); // let thread work again
  for (int i = 1; i <= 10000; ++i)
  {
    m_Mutex->Lock();
    ++localInt;
    m_Mutex->Unlock();
  }

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

  std::cout << "sharing a mutex protected variable among threads";
  if (localInt == 20000)
    std::cout << "[PASSED]" << std::endl;
  else
  {
    std::cout << "[FAILED] localInt == " << localInt << std::endl;