diff --git a/src/main/java/fi/utu/tech/threadrunner2/assignment/Task1UsingThreadDistributor.java b/src/main/java/fi/utu/tech/threadrunner2/assignment/Task1UsingThreadDistributor.java
index cca909344f76ab7841cd5feb650f33c8c1821571..5de2b24c22d798ae07443b296a17dfdf2b97f1a1 100644
--- a/src/main/java/fi/utu/tech/threadrunner2/assignment/Task1UsingThreadDistributor.java
+++ b/src/main/java/fi/utu/tech/threadrunner2/assignment/Task1UsingThreadDistributor.java
@@ -13,14 +13,16 @@ public class Task1UsingThreadDistributor extends Thread implements Distributor {
 	public Task1UsingThreadDistributor(Mediator mediator, ControlSet control) {
 		this.mediator = mediator;
 		this.control = control;
-		mediator.registerThread(this.hashCode(), "Thread");
+		for(int i=0; i<control.getThreadCount(); ++i){ //Kootaan tarvittava määrä threadeja
+			mediator.registerThread(this.hashCode(), "Thread");
+		}
 	}
 
 	public void execute() {
 			this.start();
 			mediator.setRunStatus("Created", this.hashCode());
 	}
-	public void run() {
+	public void run() {//pystyttäisiinkö vaan while notifyAll metodeilla
 		//mediator.registerThread(this.hashCode(), "Jotain1");
 		mediator.setRunStatus("Running", this.hashCode());
 		int maara = control.getBlockSize();