Method runSync

src/common/Task.cpp:215–256

}

void Coordinator::runSync(Task* task)
{
	int cntWorkers = setupWorkers(task->getMaxWorkers());
	if (cntWorkers < 1)
		return;

	HalfStaticArray<WorkerAndThd, 8> taskWorkers(*m_pool, cntWorkers);

	Worker* syncWorker = getWorker();
	taskWorkers.push(WorkerAndThd(syncWorker, NULL));

	for (int i = 1; i < cntWorkers; i++)
	{
		WorkerThread* thd = getThread();
		if (thd)
		{
			Worker* w = getWorker();
			taskWorkers.push(WorkerAndThd(w, thd));

			w->setTask(task);
			thd->runWorker(w);
		}
	}

	// run syncronously
	syncWorker->setTask(task);
	syncWorker->work(NULL);

	// wait for all workes
	for (int i = 0; i < cntWorkers; i++)
	{
		WorkerAndThd& wt = taskWorkers[i];
		if (wt.thread)
		{
			if (!wt.worker->isIdle())
				wt.thread->waitForState(WorkerThread::IDLE, -1);

			releaseThread(wt.thread);
		}
		releaseWorker(wt.worker);
	}
}

Worker* Coordinator::getWorker()
{