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

small adjustment to the example, showing the correct use of the startWith and initialize

Browse source
This commit is contained in:
momania 2011-01-04 09:32:13 +01:00
parent dfd18968c8
commit dc1fe991bb
1 changed files with 11 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

16
akka-samples/akka-sample-fsm/src/main/scala/DiningHakkersOnFsm.scala
View file

@ -33,6 +33,9 @@ case class TakenBy(hakker: Option[ActorRef])
class Chopstick(name: String) extends Actor with FSM[ChopstickState, TakenBy] {
self.id = name
// A chopstick begins its existence as available and taken by no one
startWith(Available, TakenBy(None))
// When a chopstick is available, it can be taken by a some hakker
when(Available) {
case Event(Take, _) =>
@ -49,8 +52,8 @@ class Chopstick(name: String) extends Actor with FSM[ChopstickState, TakenBy] {
goto(Available) using TakenBy(None)
}
// A chopstick begins its existence as available and taken by no one
startWith(Available, TakenBy(None))
// Initialze the chopstick
initialize
}
/**
@ -81,6 +84,9 @@ case class TakenChopsticks(left: Option[ActorRef], right: Option[ActorRef])
class FSMHakker(name: String, left: ActorRef, right: ActorRef) extends Actor with FSM[FSMHakkerState, TakenChopsticks] {
self.id = name
//All hakkers start waiting
startWith(Waiting, TakenChopsticks(None, None))
when(Waiting) {
case Event(Think, _) =>
log.info("%s starts to think", name)
@ -147,12 +153,12 @@ class FSMHakker(name: String, left: ActorRef, right: ActorRef) extends Actor wit
startThinking(5 seconds)
}
// Initialize the hakker
initialize
private def startThinking(duration: Duration): State = {
goto(Thinking) using TakenChopsticks(None, None) forMax duration
}
//All hakkers start waiting
startWith(Waiting, TakenChopsticks(None, None))
}
/*