Advertisement
Guest User

Untitled

a guest
Oct 2nd, 2014
176
0
Never
Not a member of Pastebin yet? Sign Up, it unlocks many cool features!
Scala 0.80 KB | None | 0 0
  1. import akka.actor.{Props, ActorSystem, Actor}
  2.  
  3. import scala.concurrent.Future
  4. import scala.concurrent.ExecutionContext.Implicits.global
  5.  
  6. case class StartFuture()
  7. case class SpamMessage()
  8.  
  9. class TestActor extends Actor {
  10.   private var element = 3
  11.   def receive = {
  12.     case StartFuture() => {
  13.       Future {
  14.         Thread.sleep(2000)
  15.       }.onSuccess {
  16.         case _ => {
  17.           element = 12
  18.           println(element)
  19.         }
  20.       }
  21.     }
  22.     case SpamMessage() => {
  23.       println(element)
  24.     }
  25.   }
  26. }
  27.  
  28. object TryAkka {
  29.   def main(args: Array[String]) {
  30.     val system = ActorSystem("System")
  31.     val mainActor = system.actorOf(Props[TestActor], "MainActor")
  32.     mainActor ! StartFuture()
  33.     while (true) {
  34.       Thread.sleep(100)
  35.       mainActor ! SpamMessage()
  36.     }
  37.   }
  38. }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement