Akka 中的类型化和非类型化 Actor 有什么区别?什么时候用什么?
我尝试阅读 Akka 文档来找出 Typed 和 Untyped Actor 之间的确切区别。什么时候用什么?我不确定我错过了什么。有人可以向我指出一些相关的内容或在这…
Actor 模型:为什么 Erlang/OTP 很特别?你能用另一种语言吗?
我一直在研究学习 Erlang/OTP,因此,一直在阅读(好吧,略读)有关 Actor 模型的内容。 据我了解,参与者模型只是一组函数(在 Erlang/OTP 中称为“…
Scala Actors:是否有内置方法来停止/中断 Actor?
在Java中,我对线程有兴趣,例如: Thread thread = new Thread() { @Override public void run() { //use this while loop, I can stop/ interrupt t…
自演员在 repl 中挂起
我正在关注《Scala 编程》版本 1 30.3 (p589)。它解释了您可以使用“self”作为当前线程的参与者来调试 repl 中的参与者。然而,当我使用 Scala 2.9.1…
如何在 Scala 中编写计时器 Actor?
我需要一个演员每分钟发送一条消息。我如何最好地实现这种行为?据我所知,我担心使用 java.lang.Thread.sleep(long millis) ,因为线程可以在 Scala …
从 Java 线程转向 scala Actor
我有一个java应用程序,它有各种代理(Java Algo),它们监听消息并处理它们。每个代理在单个线程上执行这些消息,这些消息被添加到阻塞队列中以便一…
如何设置 Scala actor 独占使用单独的线程来运行?
据我了解,Scala 管理一个线程池来运行参与者,并在它们之间共享线程。我可以将特定的 Actor 设置为专门在单独的线程中运行,而不与其他 Actor 共享吗…
仅通过回复回复远程客户端?
根据 akka actor 文档,可以使用 回复自频道!消息,以便代码可以在本地运行。我想对远程演员做同样的事情。 我有: class ServerActor extends Actor…
阿卡中的“self”是什么?
只是阅读 Akka 示例,无法理解 self.reply 是如何定义的?据我所知,自我回复用于在接收块内回复消息。但既然reply是self的一个方法,那么self又是什…
如何在 Scala 中检索一组 Actor 中第一个完成的 Actor?
我有一定数量的长时间运行的 Actor,我希望编写一个同步函数来返回第一个完成的 Actor。我可以通过 futures 的旋转等待来做到这一点(例如 while (! f…
有没有办法关闭 Akka 的调试输出?
在使用 Akka 时,我实现了一个简单的命令行应用程序。 但是 Akka 也会将语句打印到命令行,例如: [GENERIC] [27.10.11 22:57] [RemoteClientStarted(…
让两个本地实例与 Akka Actor 通信所需的最少代码是什么?
我想知道在一台机器上启动两个应用程序实例所需的最少代码是什么,这两个实例可以相互发送和接收消息。 据我了解,我需要 启动一个可以处理消息的演员…