Method run

src/ThreadPool.cpp:76–118

}

void ThreadPool::run()
{
  std::vector<Thread*>::iterator begin = thread_list.begin();
  std::vector<Thread*>::iterator end = thread_list.end();
  std::map<Thread*, bool> thread_map;

  bool mono_thread = thread_list.size() == 1;
  unsigned int thread_num = 1;
  time_t t0 = time(NULL);
  if (thrPoolManager->getFlags() & ThreadPoolManager::VERBOSE) {
	thrPoolManager->lock();
	std::cout << "Thread pool [" << getName() << "] started [" << thread_list.size() << " threads]\n";
	thrPoolManager->unlock();
  }

  do {
	Thread* thread = *begin++;
	pthread_t tid = 0;
	if (mono_thread) {
	  ThreadPool::wrapper(thread);
	} else {
	  pthread_create(&tid, NULL, ThreadPool::wrapper, thread);
	}
	if (thrPoolManager->getFlags() & ThreadPoolManager::VERBOSE) {
	  thrPoolManager->lock();
	  std::cout << "Thread launched [" << getName() << "#" << thread_num << ":" << tid << "] at [" << (time(NULL) - t0) << " secs]" << std::endl;
	  thrPoolManager->unlock();
	}
	thread_map[thread] = true;
	while (!thrPoolManager->reserveOneThread()) {
	  checkOneThreadFinished(thread_map);
	}
	thread_num++;
  } while (begin != end);

  wait(thread_map);

  if (thrPoolManager->getFlags() & ThreadPoolManager::VERBOSE) {
	thrPoolManager->lock();
	std::cout << "Thread pool [" << getName() << "] terminated" << std::endl;
	thrPoolManager->unlock();
  }
}

void ThreadPool::checkOneThreadFinished(std::map<Thread*, bool>& thread_map)
{