10

我正在使用 Akka 2.1.4。我需要我的一个演员向自己发送延迟消息。

我已经尝试过,从演员的内部receive

context.system.scheduler.scheduleOnce(1 second, self, msg)

但是,它不会编译,因为它找不到隐式 ExecutionContext。我可以从哪里得到它?

注意:我知道实际的发件人不会是我的演员,但这没关系,因为我不需要知道发件人是谁。

4

2 回答 2

15

你也可以这样做:

class MyActor extends Actor{
  import context._
  ...
}

通过这种方式,您可以确保您将分配给该参与者的调度程序,以防它与系统的主要调度程序不同(这是您通过解决方案获得的)。

于 2013-06-26T00:28:39.010 回答
4

我想我已经找到了:

import myActorSystem.dispatcher

context.system.scheduler.scheduleOnce(1 second, self, msg)

现在它编译了。

于 2013-06-25T21:38:32.593 回答