From 070ce923574dcc57435cb3fb2dfe86b6a38cd249 Mon Sep 17 00:00:00 2001
From: MDBijman <matthijs@bijman.org>
Date: Tue, 24 Jan 2017 12:15:26 +0100
Subject: Initial code commit with organized dependencies

---
 .../schedulers/FirstInFirstOutScheduler.h          | 37 ++++++++++++++++++++++
 1 file changed, 37 insertions(+)
 create mode 100644 Simulator/include/simulation/schedulers/FirstInFirstOutScheduler.h

(limited to 'Simulator/include/simulation/schedulers/FirstInFirstOutScheduler.h')

diff --git a/Simulator/include/simulation/schedulers/FirstInFirstOutScheduler.h b/Simulator/include/simulation/schedulers/FirstInFirstOutScheduler.h
new file mode 100644
index 00000000..0cac0dfa
--- /dev/null
+++ b/Simulator/include/simulation/schedulers/FirstInFirstOutScheduler.h
@@ -0,0 +1,37 @@
+#pragma once
+#include "Scheduler.h"
+#include <algorithm>
+
+namespace Simulation
+{
+	class FirstInFirstOutScheduler : public Scheduler
+	{
+	protected:
+		~FirstInFirstOutScheduler()
+		{
+		}
+
+	public:
+		/*
+			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();
+
+			std::for_each(
+				machines.begin(), 
+				machines.end(), 
+				[index, &workloads](std::reference_wrapper<Modeling::Machine>& machine) {
+					machine.get().giveTask(workloads.at(index));
+				}
+			);
+		}
+	};
+}
-- 
cgit v1.2.3