From 0a7b7c9f52b97ce62c4311c81de7c41e9b220e9d Mon Sep 17 00:00:00 2001
From: nuklin <nuklin@utu.fi>
Date: Fri, 19 Nov 2021 12:43:38 +0200
Subject: [PATCH] update
---
.../assignment/Task1UsingThreadDistributor.java | 6 ++++--
1 file changed, 4 insertions(+), 2 deletions(-)
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 cca9093..5de2b24 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();
--
GitLab