gistfile1.scala

package akka

import akka.actor.{Actor, ActorSystem, Props}

import scala.concurrent.duration._

object AkkaScheduleTest {
  def main(args: Array[String]) {
    val system = ActorSystem("akka_system")
    system.actorOf(Props[AkkaScheduleTest], "test_actor")
  }
}


class AkkaScheduleTest extends Actor {

  import context._

  override def preStart() = system.scheduler.scheduleOnce(500 millis, self, "init_schedule")

  // override postRestart so we don't call preStart and schedule a new message
  override def postRestart(reason: Throwable) = {}

  override def receive: Actor.Receive = {
    case "init_schedule" =>
      // send another periodic tick after the specified delay
      system.scheduler.scheduleOnce(1000 millis, self, AA())
    case a: AA =>
      println(a)
      if (a.flag < 10)
        system.scheduler.scheduleOnce(1000 millis, self, AA(a.flag + 1))
  }
}

case class AA(flag: Int = 0, ct: Long = System.nanoTime())