Làm cách nào để có một diễn viên Akka được thực hiện sau mỗi 5 phút?

Question

Tôi muốn biết liệu có bất kỳ cơ chế nào trong Akka có thể có một diễn viên được thực hiện định kỳ không?

Answer 1

Bạn không thực sự cần một diễn viên để làm điều này trong Akka 1.3.1 bạn có thể sắp xếp một hàm được gọi mỗi 5 phút như thế này:

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

Tuy nhiên, nếu bạn muốn nó được một diễn viên vì những lý do khác mà bạn sẽ gọi nó là như thế này

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) 

Nếu bạn đang sử dụng Akka 2.0 sau đó nó sẽ được thực hiện như thế này

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

Hoặc gửi một thông điệp tới một diễn viên mỗi 5 phút như

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

Phương pháp này sử dụng lịch là một trong những cách tiếp cận tốt, mặc dù có một tiềm năng cho các thông điệp để xếp hàng lên nếu công việc được thực hiện đúng tiến độ là rất lớn có thể mất nhiều thời gian hơn khoảng thời gian đã lên lịch. Nếu bạn muốn khoảng thời gian xảy ra giữa cuối của một lần lặp và bắt đầu tiếp theo, sau đó sử dụng scheduleOnce với mẫu sau:

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

Nếu bất cứ ai muốn mã java sau đó họ có thể làm như thế này

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