#pragma once
#include "Scheduler.h"
#include <algorithm>

namespace Simulation
{
	class FirstInFirstOutScheduler : public Scheduler
	{
	protected:
		~FirstInFirstOutScheduler()
		{
		}

	public:
		/**
		* \brief Distribute workloads according to the FIFO principle.
		*/
		void schedule(std::vector<std::reference_wrapper<Modeling::Machine>>& machines, std::vector<Workload*> workloads) override
		{
			if (workloads.size() == 0)
				return;

			// Find the first workload with dependencies finished
			int index = 0;
			while(!workloads.at(index)->dependencyFinished)
				index = (++index) % workloads.size();

			// Reset the number of cores used for each workload
			for (auto workload : workloads) 
			{
				workload->setCoresUsed(0);
			}

			// Distribute tasks across machines and set cores used of workloads
			for (auto machine : machines) 
			{
				machine.get().giveTask(workloads.at(index));
				workloads.at(index)->setCoresUsed(
					workloads.at(index)->getCoresUsed() + machine.get().getNumberOfCores()
				);
			}
		}
	};
}