Algorithm.cpp

#include "Algorithm.hpp"

Algorithm::Algorithm(IOProcessor* ins, SIZE_T numIns, IOProcessor* outs, SIZE_T numOuts) 
{ 
	numInputs = numIns; numOutputs = numOuts;
	inputs = ins; outputs = outs; 
}

VOID Algorithm::startIOProcessors()
{
	int i;
	for (i = 0; i < numInputs; i++)
		(inputs + i)->startThread();
	for (i = 0; i < numOutputs; i++)
		(outputs + i)->startThread();
}

VOID Algorithm::waitForIOProcessors()
{
	int i;
	for (i = 0; i < numInputs; i++)
		(inputs + i)->waitForThread();
	for (i = 0; i < numOutputs; i++)
		(outputs + i)->waitForThread();
}

VOID Algorithm::stopIOProcessors()
{
	waitForIOProcessors();
}

VOID Algorithm::pollInputs()
{

}

VOID Algorithm::pollOutputs()
{

}