Duration Ausgabe

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

@@ -7,9 +7,14 @@ 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{}
@@ -38,8 +43,12 @@ public class PrintAndEvaluate extends AbstractBehavior<PrintAndEvaluate.Message>
 
     // 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));
 
@@ -56,9 +65,11 @@ public class PrintAndEvaluate extends AbstractBehavior<PrintAndEvaluate.Message>
         return this;
     }
 
-    //Ausgeben des berechneten Wertes von dem Ausdruck
+    // 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;
     }
 }