Find centralized, trusted content and collaborate around the technologies you use most.
Teams
Q&A for work
Connect and share knowledge within a single location that is structured and easy to search.
我正在使用 Akka 2.1.4。我需要我的一个演员向自己发送延迟消息。
我已经尝试过,从演员的内部receive:
receive
context.system.scheduler.scheduleOnce(1 second, self, msg)
但是,它不会编译,因为它找不到隐式 ExecutionContext。我可以从哪里得到它?
注意:我知道实际的发件人不会是我的演员,但这没关系,因为我不需要知道发件人是谁。
你也可以这样做:
class MyActor extends Actor{ import context._ ... }
通过这种方式,您可以确保您将分配给该参与者的调度程序,以防它与系统的主要调度程序不同(这是您通过解决方案获得的)。
我想我已经找到了:
import myActorSystem.dispatcher context.system.scheduler.scheduleOnce(1 second, self, msg)
现在它编译了。