Fibonacci
This commit is contained in:
parent
4d21a44a7e
commit
6f2af5f481
|
@ -24,10 +24,11 @@ public class AkkaMainSystem extends AbstractBehavior<AkkaMainSystem.Create> {
|
||||||
|
|
||||||
private Behavior<Create> onCreate(Create command) {
|
private Behavior<Create> onCreate(Create command) {
|
||||||
//#create-actors
|
//#create-actors
|
||||||
ActorRef<ExampleActor.Message> a = this.getContext().spawn(ExampleActor.create("Alice"), "alice");
|
ActorRef<FibCont.Message> c = this.getContext().spawn(C.create(), "c");
|
||||||
|
ActorRef<Fib.Message> fib = this.getContext().spawn(Fib.create(), "fib");
|
||||||
//#create-actors
|
//#create-actors
|
||||||
|
|
||||||
a.tell(new ExampleActor.ExampleMessage(this.getContext().getSelf(),"Test123"));
|
fib.tell(new Fib.FibMessage(7, c));
|
||||||
return this;
|
return this;
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
|
@ -0,0 +1,30 @@
|
||||||
|
package com.example;
|
||||||
|
|
||||||
|
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;
|
||||||
|
|
||||||
|
public class C extends AbstractBehavior<FibCont.Message> {
|
||||||
|
public static Behavior<FibCont.Message> create() {
|
||||||
|
return Behaviors.setup(C::new);
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
private C(ActorContext<FibCont.Message> context) {
|
||||||
|
super(context);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Receive<FibCont.Message> createReceive() {
|
||||||
|
return newReceiveBuilder()
|
||||||
|
.onMessage(FibCont.FibContMessage.class, this::onFibContMessage)
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<FibCont.Message> onFibContMessage(FibCont.FibContMessage msg) {
|
||||||
|
getContext().getLog().info("{}", msg.n());
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
}
|
|
@ -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 = name;
|
|
||||||
}
|
|
||||||
|
|
||||||
@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;
|
|
||||||
}
|
|
||||||
}
|
|
|
@ -0,0 +1,41 @@
|
||||||
|
package com.example;
|
||||||
|
|
||||||
|
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;
|
||||||
|
|
||||||
|
public class Fib extends AbstractBehavior<Fib.Message> {
|
||||||
|
|
||||||
|
public interface Message {};
|
||||||
|
|
||||||
|
public record FibMessage(int n, ActorRef<FibCont.Message> cust) implements Message { }
|
||||||
|
|
||||||
|
public static Behavior<Message> create() {
|
||||||
|
return Behaviors.setup(Fib::new);
|
||||||
|
}
|
||||||
|
|
||||||
|
private Fib(ActorContext<Message> context) {
|
||||||
|
super(context);
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Receive<Message> createReceive() {
|
||||||
|
return newReceiveBuilder()
|
||||||
|
.onMessage(FibMessage.class, this::onFibMessage)
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<Message> onFibMessage(FibMessage msg) {
|
||||||
|
if(msg.n <= 1) {
|
||||||
|
msg.cust.tell(new FibCont.FibContMessage(msg.n));
|
||||||
|
} else {
|
||||||
|
ActorRef<FibCont.Message> cont = this.getContext().spawnAnonymous(FibCont.create(msg.cust));
|
||||||
|
this.getContext().getSelf().tell(new FibMessage(msg.n - 1, cont));
|
||||||
|
this.getContext().getSelf().tell(new FibMessage(msg.n - 2, cont));
|
||||||
|
}
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
}
|
|
@ -0,0 +1,48 @@
|
||||||
|
package com.example;
|
||||||
|
|
||||||
|
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;
|
||||||
|
|
||||||
|
public class FibCont extends AbstractBehavior<FibCont.Message> {
|
||||||
|
|
||||||
|
private boolean flag;
|
||||||
|
private int store;
|
||||||
|
|
||||||
|
public interface Message {};
|
||||||
|
|
||||||
|
public record FibContMessage(int n) implements Message { }
|
||||||
|
|
||||||
|
public static Behavior<Message> create(ActorRef<Message> cust) {
|
||||||
|
return Behaviors.setup(context -> new FibCont(context, cust));
|
||||||
|
}
|
||||||
|
|
||||||
|
private final ActorRef<Message> cust;
|
||||||
|
|
||||||
|
private FibCont(ActorContext<Message> context, ActorRef<Message> cust) {
|
||||||
|
super(context);
|
||||||
|
this.cust = cust;
|
||||||
|
this.flag = false;
|
||||||
|
this.store = 0;
|
||||||
|
}
|
||||||
|
|
||||||
|
@Override
|
||||||
|
public Receive<Message> createReceive() {
|
||||||
|
return newReceiveBuilder()
|
||||||
|
.onMessage(FibContMessage.class, this::onFibContMessage)
|
||||||
|
.build();
|
||||||
|
}
|
||||||
|
|
||||||
|
private Behavior<Message> onFibContMessage(FibContMessage msg) {
|
||||||
|
if (this.flag) {
|
||||||
|
this.cust.tell(new FibContMessage(this.store + msg.n));
|
||||||
|
} else {
|
||||||
|
this.flag = true;
|
||||||
|
this.store = msg.n;
|
||||||
|
}
|
||||||
|
return this;
|
||||||
|
}
|
||||||
|
}
|
Loading…
Reference in New Issue