raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 11

fix Java8 DiningHakkers sample

Browse source
This commit is contained in:
Roland Kuhn 2015-06-29 20:56:06 +02:00
parent 33bc502c76
commit 039e8261ff
1 changed files with 6 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

14
akka-samples/akka-sample-fsm-java-lambda/src/main/java/sample/become/DiningHakkersOnBecome.java
View file

@ -60,6 +60,12 @@ public class DiningHakkersOnBecome {
this.name = name; this.name = name;
this.left = left; this.left = left;
this.right = right; this.right = right;
//All hakkers start in a non-eating state
receive(ReceiveBuilder.matchEquals(Think, m -> {
System.out.println(String.format("%s starts to think", name));
startThinking(Duration.create(5, SECONDS));
}).build());
} }
//When a hakker is eating, he can decide to start to think, //When a hakker is eating, he can decide to start to think,
@ -124,14 +130,6 @@ public class DiningHakkersOnBecome {
right.tell(new Take(self()), self()); right.tell(new Take(self()), self());
}).build(); }).build();
//All hakkers start in a non-eating state
public Hakker() {
receive(ReceiveBuilder.matchEquals(Think, m -> {
System.out.println(String.format("%s starts to think", name));
startThinking(Duration.create(5, SECONDS));
}).build());
}
private void startThinking(FiniteDuration duration) { private void startThinking(FiniteDuration duration) {
context().become(thinking); context().become(thinking);
context().system().scheduler().scheduleOnce(duration, self(), Eat, context().system().dispatcher(), self()); context().system().scheduler().scheduleOnce(duration, self(), Eat, context().system().dispatcher(), self());