MatrNum AkkaStart.java

revert TimerScheduler eingebaut. Funktionalität komplett fertig

src/main/java/com/example/Actor.java

@@ -1,21 +1,35 @@
 package com.example;
 
+/*
+Martrikelnummer der Gruppenmitglieder: Olha Grubryn (235122), Egor Rutkowski(225064), Nikola Kramaric (238498), Dennis Ruppel (238503)
+*/
 import akka.actor.typed.ActorRef;
 import akka.actor.typed.Behavior;
-import akka.actor.typed.javadsl.AbstractBehavior;
-import akka.actor.typed.javadsl.ActorContext;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.actor.typed.javadsl.Receive;
 import akka.actor.typed.javadsl.*;
 
 import java.time.Duration;
 import java.util.Objects;
-import java.util.logging.Logger;
 
 public class Actor extends AbstractBehavior<Actor.Message> {
 
-    //Timer für die Berechnung
-    final TimerScheduler<Message> timer;
+
+    //Timer, um bei den Berechnungen eine Sekunde lang zu warten.
+    TimerScheduler<Message> timer;
+
+    Expression expression;
+
+    //Zeichen für die Operation (Add, Sub, Mul) welche benutzt wird
+    String operationString;
+
+    //Referenz auf den initialen Actor
+    ActorRef<PrintAndEvaluate.Message> initial;
+
+    //Referenz auf den (potenziellen) OberSubActor. Es ist immer entweder initial oder oberActor null.
+    ActorRef<Actor.Message> oberActor;
+
+    //Linke Seite: true, Rechte Seite: false um zu wissen, ob dieser Actor ein linkes oder rechtes Kind ist.
+    boolean side;
+
     //Zurückgegebener String & Integer von der linken Seite
     String leftString;
     int leftInt;
@@ -24,103 +38,278 @@ public class Actor extends AbstractBehavior<Actor.Message> {
     String rightString;
     int rightInt;
 
-    //Zeichen für die Operation (Add, Sub, Mul) welche benutzt wird
-    String operationString;
-
-    String name;
-    Expression expression;
     public interface Message {}
 
-    public record Compute() implements Message{}
+    //Message kommt von dem initialen Actor
+    public record PrintMessage(ActorRef<PrintAndEvaluate.Message> sender, Expression expression) implements Message{}
+    public record SubPrintMessage(ActorRef<Actor.Message> sender, Expression expression, boolean side) implements Message{}
 
-    public record PrintAndEvaluate(Expression expression) implements Message{}
+    //Message kommt von einem Actor
+    public record EvaluateMessage(ActorRef<com.example.PrintAndEvaluate.Message> sender, Expression expression) implements Message{}
+    public record SubEvaluateMessage(ActorRef<Actor.Message> sender, Expression expression, boolean side) implements Message{}
 
     //Antwort von dem linken Kind
-    public record LeftResponse(String string, int wert) implements Message{}
+    public record LeftStringResponse(String string) implements Message{}
+    public record LeftIntResponse(int wert) implements Message{}
 
     //Antwort von dem rechten Kind
-    public record RightResponse(String string, int wert) implements Message{}
+    public record RightStringResponse(String string) implements Message{}
+    public record RightIntResponse(int wert) implements Message{}
 
-    private Actor(ActorContext<Message> context, String name, TimerScheduler<Message> timer){
+    //Nachricht an sich selbst, um nach einer Sekunde Wartezeit das Ergebnis zu berechnen
+    public record Compute() implements Message{}
+
+    private Actor(ActorContext<Actor.Message> context, TimerScheduler<Message> timer){
         super(context);
-        this.name = name;
         this.timer = timer;
     }
 
-    public static Behavior<Actor.Message> create(String name){
-        return Behaviors.setup(context -> Behaviors.withTimers(timers -> new Actor(context, name, timers)));
+    public static Behavior<Actor.Message> create(){
+        return Behaviors.setup(context -> Behaviors.withTimers(timers ->  new Actor(context,timers)));
     }
 
     @Override
     public Receive<Actor.Message> createReceive(){
         return newReceiveBuilder()
-                .onMessage(PrintAndEvaluate.class, this::onPrintAndEvaluate)
-                .onMessage(LeftResponse.class, this::onLeftResponse)
-                .onMessage(RightResponse.class, this::onRightResponse)
+                .onMessage(PrintMessage.class, this::onPrintMessage)
+                .onMessage(SubPrintMessage.class, this::onSubPrintMessage)
+                .onMessage(LeftStringResponse.class, this::onLeftStringResponse)
+                .onMessage(RightStringResponse.class, this::onRightStringResponse)
+                .onMessage(EvaluateMessage.class, this::onEvaluateMessage)
+                .onMessage(SubEvaluateMessage.class, this::onSubEvaluateMessage)
+                .onMessage(LeftIntResponse.class, this::onLeftIntResponse)
+                .onMessage(RightIntResponse.class, this::onRightIntResponse)
                 .onMessage(Compute.class, this::onComputeMessage)
                 .build();
     }
 
-    private Behavior<Message> onPrintAndEvaluate(PrintAndEvaluate message){
+    //Die Nachricht von dem initialen Actor wird verarbeitet und, falls nötig (kein Val), weitere Actors erstellt.
+    //Dabei wird seine Referenz in @initial gespeichert und diese ist für den Formatierungsvorgang
+    private Behavior<Message> onPrintMessage(PrintMessage message){
+        this.initial = message.sender;
         this.expression = message.expression;
         //Wenn initial nur Val übergeben wird → einfach ausgeben ansonsten UnterActors erstellen
         if (Objects.requireNonNull(expression) instanceof Expression.Add add) {
             this.operationString = "+";
-            ActorRef<SubActor.Message> LeftSubActor = getContext().spawnAnonymous(SubActor.create());
-            LeftSubActor.tell(new SubActor.PrintAndEvaluate(getContext().getSelf(),add.left(), true));
-            ActorRef<SubActor.Message> RightSubActor = getContext().spawnAnonymous(SubActor.create());
-            RightSubActor.tell(new SubActor.PrintAndEvaluate(getContext().getSelf(),add.right(), false));
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubPrintMessage(getContext().getSelf(),add.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubPrintMessage(getContext().getSelf(),add.right(), false));
         }
         else if (expression instanceof Expression.Sub sub) {
             this.operationString = "-";
-            ActorRef<SubActor.Message> LeftSubActor = getContext().spawnAnonymous(SubActor.create());
-            LeftSubActor.tell(new SubActor.PrintAndEvaluate(getContext().getSelf(),sub.left(), true));
-            ActorRef<SubActor.Message> RightSubActor = getContext().spawnAnonymous(SubActor.create());
-            RightSubActor.tell(new SubActor.PrintAndEvaluate(getContext().getSelf(),sub.right(), false));
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubPrintMessage(getContext().getSelf(),sub.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubPrintMessage(getContext().getSelf(),sub.right(), false));
         }
         else if (expression instanceof Expression.Mul mul) {
             this.operationString = "*";
-            ActorRef<SubActor.Message> LeftSubActor = getContext().spawnAnonymous(SubActor.create());
-            LeftSubActor.tell(new SubActor.PrintAndEvaluate(getContext().getSelf(),mul.left(), true));
-            ActorRef<SubActor.Message> RightSubActor = getContext().spawnAnonymous(SubActor.create());
-            RightSubActor.tell(new SubActor.PrintAndEvaluate(getContext().getSelf(),mul.right(), false));
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubPrintMessage(getContext().getSelf(),mul.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubPrintMessage(getContext().getSelf(),mul.right(), false));
         } else if (expression instanceof Expression.Val val) {
-            logger.info(val.inner() + "");
+            initial.tell(new PrintAndEvaluate.StringResponse(String.valueOf(val.inner())));
         }
+
         return this;
     }
 
-    Logger logger = Logger.getLogger(Actor.class.getName());
-
-    //Antwort von dem rechten Kind. Wenn beide Seiten geantwortet haben, wird eine Sekunde gewartet und dann das Ergebnis
-    //berechnet in Compute()
-    private Behavior<Message> onLeftResponse(LeftResponse response){
-        this.leftString = response.string;
-        this.leftInt = response.wert;
-        if(this.rightString != null){
-            this.timer.startSingleTimer(new Compute(),Duration.ofSeconds(1));
+    //Nachricht von dem Actor, von welchem dieser Actor erstellt wurde, wird verarbeitet und,
+    //falls nötig (kein Val), weitere SubActors erstellt.
+    //Dabei wird seine Referenz in oberActor gespeichert und diese Funktion ist für den Formatierungsvorgang
+    private Behavior<Message> onSubPrintMessage(SubPrintMessage message){
+        this.oberActor = message.sender;
+        this.expression = message.expression;
+        this.side = message.side;
+        //Wenn initial nur Val übergeben wird → einfach ausgeben ansonsten UnterActors erstellen
+        if (Objects.requireNonNull(expression) instanceof Expression.Add add) {
+            this.operationString = "+";
+            ActorRef<Message> subActorLeft = getContext().spawnAnonymous(Actor.create());
+            subActorLeft.tell(new SubPrintMessage(getContext().getSelf(),add.left(), true));
+            ActorRef<Message> subActorRight = getContext().spawnAnonymous(Actor.create());
+            subActorRight.tell(new SubPrintMessage(getContext().getSelf(),add.right(), false));
         }
-        return this;
+        else if (expression instanceof Expression.Sub sub) {
+            this.operationString = "-";
+            ActorRef<Message> subActorLeft = getContext().spawnAnonymous(Actor.create());
+            subActorLeft.tell(new SubPrintMessage(getContext().getSelf(),sub.left(), true));
+            ActorRef<Message> subActorRight = getContext().spawnAnonymous(Actor.create());
+            subActorRight.tell(new SubPrintMessage(getContext().getSelf(),sub.right(), false));
         }
-
-    //Antwort von dem rechten Kind. Wenn beide Seiten geantwortet haben, wird eine Sekunde gewartet und dann das Ergebnis
-    //berechnet in Compute()
-    private Behavior<Message> onRightResponse(RightResponse response){
-        this.rightString = response.string;
-        this.rightInt = response.wert;
-        if(this.leftString != null){
-            this.timer.startSingleTimer(new Compute(),Duration.ofSeconds(1));
-        }
-        return this;
-    }
-
-    private Behavior<Message> onComputeMessage(Compute response){
-        if(operationString.equals("+")){
-            logger.info("(" + leftString + operationString + rightString + ")    Wert: " + (leftInt + rightInt));
-        } else if (operationString.equals("-")) {
-            logger.info("(" + leftString + operationString + rightString + ")    Wert: " + (leftInt - rightInt));
+        else if (expression instanceof Expression.Mul mul) {
+            this.operationString = "*";
+            ActorRef<Message> subActorLeft = getContext().spawnAnonymous(Actor.create());
+            subActorLeft.tell(new SubPrintMessage(getContext().getSelf(),mul.left(), true));
+            ActorRef<Message> subActorRight = getContext().spawnAnonymous(Actor.create());
+            subActorRight.tell(new SubPrintMessage(getContext().getSelf(),mul.right(), false));
+        } else if (expression instanceof Expression.Val val) {
+            if(side == true){
+                oberActor.tell(new Actor.LeftStringResponse(String.valueOf(val.inner())));
             }else{
-            logger.info("(" + leftString + operationString + rightString + ")    Wert: " + (leftInt * rightInt));
+                oberActor.tell(new Actor.RightStringResponse(String.valueOf(val.inner())));
+            }
+        }
+        return this;
+    }
+
+    //Antwort von dem linken Teilkind wird empfangen, verarbeitet und an den nächsthöheren Actor geschickt, falls von beiden Teilkindern
+    //bereits eine Antwort erhalten wurde. Hier für den Formatierungsvorgang.
+    private Behavior<Message> onLeftStringResponse(LeftStringResponse response){
+        this.leftString = response.string;
+        if(this.rightString != null){
+            if(this.initial != null){
+                initial.tell(new PrintAndEvaluate.StringResponse("(" + leftString + operationString + rightString +")"));
+            }else {
+                if(side == true){
+                    oberActor.tell(new Actor.LeftStringResponse("(" + leftString + operationString + rightString +")"));
+                }else {
+                    oberActor.tell(new Actor.RightStringResponse("(" + leftString + operationString + rightString +")"));
+                }
+            }
+        }
+        return this;
+    }
+    //Antwort von dem rechten Teilkind wird empfangen, verarbeitet und an den nächsthöheren Actor geschickt, falls von beiden Teilkindern
+    //bereits eine Antwort erhalten wurde. Hier für den Formatierungsvorgang.
+    private Behavior<Message> onRightStringResponse(RightStringResponse response) {
+        this.rightString = response.string;
+        if (this.leftString != null) {
+            if (this.initial != null) {
+                initial.tell(new PrintAndEvaluate.StringResponse("(" + leftString + operationString + rightString + ")"));
+            } else {
+                if (side == true) {
+                    oberActor.tell(new Actor.LeftStringResponse("(" + leftString + operationString + rightString + ")"));
+                } else {
+                    oberActor.tell(new Actor.RightStringResponse("(" + leftString + operationString + rightString + ")"));
+                }
+            }
+        }
+        return this;
+    }
+
+    //Die Nachricht von dem initialen Actor wird verarbeitet und, falls nötig (kein Val), weitere Actors erstellt.
+    //Dabei wird seine Referenz in @initial gespeichert und diese ist für den Rechenvorgang
+    private Behavior<Message> onEvaluateMessage(EvaluateMessage message){
+        this.initial = message.sender;
+        this.expression = message.expression;
+        //Wenn initial nur Val übergeben wird → einfach ausgeben ansonsten UnterActors erstellen
+        if (Objects.requireNonNull(expression) instanceof Expression.Add add) {
+            this.operationString = "+";
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),add.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),add.right(), false));
+        }
+        else if (expression instanceof Expression.Sub sub) {
+            this.operationString = "-";
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),sub.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),sub.right(), false));
+        }
+        else if (expression instanceof Expression.Mul mul) {
+            this.operationString = "*";
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),mul.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),mul.right(), false));
+        } else if (expression instanceof Expression.Val val) {
+            initial.tell(new PrintAndEvaluate.IntResponse(val.inner()));
+        }
+        return this;
+    }
+
+    //Nachricht von dem Actor, von welchem dieser Actor erstellt wurde, wird verarbeitet und,
+    //falls nötig (kein Val), weitere SubActors erstellt.
+    //Dabei wird seine Referenz in oberActor gespeichert und diese Funktion ist für den Rechenvorgang
+    private Behavior<Message> onSubEvaluateMessage(SubEvaluateMessage message){
+        this.oberActor = message.sender;
+        this.expression = message.expression;
+        this.side = message.side;
+        //Wenn initial nur Val übergeben wird → einfach ausgeben ansonsten UnterActors erstellen
+        if (Objects.requireNonNull(expression) instanceof Expression.Add add) {
+            this.operationString = "+";
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),add.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),add.right(), false));
+        }
+        else if (expression instanceof Expression.Sub sub) {
+            this.operationString = "-";
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),sub.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),sub.right(), false));
+        }
+        else if (expression instanceof Expression.Mul mul) {
+            this.operationString = "*";
+            ActorRef<Actor.Message> LeftSubActor = getContext().spawnAnonymous(Actor.create());
+            LeftSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),mul.left(), true));
+            ActorRef<Actor.Message> RightSubActor = getContext().spawnAnonymous(Actor.create());
+            RightSubActor.tell(new Actor.SubEvaluateMessage(getContext().getSelf(),mul.right(), false));
+        } else if (expression instanceof Expression.Val val) {
+            if(side == true){
+                oberActor.tell(new LeftIntResponse(val.inner()));
+            }else{
+                oberActor.tell(new RightIntResponse(val.inner()));
+            }
+
+        }
+        return this;
+    }
+
+    //Antwort von dem linken Teilkind wird empfangen. Falls von beiden Teilkindern bereits eine Antwort erhalten wurde,
+    //wird eine Sekunde lang gewartet und die Lösung des (Teil-)Ausdrucks berechnet.
+    private Behavior<Message> onLeftIntResponse(LeftIntResponse response){
+        this.leftInt = response.wert;
+        if(this.rightInt != 0){
+            timer.startSingleTimer(new Compute(), Duration.ofSeconds(1));
+        }
+        return this;
+    }
+
+    //Antwort von dem rechten Teilkind wird empfangen. Falls von beiden Teilkindern bereits eine Antwort erhalten wurde,
+    //wird eine Sekunde lang gewartet und die Lösung des (Teil-)Ausdrucks berechnet.
+    private Behavior<Message> onRightIntResponse(RightIntResponse response){
+        this.rightInt = response.wert;
+        if(this.leftInt != 0){
+            timer.startSingleTimer(new Compute(), Duration.ofSeconds(1));
+        }
+        return this;
+    }
+
+    //Hier wird die Lösung des (Teil-)Ausdrucks berechnet und an den nächsthöheren Actor oder, falls nicht vorhanden,
+    //an PrintAndEvaluate gesendet.
+    private Behavior<Message> onComputeMessage(Compute response) {
+        if (oberActor != null) {
+            //side == true bedeutet, dass dieser Actor das linke Kind ist und es wird LeftResponse geschickt
+            if (side == true) {
+                if (operationString.equals("+")) {
+                    oberActor.tell(new LeftIntResponse(leftInt + rightInt));
+                } else if (operationString.equals("-")) {
+                    oberActor.tell(new LeftIntResponse(leftInt - rightInt));
+                } else {
+                    oberActor.tell(new LeftIntResponse(leftInt * rightInt));
+                }
+            } else {
+                if (operationString.equals("+")) {
+                    oberActor.tell(new RightIntResponse(leftInt + rightInt));
+                } else if (operationString.equals("-")) {
+                    oberActor.tell(new RightIntResponse(leftInt - rightInt));
+                } else {
+                    oberActor.tell(new RightIntResponse(leftInt * rightInt));
+                }
+            }
+        } else {
+            if (operationString.equals("+")) {
+                initial.tell(new PrintAndEvaluate.IntResponse(leftInt + rightInt));
+            } else if (operationString.equals("-")) {
+                initial.tell(new PrintAndEvaluate.IntResponse(leftInt - rightInt));
+            } else {
+                initial.tell(new PrintAndEvaluate.IntResponse(leftInt * rightInt));
+            }
         }
         return this;
     }

src/main/java/com/example/AkkaMainSystem.java

@@ -1,5 +1,9 @@
 package com.example;
 
+/*
+Martrikelnummer der Gruppenmitglieder: Olha Grubryn (235122), Egor Rutkowski(225064), Nikola Kramaric (238498), Dennis Ruppel (238503)
+*/
+
 import akka.actor.typed.ActorRef;
 import akka.actor.typed.Behavior;
 import akka.actor.typed.javadsl.AbstractBehavior;
@@ -26,12 +30,12 @@ public class AkkaMainSystem extends AbstractBehavior<AkkaMainSystem.Create> {
     }
 
     private Behavior<Create> onCreate(Create command) {
-        //#create-actors
         Expression expression = Expression.generateExpression(6, 9);
-        ActorRef<Actor.Message> computer = this.getContext().spawn(Actor.create("Rechner"), "Rechner");
-        computer.tell(new Actor.PrintAndEvaluate(expression));
-        //Vergleich mit dem Output der Berechnung
-        System.out.println("SOLL:  "+expression+ "   Wert:" +expression.eval() + "   Runtime: " + expression.runtime());
+        //Vergleich mit dem Output der Berechnung zum Testen
+        System.out.println("SOLL:  "+expression+ "   Wert:" +expression.eval() + "   Runtime: " + expression.runtime() + " Sekunden");
+        //#create-actors
+        ActorRef<PrintAndEvaluate.Message> computer = this.getContext().spawn(PrintAndEvaluate.create("Rechner"), "rechner");
+        computer.tell(new PrintAndEvaluate.StartMessage(expression));
         return this;
     }
 }

src/main/java/com/example/AkkaStart.java

@@ -3,6 +3,9 @@ package com.example;
 import akka.actor.typed.ActorSystem;
 
 import java.io.IOException;
+/*
+Martrikelnummer der Gruppenmitglieder: Olha Grubryn (235122), Egor Rutkowski(225064), Nikola Kramaric (238498), Dennis Ruppel (238503)
+*/
 public class AkkaStart {
   public static void main(String[] args) {
     final ActorSystem<AkkaMainSystem.Create> messageMain = ActorSystem.create(AkkaMainSystem.create(), "akkaMainSystem");

src/main/java/com/example/ExampleActor.java

@@ -1,35 +0,0 @@
-package com.example;
-
-import akka.actor.typed.ActorRef;
-import akka.actor.typed.Behavior;
-import akka.actor.typed.javadsl.*;
-
-public class ExampleActor extends AbstractBehavior<ExampleActor.Message>{
-
-    public interface Message {};
-
-    public record ExampleMessage(ActorRef<AkkaMainSystem.Create> someReference, String someString) implements Message {  }
-
-    public static Behavior<Message> create(String name) {
-        return Behaviors.setup(context -> new ExampleActor(context, name));
-    }
-
-    private final String name;
-
-    private ExampleActor(ActorContext<Message> context, String name) {
-        super(context);
-        this.name = "test";
-    }
-
-    @Override
-    public Receive<Message> createReceive() {
-        return newReceiveBuilder()
-                .onMessage(ExampleMessage.class, this::onExampleMessage)
-                .build();
-    }
-
-    private Behavior<Message> onExampleMessage(ExampleMessage msg) {
-        getContext().getLog().info("I ({}) got a message: ExampleMessage({},{})", this.name, msg.someReference, msg.someString);
-        return this;
-    }
-}

src/main/java/com/example/ExampleTimerActor.java

@@ -1,45 +0,0 @@
-package com.example;
-
-import akka.actor.typed.javadsl.TimerScheduler;
-import akka.actor.typed.Behavior;
-import akka.actor.typed.javadsl.AbstractBehavior;
-import akka.actor.typed.javadsl.ActorContext;
-import akka.actor.typed.javadsl.Behaviors;
-import akka.actor.typed.javadsl.Receive;
-
-import java.time.Duration;
-
-
-public class ExampleTimerActor extends AbstractBehavior<ExampleTimerActor.Message> {
-
-    public interface Message {};
-
-
-    public record ExampleMessage(String someString) implements Message {  }
-
-    public static Behavior<Message> create() {
-        return Behaviors.setup(context -> Behaviors.withTimers(timers -> new ExampleTimerActor(context, timers)));
-    }
-
-    private final TimerScheduler<ExampleTimerActor.Message> timers;
-
-    private ExampleTimerActor(ActorContext<Message> context, TimerScheduler<ExampleTimerActor.Message> timers) {
-        super(context);
-        this.timers = timers;
-
-        Message msg = new ExampleMessage("test123");
-        this.timers.startSingleTimer(msg, msg, Duration.ofSeconds(10));
-    }
-
-    @Override
-    public Receive<Message> createReceive() {
-        return newReceiveBuilder()
-                .onMessage(ExampleMessage.class, this::onExampleMessage)
-                .build();
-    }
-
-    private Behavior<Message> onExampleMessage(ExampleMessage msg) {
-        getContext().getLog().info("I have send myself this message after 10 Seconds: {}", msg.someString);
-        return this;
-    }
-}

src/main/java/com/example/PrintAndEvaluate.java

@@ -0,0 +1,79 @@
+package com.example;
+
+/*
+Martrikelnummer der Gruppenmitglieder: Olha Grubryn (235122), Egor Rutkowski(225064), Nikola Kramaric (238498), Dennis Ruppel (238503)
+*/
+
+import akka.actor.typed.ActorRef;
+import akka.actor.typed.Behavior;
+import akka.actor.typed.javadsl.AbstractBehavior;
+import akka.actor.typed.javadsl.ActorContext;
+import akka.actor.typed.javadsl.Behaviors;
+import akka.actor.typed.javadsl.Receive;
+
+import java.time.Duration;
+import java.time.Instant;
+
+public class PrintAndEvaluate extends AbstractBehavior<PrintAndEvaluate.Message> {
+
+    String name;
+    Instant startTime; // Startzeit für die Zeitmessung der Berechnung
+
+    public interface Message{}
+
+    public record StringResponse(String string) implements Message{}
+
+    public record StartMessage(Expression expression) implements Message{}
+
+    public record IntResponse(int wert) implements Message{}
+
+    private PrintAndEvaluate(ActorContext<PrintAndEvaluate.Message> context, String name){
+        super(context);
+        this.name = name;
+    }
+
+    public static Behavior<PrintAndEvaluate.Message> create(String name){
+        return Behaviors.setup(context -> new PrintAndEvaluate(context, name));
+    }
+
+    @Override
+    public Receive<PrintAndEvaluate.Message> createReceive(){
+        return newReceiveBuilder()
+                .onMessage(StartMessage.class, this::onStartMessage)
+                .onMessage(StringResponse.class, this::onStringResponse)
+                .onMessage(IntResponse.class, this::onIntResponse)
+                .build();
+    }
+
+    // Mit dieser Message wird der PrintAndEvaluate Aktor in Gang gesetzt
+    private Behavior<Message> onStartMessage(StartMessage message){
+        // Startzeit für die Zeitmessung setzen
+        this.startTime = Instant.now();
+
+        // Starten des Formatierungsvorganges
+        this.getContext().getLog().info("\n Beginn der Ausdrucksformatierung");
+
+        ActorRef<Actor.Message> printActor = getContext().spawnAnonymous(Actor.create());
+        printActor.tell(new Actor.PrintMessage(getContext().getSelf(), message.expression));
+
+        // Starten des Berechnungsvorganges
+        this.getContext().getLog().info("\n Beginn der Berechnung");
+        ActorRef<Actor.Message> computeActor = getContext().spawnAnonymous(Actor.create());
+        computeActor.tell(new Actor.EvaluateMessage(getContext().getSelf(), message.expression));
+        return this;
+    }
+
+    // Ausgeben des Ausdruckes als String
+    private Behavior<Message> onStringResponse(StringResponse response){
+        this.getContext().getLog().info("\n Formatierter Ausdruck: " + response.string);
+        return this;
+    }
+
+    // Ausgeben des berechneten Wertes von dem Ausdruck und der Berechnungsdauer
+    private Behavior<Message> onIntResponse(IntResponse response){
+        Duration duration = Duration.between(startTime, Instant.now());
+        this.getContext().getLog().info("\n Ausgerechneter Wert: " + response.wert);
+        this.getContext().getLog().info("\n Berechnungsdauer: " + duration.toSeconds() + " Sekunden");
+        return this;
+    }
+}

src/main/java/com/example/SubActor.java

@@ -1,218 +0,0 @@
-package com.example;
-
-import akka.actor.typed.ActorRef;
-import akka.actor.typed.Behavior;
-import akka.actor.typed.javadsl.*;
-
-import java.time.Duration;
-import java.util.Objects;
-
-public class SubActor extends AbstractBehavior<SubActor.Message> {
-
-
-    //Timer, um bei den Berechnungen eine Sekunde lang zu warten
-    TimerScheduler<Message> timer;
-
-    Expression expression;
-
-    //Zeichen für die Operation (Add, Sub, Mul) welche benutzt wird
-    String operationString;
-
-    //Referenz auf den initialen Actor
-    ActorRef<Actor.Message> initial;
-
-    //Referenz auf den (potenziellen) OberSubActor. Es ist immer entweder initial oder oberActor null.
-    ActorRef<SubActor.Message> oberActor;
-
-    //Linke Seite: true, Rechte Seite: false um zu wissen welche Seite des Ausdrucks berechnet wird.
-    boolean side;
-
-    //Zurückgegebener String & Integer von der linken Seite
-    String leftString;
-    int leftInt;
-
-    //Zurückgegebener String & Integer von der rechten Seite
-    String rightString;
-    int rightInt;
-
-    public interface Message {}
-
-    //Message kommt von dem initialen Actor
-    public record PrintAndEvaluate(ActorRef<Actor.Message> sender,Expression expression, Boolean side) implements Message{ }
-
-    //Message kommt von einem anderen SubActor
-    public record SubPrintAndEvaluate(ActorRef<SubActor.Message> sender,Expression expression, Boolean side) implements Message{ }
-
-    //Antwort von dem linken Kind
-    public record LeftResponse(String string, int wert) implements Message{ }
-
-    //Antwort von dem rechten Kind
-    public record RightResponse(String string, int wert) implements Message{ }
-
-    //Nachricht an sich selbst, um nach einer Sekunde Wartezeit das Ergebnis zu berechnen
-    public record Compute() implements Message{}
-
-    private SubActor(ActorContext<SubActor.Message> context, TimerScheduler<Message> timer){
-        super(context);
-        this.timer = timer;
-    }
-
-    public static Behavior<SubActor.Message> create(){
-        return Behaviors.setup(context -> Behaviors.withTimers(timers ->  new SubActor(context,timers)));
-    }
-
-    @Override
-    public Receive<SubActor.Message> createReceive(){
-        return newReceiveBuilder()
-                .onMessage(PrintAndEvaluate.class, this::onPrintAndEvaluate)
-                .onMessage(SubPrintAndEvaluate.class, this::onSubPrintAndEvaluate)
-                .onMessage(LeftResponse.class, this::onLeftResponse)
-                .onMessage(RightResponse.class, this::onRightResponse)
-                .onMessage(Compute.class, this::onComputeMessage)
-                .build();
-    }
-
-    //Die Nachricht von dem initialen Actor wird verarbeitet.
-    //Dabei wird seine Referenz in @initial gespeichert
-    public Behavior<Message> onPrintAndEvaluate(PrintAndEvaluate message) {
-        this.initial = message.sender;
-        this.expression = message.expression;
-        this.side = message.side;
-        //Wenn initial nur Val übergeben wird → einfach ausgeben ansonsten UnterActors erstellen
-        if (Objects.requireNonNull(expression) instanceof Expression.Add add) {
-            this.operationString = "+";
-            ActorRef<Message> subActorLeft = getContext().spawnAnonymous(SubActor.create());
-            subActorLeft.tell(new SubPrintAndEvaluate(getContext().getSelf(), add.left(), true));
-            ActorRef<Message> subActorRight = getContext().spawnAnonymous(SubActor.create());
-            subActorRight.tell(new SubPrintAndEvaluate(getContext().getSelf(), add.right(), false));
-        } else if (expression instanceof Expression.Sub sub) {
-            this.operationString = "-";
-            ActorRef<Message> subActorLeft = getContext().spawnAnonymous(SubActor.create());
-            subActorLeft.tell(new SubPrintAndEvaluate(getContext().getSelf(),sub.left(), true));
-            ActorRef<Message> subActorRight = getContext().spawnAnonymous(SubActor.create());
-            subActorRight.tell(new SubPrintAndEvaluate(getContext().getSelf(),sub.right(), false));
-        } else if (expression instanceof Expression.Mul mul) {
-            this.operationString = "*";
-            ActorRef<Message> subActorLeft = getContext().spawnAnonymous(SubActor.create());
-            subActorLeft.tell(new SubPrintAndEvaluate(getContext().getSelf(),mul.left(), true));
-            ActorRef<Message> subActorRight = getContext().spawnAnonymous(SubActor.create());
-            subActorRight.tell(new SubPrintAndEvaluate(getContext().getSelf(),mul.right(), false));
-        } else if (expression instanceof Expression.Val val) {
-            if(side == true){
-                initial.tell(new Actor.LeftResponse(String.valueOf(val.inner()), val.inner()));
-            }else{
-                initial.tell(new Actor.RightResponse(String.valueOf(val.inner()), val.inner()));
-            }
-        }
-        return this;
-    }
-
-        //Nachricht von dem SubActor, von welchem dieser SubActor erstellt wurde, wird verarbeitet.
-        //Dabei wird seine Referenz in oberActor gespeichert.
-        public Behavior<Message> onSubPrintAndEvaluate(SubPrintAndEvaluate message){
-            this.oberActor = message.sender;
-            this.expression = message.expression;
-            this.side = message.side;
-            //Wenn initial nur Val übergeben wird → einfach ausgeben ansonsten UnterActors erstellen
-            if (Objects.requireNonNull(expression) instanceof Expression.Add add) {
-                this.operationString = "+";
-                ActorRef<Message> subActorLeft = getContext().spawnAnonymous(SubActor.create());
-                subActorLeft.tell(new SubPrintAndEvaluate(getContext().getSelf(),add.left(), true));
-                ActorRef<Message> subActorRight = getContext().spawnAnonymous(SubActor.create());
-                subActorRight.tell(new SubPrintAndEvaluate(getContext().getSelf(),add.right(), false));
-            }
-            else if (expression instanceof Expression.Sub sub) {
-                this.operationString = "-";
-                ActorRef<Message> subActorLeft = getContext().spawnAnonymous(SubActor.create());
-                subActorLeft.tell(new SubPrintAndEvaluate(getContext().getSelf(),sub.left(), true));
-                ActorRef<Message> subActorRight = getContext().spawnAnonymous(SubActor.create());
-                subActorRight.tell(new SubPrintAndEvaluate(getContext().getSelf(),sub.right(), false));
-            }
-            else if (expression instanceof Expression.Mul mul) {
-                this.operationString = "*";
-                ActorRef<Message> subActorLeft = getContext().spawnAnonymous(SubActor.create());
-                subActorLeft.tell(new SubPrintAndEvaluate(getContext().getSelf(),mul.left(), true));
-                ActorRef<Message> subActorRight = getContext().spawnAnonymous(SubActor.create());
-                subActorRight.tell(new SubPrintAndEvaluate(getContext().getSelf(),mul.right(), false));
-            } else if (expression instanceof Expression.Val val) {
-                if(side == true){
-                    oberActor.tell(new SubActor.LeftResponse(String.valueOf(val.inner()), val.inner()));
-                }else{
-                    oberActor.tell(new SubActor.RightResponse(String.valueOf(val.inner()), val.inner()));
-                }
-            }
-            return this;
-    }
-
-    public Behavior<Message> onLeftResponse(LeftResponse response){
-        this.leftString = response.string;
-        this.leftInt = response.wert;
-        if(this.rightString != null){
-            timer.startSingleTimer(new Compute(), Duration.ofSeconds(1));
-        }
-        return this;
-    }
-
-    public Behavior<Message> onRightResponse(RightResponse response){
-        this.rightString = response.string;
-        this.rightInt = response.wert;
-        if(this.leftString != null){
-            timer.startSingleTimer(new Compute(), Duration.ofSeconds(1));
-        }
-        return this;
-    }
-
-    private Behavior<Message> onComputeMessage(Compute response) {
-        if (oberActor != null) {
-            //side == true bedeutet, dass dieser Actor das linke Kind ist und es wird LeftResponse geschickt
-            if (side == true) {
-                if (operationString.equals("+")) {
-                    oberActor.tell(new LeftResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt + rightInt));
-                } else if (operationString.equals("-")) {
-                    oberActor.tell(new LeftResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt - rightInt));
-                } else {
-                    oberActor.tell(new LeftResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt * rightInt));
-                }
-            } else {
-                if (operationString.equals("+")) {
-                    oberActor.tell(new RightResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt + rightInt));
-                } else if (operationString.equals("-")) {
-                    oberActor.tell(new RightResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt - rightInt));
-                } else {
-                    oberActor.tell(new RightResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt * rightInt));
-                }
-            }
-        } else {
-            if (side == true) {
-                if (operationString.equals("+")) {
-                    initial.tell(new Actor.LeftResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt + rightInt));
-                } else if (operationString.equals("-")) {
-                    initial.tell(new Actor.LeftResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt - rightInt));
-                } else {
-                    initial.tell(new Actor.LeftResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt * rightInt));
-                }
-            } else {
-                if (operationString.equals("+")) {
-                    initial.tell(new Actor.RightResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt + rightInt));
-                } else if (operationString.equals("-")) {
-                    initial.tell(new Actor.RightResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt - rightInt));
-                } else {
-                    initial.tell(new Actor.RightResponse("(" + leftString + operationString + rightString + ")",
-                            leftInt * rightInt));
-                }
-            }
-        }
-        return this;
-    }
-}