Comment puis-je faire exécuter un acteur Akka toutes les 5 minutes?

Question

J'aimerais savoir s'il existe un mécanisme dans Akka qui permet à un acteur d'être exécuté périodiquement?

Answer 1

Vous avez vraiment pas besoin d'un acteur à faire dans Akka vous 1.3.1 pouvez programmer une fonction à appeler toutes les 5 minutes comme ceci:

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

Cependant, si vous ne voulez qu'il soit un acteur pour d'autres raisons que vous appelleriez comme ça

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 vous utilisez 2.0, il serait Akka alors fait comme ce

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

ou envoyer un message à un acteur toutes les 5 minutes comme celui-ci

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

L'approche par le calendrier est une bonne approche, bien qu'il y ait un potentiel pour les messages à faire la queue si le travail effectué dans les délais prévus est si grand cela pourrait prendre plus de temps que l'intervalle prévu. Si vous voulez que l'intervalle de se produire entre la fin d'une itération et commençant de la suivante, utilisez scheduleOnce avec le motif suivant:

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 quelqu'un veux code java alors ils peuvent faire comme ça

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