Akka Schauspieler - warten Sie einige Zeit, um zu erwarten, dass eine Nachricht, ansonsten eine Nachricht senden

Ja, wenn Sie wollen, zu warten, für alle Nachricht, stellen Sie einfach eine receiveTimeout: http://doc.akka.io/docs/akka/current/scala/actors.html#receive-timeout

(Die Doku ist etwas irreführend hier können Sie die receiveTimeout nach jeder Nachricht auch)

Vielleicht ein overkill, aber Sie können überprüfen Sie heraus die Finite State Machine (FSM) Merkmal.

import akka._
import actor._
import util._
import duration._
import Impatient._

object Impatient {
  sealed trait State
  case object WaitingForMessage extends State
  case object MessageReceived extends State
  case object TimeoutExpired extends State

  sealed trait Data
  case object Unitialized extends Data

  //In
  case object Message
}

class Impatient(receiver: ActorRef) extends Actor with FSM[State, Data] {
  startWith(WaitingForMessage, Unitialized)

  when(WaitingForMessage, stateTimeout = 3 seconds) {
    case Event(StateTimeout, data) => goto(TimeoutExpired) using data //data is usually modified here
    case Event(Message, data) => goto(MessageReceived) using data //data is usually modified here
  }

  onTransition {
    case WaitingForMessage -> MessageReceived => stateData match {
      case data => log.info("Received message: " + data)
    }
    case WaitingForMessage -> TimeoutExpired => receiver ! TimeoutExpired
  }

  when(MessageReceived) {
    case _ => stay
  }

  when(TimeoutExpired) {
    case _ => stay
  }

  initialize
}

Hier ist es in Aktion:

object Main extends App {
  import akka._
  import actor._
  import Impatient._

  val system = ActorSystem("System")

  val receiver = system.actorOf(Props(new Actor with ActorLogging {
    def receive = {
      case TimeoutExpired => log.warning("Timeout expired")
    }
  }))

  val impatient = system.actorOf(Props(new Impatient(receiver)), name = "Impatient")
  impatient ! Message

  val impatient2 = system.actorOf(Props(new Impatient(receiver)), name = "Impatient2")
  Thread.sleep(4000)
  impatient2 ! Message

  system.shutdown()
}