有没有办法关闭 Akka 的调试输出?
在使用 Akka 时,我实现了一个简单的命令行应用程序。 但是 Akka 也会将语句打印到命令行,例如: [GENERIC] [27.10.11 22:57] [RemoteClientStarted(…
让两个本地实例与 Akka Actor 通信所需的最少代码是什么?
我想知道在一台机器上启动两个应用程序实例所需的最少代码是什么,这两个实例可以相互发送和接收消息。 据我了解,我需要 启动一个可以处理消息的演员…
为什么使用 akka eventhandler 进行日志记录
在以下文档中,事件处理程序被描述为取代日志记录 http://akka.io/docs/akka/1.2/general/event -handler.html 有一个事件处理程序取代了 Akka 中的日…
使用 akka future 和 actor 并行化列表
我想向参与者发送消息列表,在未来立即收到回复,然后等待所有未来完成,然后再返回调用方法。通过阅读 akka 文档,我相信 Future.sequence 是可行的…
在 Scala 的 Actor 中传递函数并对其结果进行操作
我正在 scala 中实现一个基于 actor 的应用程序,并且我试图能够在 actor 之间传递函数,以便仅在 actor 收到某些消息时才处理它们。 import actors.A…
Actor 是在简单的多人游戏之间实现消息传递的正确工具吗?
我正在考虑使用 Actor 来制作一个用 Scala 和 Java2D 编写的简单的类似 Asteroid 的游戏,该游戏可以由两个玩家以合作模式玩。 两名玩家都可以在共享…
丢弃 Scala actor 中除最后一条消息之外的所有消息
我有一个 SwingWorker 演员,它根据发送的参数对象计算要显示的绘图;然后在 EDT 线程上绘制绘图。一些 GUI 元素可以调整该图的参数。当它们发生变化…
在 Scala 中创建自文档 Actor
我正在考虑使用 finagle 在 Scala 中实现基于 JSON-RPC 的 Web 服务。我正在尝试找出如何最好地构建 RPC 调用代码(即采用反序列化请求并调用适当的方…
与 Scala.Actors 相比,如何正确设置 Akka.Actors
如何运行 2 个 Akka Actor,调用者每 n 秒向消费者发送一条消息? 由于 Scala.Actors 库中没有循环反应方法,我陷入了困境 不知何故,以下内容将不会…
适用于 Ocaml 和其他语言的基于 Actor 的分布式并发库
Closed. This question is seeking recommendations for software libraries, tutorials, tools, books, or other off-site resources. It does not …
为什么scala actor消息队列没有界限(大小)
def append(msg: Msg, session: OutputChannel[Any]) { changeSize(1) // size always increases by 1 val el = new MQueueElement(msg, session) if…
“自我”如何实现?在 Scala 演员中工作?
以下代码片段摘自《Scala import actors.Actor object NameResolver extends Actor { import java.net.{InetAddress, UnknownHostException} def act(…
Scala-Actors,避免内存泄漏是一个好习惯吗?
一切都始于问题“Scala,Actors,未读收件箱消息会发生什么? ”。我在想如何在具有许多参与者的大型系统中避免此类问题。 我发现自己写了这样的东西…