#include "TickOrganizer.h"
#include "Constants.h"


TickOrganizer::TickOrganizer()
	: ReferenceCounter()
{
	queue = new TickQueue();
	workerCount = NUM_TICK_WORKERS;
	workers = new TickWorker * [workerCount];
	for (int i = 0; i < workerCount; i++)
		workers[i] = new TickWorker(queue);
}

TickOrganizer::~TickOrganizer()
{
	queue->requestExit();
	for (int i = 0; i < workerCount; i++)
	{
		workers[i]->warteAufThread(10000);
		workers[i]->ende();
		workers[i]->release();
	}
	queue->release();
	delete[] workers;
}

void TickOrganizer::nextTick()
{
	queue->startNextTick(&tickSources);
	bool notWaiting = 0;
	do
	{
		queue->waitForEmpty();
		for (int i = 0; i < workerCount; i++)
			notWaiting |= !workers[i]->isWaiting();
	} while (notWaiting);
	queue->postTick();
}

void TickOrganizer::addTickSource(Block* zBlock)
{
	tickSources.add(zBlock);
}

void TickOrganizer::removeTickSource(Block* zBlock)
{
	int index = 0;
	for (Block* block : tickSources)
	{
		if (block == zBlock)
		{
			tickSources.remove(index);
			return;
		}
		index++;
	}
}