From bf52cfa229c761fc8b878626928b1e0c0d9cedc6 Mon Sep 17 00:00:00 2001
From: darkress <30271678+DarkressX@users.noreply.github.com>
Date: Sat, 10 Jun 2023 17:15:26 +0200
Subject: [PATCH] Variable threadcount

---
 de/darkress/pixelfood/Main.java | 41 +++++++++------------------------
 1 file changed, 11 insertions(+), 30 deletions(-)

diff --git a/de/darkress/pixelfood/Main.java b/de/darkress/pixelfood/Main.java
index f34c71f..d5706bb 100644
--- a/de/darkress/pixelfood/Main.java
+++ b/de/darkress/pixelfood/Main.java
@@ -94,41 +94,22 @@ class Main
         final String HOSTNAME = args[2];
         final int xOffset = Integer.parseInt(args[0]);
         final int yOffset = Integer.parseInt(args[1]);
-        final String imageName = args[4];
+        int threadCount = Integer.parseInt(args[4]);
+        final String imageName = args[5];
 
         // Read the PNG file
         BufferedImage image = processImage(imageName);
         String[] pixelArray = prepareArray(image, xOffset, yOffset);
+        ArrayList<Worker> workerList = new ArrayList<>();
 
-        Worker worker0 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker1 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker2 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker3 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker4 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker5 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker6 = new Worker(HOSTNAME, PORT, pixelArray);
-        Worker worker7 = new Worker(HOSTNAME, PORT, pixelArray);
+        for(int i = 0; i < threadCount; i++)
+        {
+            workerList.add(new Worker(HOSTNAME, PORT, pixelArray));
+        }
 
-
-        worker0.start();
-        worker1.start();
-        worker2.start();
-        worker3.start();
-        worker4.start();
-        worker5.start();
-        worker6.start();
-        worker7.start();
-
-        /*try {
-            Socket socket = new Socket(HOSTNAME, PORT);
-            while(true) {
-                for(int i = 0; i < pixelArray.length; i++) {
-                    byte[] payload = pixelArray[i].getBytes();
-                    socket.getOutputStream().write(payload);
-                }
-            }
-        } catch (IOException e) {
-            e.printStackTrace();
-        }*/
+        for(int i = 0; i < threadCount; i++)
+        {
+            workerList.get(i).start();
+        }
     }
 }