热交换 Akka Actor 的用例
Akka 1.1.3 文档指出“[t]he become 方法对于许多不同的事情都很有用,但它的一个特别好的例子是它用于实现有限状态机的示例(密克罗尼西亚联邦)。”…
如何从标准输入获取演员消息?
我想知道是否有可能(以及如何)让 akka actor 接收来自 stdin 的消息。本质上,这个想法是将每一行输入作为消息发送给参与者,例如 > myprogram DO X…
Scala、Actors,未读收件箱消息会怎样?
Scala Actors 中的未读收件箱消息会发生什么情况?例如两种情况:1.如果忘记为特殊消息实现反应案例:actor!NoReactCaseMessage2.如果消息来得太快:(…
基于 C++0x 线程标准构建的 Actors 实现
我有点失望地发现 C++0x 并发标准似乎没有对消息传递 Actors 模型提供任何本机支持。 我缺少对此的支持吗?也许是期货/承诺中的东西?是否有任何强大…
如何与actor实现异步相互依赖的可取消操作?
我对 Actor 模型还很陌生,这就是为什么我认为已经有既定的模式可以用 Actor 和 future 等美丽的可组合抽象来解决我的常见场景。 我的异步操作具有以…
Scala:如何在数组中启动演员?
我正在尝试用 2 种语言(Java 和 Scala)编写一个简单的客户端/服务器聊天应用程序。 Java 版本可以使用,唯一的问题是翻译它。 在Java中我有这样的代…
如何设置 akka Actor 容错能力?
我正在尝试在 akka Actors 中获得容错行为。我正在编写一些代码,这些代码依赖于系统中的 Actor 可用于长期处理。我发现我的处理在几个小时后停止(应…
使用线程局部变量的 Actor 回复会导致错误吗?
我注意到 Actor 应答调用ReplyReactor类型的线程局部变量的reply方法(参见私有方法rawSelf)。此 reply 方法将消息发送到 senders.head,其中 sender…
使用 play 框架在 scala 中的 Actor 中出现奇怪的 NullPointerException
我想做一些并行计算,但在调用我拥有的对象之外的任何函数时,我遇到了一个非常奇怪的 java.lang.NullPointerException 。 看一下: case class Retur…
如何取消ConsoleReader.readLine()
首先,我正在学习scala,并且是java世界的新手。 我想创建一个控制台并将该控制台作为可以启动和停止的服务运行。 我能够在 Actor 中运行 ConsoleRead…
如何防止 Scala 中的 Actor 邮箱增长?
据我所知,Scala actors 的邮箱没有大小限制。因此,如果参与者从其邮箱读取消息慢于其他人向该邮箱发送消息,那么它最终造成内存泄漏。 我们如何确保…