2012-05-02 6 views

答えて

1

非常にシンプルだが拡張可能なスケジューラ・システムはアッカで構築することができる。

 
import akka.actor._ 
import akka.util.duration._ 

val system = ActorSystem("SchedulerTest") 
case object Job 

val runnerActor = system.actorOf(Props(
    new Actor{ 
     def receive = { case Job => println("run " + self.path.name)} 
    } 
)) 

//schedule a Job message to the actor in 500 ms 
system.scheduler.scheduleOnce(500 milliseconds, runnerActor, Job) 

//system.scheduler.schedule(0 milliseconds, 50 milliseconds, runnerActor, Job) //this repeats a message every 50 ms 

ワーカーアクターは、必要に応じてさらにイベントをスケジュールすることができます。 構成をdbにシリアル化するには、さまざまな方法があります。

Akka 2.0 Doc on Scheduler

関連する問題