¿Cómo puedo hacer que un actor Akka se ejecute cada 5 minutos?

Question

Me gustaría saber si hay algún mecanismo en Akka que pueda tener un actor ejecutado periódicamente?

Answer 1

Usted realmente no necesita un actor para hacer esto en Akka 1.3.1 puede programar una función a ser llamada cada 5 minutos como esto:

Scheduler.schedule(() => println("Do something"), 0L, 5L, TimeUnit.MINUTES) 

Sin embargo, si usted quiere que sea un actor por otras razones que lo llamaría como esto

case class Message() 

val actor = actorOf(new Actor { 
    def receive = { 
    case Message() => println("Do something in actor") 
    } 
}).start() 

Scheduler.schedule(actor, Message(), 0L, 5L, TimeUnit.MINUTES) 

Si está utilizando Akka 2.0 a continuación, que sería hecho como éste

val system = ActorSystem("MySystem") 
system.scheduler.schedule(0 seconds, 5 minutes)(println("do something")) 

o enviar un mensaje a un actor cada 5 minutos como este

case class Message() 
class MyActor extends Actor { 
    def receive = { case Message() => println("Do something in actor") } 
} 

val system = ActorSystem("MySystem") 
val actor = system.actorOf(Props(new MyActor), name = "actor") 
system.scheduler.schedule(0 seconds, 5 minutes, actor, Message()) 

Answer 2

El método que utiliza horario es una buena aproximación, aunque hay una posibilidad de que los mensajes que hacer cola si el trabajo realizado en la fecha prevista es tan grande que podría tomar más tiempo que el intervalo programado. Si desea que el intervalo de que se produzca entre el final de una iteración y la comenzando de la siguiente, a continuación, utilizar scheduleOnce con el siguiente patrón:

import akka.actor.Actor 
import scala.concurrent.duration._ 

class SchedulingActor extends Actor { 

    override def preStart(): Unit = { 
    self ! "Do Some Work" 
    } 

    def receive = { 
    case "Do Some Work" => 
     doWork 
     context.system.scheduler.scheduleOnce(5 minutes, self, "Do Some Work") 
    } 

    def doWork = ??? 
} 

Answer 3

Si alguien quiere el código de Java, entonces pueden hacer como esto

Cancellable cancellable = system.scheduler().schedule(Duration.Zero(), Duration.create(5, TimeUnit.MINUTES), cronActor, "tick", system.dispatcher(), null);