Akka / future——Akka 是否决定它是否“值得”?使用当前线程还是调度程序?
我目前正在考虑使用 Akka(Java API/库)来完成创建多个 Future 并将它们放入 BlockingQueue 的任务。现在,由 Callables 处理的某些任务可能在调用线…
在哪里可以找到 akka.cloud 包?
有人可以向我指出包含 akka.cloud.cluster 包的 Akka 版本吗?我目前使用的是 Akka 1.2-RC6。谷歌搜索此主题会导致有关 Cloudy Akka 的链接失效...…
从 Actor 向调用者发送 None
我有一个简单的 Actor,它使用 ScalaQuery 查询数据库,我已经模拟了它来测试使用它的客户端。 我想要的是,如果 ID 匹配,(模拟)Actor 会回复 Some…
热交换 Akka Actor 的用例
Akka 1.1.3 文档指出“[t]he become 方法对于许多不同的事情都很有用,但它的一个特别好的例子是它用于实现有限状态机的示例(密克罗尼西亚联邦)。”…
Spray 框架生产准备好了吗?
Spray 框架 (spray.cc) 似乎是使用 Scala 和 REST 构建 REST 服务的一种有趣且高效的方式。阿卡。我来自 Java + Spring 学校,那里的一切都有很好的文…
如何从标准输入获取演员消息?
我想知道是否有可能(以及如何)让 akka actor 接收来自 stdin 的消息。本质上,这个想法是将每一行输入作为消息发送给参与者,例如 > myprogram DO X…
如何理解AKKA中使用的这种CCAS锁定机制?
我刚刚在akka中发现了一段代码。 https://codereview.scala-lang.org/fisheye/browse/~raw,r=25521/scala-svn/scala/trunk/test/files/presentation/a…
为什么 Scala 无法实例化伴随对象?
我是 Scala 和 Akka 的新手,所以如果这是一个新手问题,请原谅我,但我在其他地方找不到答案...... 根据记录,我使用 Scala 2.9.0-1 和 Akka 1.1.3 …
如何设置 akka Actor 容错能力?
我正在尝试在 akka Actors 中获得容错行为。我正在编写一些代码,这些代码依赖于系统中的 Actor 可用于长期处理。我发现我的处理在几个小时后停止(应…
结合 Akka、Spray 和嵌入式 Jetty
我正在尝试创建一个包含 Akka、Spray 和 Jetty 的独立 JAR。理想情况下,我将整个应用程序分发到单个文件中,而不包含任何外部文件。 我了解如何创建…
“单位” Akka TypedActor 上的方法超时,但应该是异步的
我正在尝试使用 Akka TypedActors (1.1.2)。我有一个接口,就像 trait Namespace { def cellCount: Int def isEmpty: Boolean def cell(key: String):…