diff --git a/de/darkress/pixelfood/Main.java b/de/darkress/pixelfood/Main.java
index d5706bb..682d229 100644
--- a/de/darkress/pixelfood/Main.java
+++ b/de/darkress/pixelfood/Main.java
@@ -57,7 +57,7 @@ class Main
         return null;
     }
 
-    private static String[] prepareArray(BufferedImage image, int xOffset, int yOffset) {
+    private static ArrayList<String> prepareArray(BufferedImage image, int xOffset, int yOffset) {
 
         int width = image.getWidth();
         int height = image.getHeight();
@@ -79,13 +79,26 @@ class Main
                 }
             }
         }
-        String[] payloadArray = new String[pixelArray.size()];
+        /*String[] payloadArray = new String[pixelArray.size()];
         for(int i = 0; i < payloadArray.length; i++)
         {
             payloadArray[i] = pixelArray.get(i);
         }
 
-        return payloadArray;
+        return payloadArray;*/
+        return pixelArray;
+    }
+
+    public static String[] prepareThreadArray(ArrayList<String> fullArray, int threadNumber, int threadCount)
+    {
+        String[] threadArray = new String[fullArray.size()/threadCount];
+        int count = 0;
+        for(int i = (threadNumber*fullArray.size())/threadCount; i < ((threadNumber+1)*fullArray.size())/threadCount; i++)
+        {
+            threadArray[count] = fullArray.get(i);
+            count++;
+        }
+        return threadArray;
     }
 
     //Syntax blabla.jar x y Hostname Port Image.png
@@ -99,12 +112,13 @@ class Main
 
         // Read the PNG file
         BufferedImage image = processImage(imageName);
-        String[] pixelArray = prepareArray(image, xOffset, yOffset);
+        ArrayList<String> fullArray = prepareArray(image, xOffset, yOffset);
         ArrayList<Worker> workerList = new ArrayList<>();
 
         for(int i = 0; i < threadCount; i++)
         {
-            workerList.add(new Worker(HOSTNAME, PORT, pixelArray));
+            String[] threadArray = prepareThreadArray(fullArray, i, threadCount);
+            workerList.add(new Worker(HOSTNAME, PORT, threadArray));
         }
 
         for(int i = 0; i < threadCount; i++)