Java Akka des ActorRef Asynchron mit geplanten Ausgaben

Question

Nach dem Programm von diesem Link: Java Akka's ActorRef async issues

Gibt es irgendwelche Akka native Funktionen, die ich als Scheduling-Funktionen für actor.tell verwenden kann? Ich möchte jedes Zeitintervall einplanen, um automatisch zu "erzählen".

Übrigens, ich wähle nicht den Java-Executor, da ich keine OS-Ressourcen verschwenden möchte.

Beispielcode angehängt:

ActorSystem as1 = ActorSystem.create("actor1"); 
ActorRef ar1 = as1.actorOf(Props.create(Hello.class), "ar1"); 
ActorRef ar2 = as1.actorOf(Props.create(Hello.class), "ar2"); 
Router router = new Router(new RoundRobinRoutingLogic()); 
router = router.addRoutee(ar1); 
router = router.addRoutee(ar2); 
System.out.println("Start to say hello!"); 
router.route("Bob",ActorRef.noSender()); 
router.route("John",ActorRef.noSender()); 
System.out.println("Finish to say hello!”); 

Answer 1

Diese section in the reference guide sollte dies sehr hilfreich sein. Innerhalb Schauspieler, können Sie so etwas wie tun:

FiniteDuration delay = FiniteDuration.create(10, TimeUnit.MINUTES); 
FiniteDuration initialDelay = FiniteDuration.create(2, TimeUnit.MINUTES); 
getContext().system().scheduler().schedule(initialDelay, delay, self(), message, getContext().dispatcher(), ActorRef.noSender()); 

Von außen Schauspieler, können Sie so etwas wie unten tun, wenn Sie einen ActorRef ref haben

FiniteDuration delay = FiniteDuration.create(10, TimeUnit.MINUTES); 
FiniteDuration initialDelay = FiniteDuration.create(2, TimeUnit.MINUTES); 
actorSystem.scheduler().schedule(initialDelay, delay, self(), message, actorSystem.dispatcher(), ActorRef.noSender()) 

einen Router:

ActorSystem as1 = ActorSystem.create("actor1"); 
ActorRef ar1 = as1.actorOf(Props.create(Hello.class), "ar1"); 
ActorRef ar2 = as1.actorOf(Props.create(Hello.class), "ar2"); 
List<String> routees = Arrays.asList(ar1, ar2); 
ActorRef routerActorRef = as1.actorOf(new RoundRobinGroup(routees).props(), "router"); 
System.out.println("Start to say hello!"); 

FiniteDuration delay = FiniteDuration.create(10, TimeUnit.MINUTES); 
FiniteDuration initialDelay = FiniteDuration.create(2, TimeUnit.MINUTES); 
as1.scheduler().schedule(initialDelay, delay, routerActorRef, "Bob", as1.dispatcher(), ActorRef.noSender()) 

as1.scheduler().schedule(initialDelay, delay, routerActorRef, "John", as1.dispatcher(), ActorRef.noSender()) 

System.out.println("Finish to say hello!”);