Wie kann ich einen Akka-Schauspieler alle 5 Minuten hinrichten lassen?

Ich würde gerne wissen, ob es irgendwelche Mechanismus in Akka haben kann, dass ein Schauspieler, der periodisch ausgeführt?

InformationsquelleAutor der Frage Evans Y. | 2012-03-15

  1. 56

    Brauchst du nicht unbedingt ein Schauspieler, der dazu in Akka 1.3.1 Sie können planen, eine Funktion, die aufgerufen werden alle 5 Minuten so:

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

    Jedoch, wenn Sie wollen, dass es ein Schauspieler zu sein, für die anderen Gründe würden Sie nennen mag

    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)

    Wenn Sie mit Akka 2.0, dann wäre es so geschehen,

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

    Oder senden einer Nachricht an einen Schauspieler, der alle 5 Minuten wie diese

    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())

    InformationsquelleAutor der Antwort kerryjj

  2. 19

    Ansatz mit Zeitplan ist ein guter Ansatz, obwohl es ein potential für die Nachrichten in die Warteschlange, wenn die arbeiten im Zeitplan ist so groß, dass es vielleicht länger dauern als die geplanten Intervall. Wenn Sie möchten, dass das Intervall auftreten, zwischen den Ende einer iteration und der Anfang der nächste, dann verwenden Sie scheduleOnce mit dem folgenden Muster:

    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 = ???
}

    InformationsquelleAutor der Antwort mattinbits

  3. 1

    Wenn jemand java-code, dann können Sie dies so tun

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

    InformationsquelleAutor der Antwort Amit Yadav

  4. 0

    Mehr vollständiges Java-Beispiel:

    import akka.actor.AbstractActor;
import akka.actor.ActorRef;
import scala.concurrent.duration.FiniteDuration;
import java.util.concurrent.TimeUnit;

public class AnActor extends AbstractActor {
    private final FiniteDuration SCHEDULED_WORK_DELAY = new FiniteDuration(5, TimeUnit.MINUTES);

    @Override
    public void preStart() {
        getSelf().tell("Do Scheduled Work", ActorRef.noSender());
    }

    @Override
    public Receive createReceive() {
        return receiveBuilder()
        .matchEquals("Do Scheduled Work", work -> {
            doScheduledWork();
         context().system().scheduler().scheduleOnce(SCHEDULED_WORK_DELAY, getSelf(),
                "Do Scheduled Work", context().dispatcher(), ActorRef.noSender());
        })
        .build();
    }

    private void doScheduledWork() { ... }
}

    InformationsquelleAutor der Antwort Brett Tofel

Schreibe einen Kommentar