Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- import akka.actor.{Props, ActorSystem, Actor}
- import scala.concurrent.Future
- import scala.concurrent.ExecutionContext.Implicits.global
- case class StartFuture()
- case class SpamMessage()
- class TestActor extends Actor {
- private var element = 3
- def receive = {
- case StartFuture() => {
- Future {
- Thread.sleep(2000)
- }.onSuccess {
- case _ => {
- element = 12
- println(element)
- }
- }
- }
- case SpamMessage() => {
- println(element)
- }
- }
- }
- object TryAkka {
- def main(args: Array[String]) {
- val system = ActorSystem("System")
- val mainActor = system.actorOf(Props[TestActor], "MainActor")
- mainActor ! StartFuture()
- while (true) {
- Thread.sleep(100)
- mainActor ! SpamMessage()
- }
- }
- }
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement