Method ~Coordinator

src/common/Task.cpp:173–213

/// class Coordinator

Coordinator::~Coordinator()
{
	MutexLockGuard guard(m_mutex, FB_FUNCTION);

	for (WorkerThread** p = m_activeThreads.begin(); p < m_activeThreads.end(); p++)
		(*p)->shutdown(false);

	while (!m_activeThreads.isEmpty())
	{
		WorkerThread* thd = m_activeThreads.pop();
		{
			MutexUnlockGuard unlock(m_mutex, FB_FUNCTION);
			thd->shutdown(true);
		}
		delete thd;
	}

	while (!m_idleThreads.isEmpty())
	{
		WorkerThread* thd = m_idleThreads.pop();
		{
			MutexUnlockGuard unlock(m_mutex, FB_FUNCTION);
			thd->shutdown(true);
		}
		delete thd;
	}

	while (!m_activeWorkers.isEmpty())
	{
		Worker* w = m_activeWorkers.back();

		MutexUnlockGuard unlock(m_mutex, FB_FUNCTION);
		w->waitFor(-1);
	}

	while (!m_idleWorkers.isEmpty())
	{
		Worker* w = m_idleWorkers.pop();
		delete w;
	}
}

void Coordinator::runSync(Task* task)
{