Akka调度

Question

我有以下代码块调用两个请求略有延迟。

    final ActorRef actor1 = getContext().actorOf(
            ActorClass.props(context,
            "actor1");
    futures.add(ask(actor1 , msg1, t));

    final ActorRef actor2 = getContext().actorOf(
            ActorClass.props(context,
            "actor2");
    futures.add(Patterns.after(Duration.create(10000, TimeUnit.MILLISECONDS),
            getContext().system().scheduler() , 
            getContext().dispatcher(), ask(actor2,msg2,t)));

在actor1和actor2中，我调用了一个REST请求，该请求返回一个cookie和响应消息。我在这里的意图是延迟发送与actor2对应的REST请求。然而，我从日志中观察到，请求立即从两个参与者发送，只有响应处理（在两个未来之间）延迟10秒。这是Akka中调度器的预期行为吗？如果我想在上述情况下延迟两个参与者之间的请求启动，我可以使用线程。睡觉（我在某个地方读到不建议在akka演员内使用Thread.sleep）。感谢您的意见。

Answer 1

（…）之后的，未来

模式之后的版本将立即开始执行，并将延迟完成此方法产生的未来。然而，如果您想延迟开始执行，您将需要在（...，Callable之后使用

// example code in Scala, but uses Java API

// future executes ASAP
print("Hello ")
Patterns.after(1.second, sys.scheduler, sys.dispatcher, Future { println("World!") })

// future executes after 1 second
print("Hello ")
Patterns.after(1.second, sys.scheduler, sys.dispatcher, 
  new Callable[Future[Unit]] {
    override def call() = Future { println("World!") }
  }
)

哈金快乐！