Logging system rewritten + export to file

Author: potat-dev

src/labs/sem1/lab10/DebugStack.java

@@ -2,43 +2,49 @@
 
 public class DebugStack extends Stack {
   protected boolean debug = false;
+  Logger logger;
 
-  public void setDebug(boolean debug) {
-    this.debug = debug;
+  public void setLogger(Object logger) {
+    if (logger instanceof Logger) {
+      this.logger = (Logger) logger;
+      debug = true;
+    } else {
+      debug = false;
+    }
   }
 
   public void push(int i) {
     if (debug)
-      Utils.printRow("Push START");
+      logger.printRow("Push START");
     super.push(i);
     if (debug)
-      Utils.printRow("Push END");
+      logger.printRow("Push END");
   }
 
-  public int pop() throws RuntimeException {
+  public int pop() {
     if (debug)
-      Utils.printRow("Pop START");
+      logger.printRow("Pop START");
     int i = super.pop();
     if (debug)
-      Utils.printRow("Pop END");
+      logger.printRow("Pop END");
     return i;
   }
 
   public boolean equals(Object o) {
     if (debug)
-      Utils.printRow("Equals START");
+      logger.printRow("Equals START");
     boolean b = super.equals(o);
     if (debug)
-      Utils.printRow("Equals END");
+      logger.printRow("Equals END");
     return b;
   }
 
   public String toString() {
     if (debug)
-      Utils.printRow("toString START");
+      logger.printRow("toString START");
     String s = super.toString();
     if (debug)
-      Utils.printRow("toString END");
+      logger.printRow("toString END");
     return s;
   }
 }

src/labs/sem1/lab10/Logger.java

@@ -0,0 +1,52 @@
+package labs.sem1.lab10;
+
+import java.nio.file.Files;
+import java.nio.file.Paths;
+import java.io.IOException;
+
+public class Logger {
+  StringBuilder sb;
+  String[] row;
+
+  public Logger(int threadsCount) {
+    sb = new StringBuilder();
+    // header of the CSV file
+    row = new String[threadsCount + 1];
+    row[0] = "main";
+    for (int i = 1; i < row.length; i++) {
+      row[i] = "Thread " + (i - 1);
+    }
+    // append header to the string
+    sb.append(String.join(",", row) + "\n");
+    // empty row for next lines
+    for (int i = 0; i < row.length; i++) {
+      row[i] = "\"\"";
+    }
+  }
+
+  public void printRow(String s) {
+    // print s at the column of the current thread (other columns should be empty)
+    // get current thread id from "Thread 0" -> 1 (main -> 0)
+    String threadName = Thread.currentThread().getName();
+    int threadId = (threadName.equals("main")) ? 0 : Integer.parseInt(threadName.split(" ")[1]) + 1;
+    // add s to the its column and append to the string
+    row[threadId] = s;
+    sb.append(String.join(",", row) + "\n");
+    // empty row for next lines
+    row[threadId] = "\"\"";
+  }
+
+  public void writeFile(String filename) {
+    // if file or folder doesn't exist, create it
+    try {
+      if (!Files.exists(Paths.get(filename))) {
+        Files.createDirectories(Paths.get(filename).getParent());
+        Files.createFile(Paths.get(filename));
+      }
+      // write the string to the file
+      Files.write(Paths.get(filename), sb.toString().getBytes());
+    } catch (IOException e) {
+      e.printStackTrace();
+    }
+  }
+}

src/labs/sem1/lab10/Main.java

@@ -5,6 +5,7 @@ public static void main(String[] args) {
     // classes to benchmark
     Class<?>[] classes = {
         Stack.class,
+        DebugStack.class,
         SynchroStack.class,
         SynchroStackFast.class
     };
@@ -59,12 +60,20 @@ public static void main(String[] args) {
         for (int j = 0; j < threadsPerMethod; j++) {
           int index = i * threadsPerMethod + j;
           threads[index] = new Thread(methods[i]);
-          threads[index].setName("Thread-" + index);
+          threads[index].setName("Thread " + index);
         }
       }
 
+      Logger log = null;
+      // set logger if stack is subclass of DebugStack and not DebugStack itself
+      // because DebugStack is not synchronized (and therefore not thread-safe)
+      if (stack instanceof DebugStack && !stack.getClass().getSimpleName().equals("DebugStack")) {
+        log = new Logger(threads.length);
+        ((DebugStack) stack).setLogger(log);
+      }
+
       // print stack type
-      System.out.print(String.format("Benchmarking: %s ", stack.getClass().getSimpleName()));
+      System.out.print("Benchmarking: " + stack.getClass().getSimpleName() + " ");
 
       // start measuring time
       long start = System.currentTimeMillis();
@@ -86,6 +95,11 @@ public static void main(String[] args) {
       // stop measuring time
       long end = System.currentTimeMillis();
       System.out.println("- took " + (end - start) + " ms");
+
+      // write to file
+      if (log != null) {
+        log.writeFile("results/" + stack.getClass().getSimpleName() + ".csv");
+      }
     }
   }
 }