Scalatest FunSuite 和 Akka Actor
我想编写一个使用 Akka Actor 并从 sbt 运行的 ScalaTest 测试套件。当我尝试这样做时: class Tests extends FunSuite with BeforeAndAfterAll { ove…
追踪“发送者层次结构”在 Scala 演员中
我目前正在维护几个基于 Actor 的 Scala 应用程序,我发现自己一直在问的一个问题是谁发送该消息? 例如,我找到了打印的一段代码我在日志中发现的可…
从2.0开始如何启动Akka Actors?
我正在使用 Akka Actors,并且正在尝试更新我的代码以使用最新的 2.0 里程碑。 API 发生了一些变化,例如 Actor 的创建现在通过名为 ActorSystem 的东…
在 Scala 中扩展抽象远程 Actor 和模式匹配(类加载?)
我正在实现一些扩展 Actor 的抽象类并提供一些额外的功能 [1]。但是,模式匹配似乎在接收语句中不起作用。如果我从客户端发送一个案例对象 Connect 到…
JBoss netty:如何将 Telnet 连接集成到单独的线程中?
我正在开发一个 Web 应用程序,该应用程序在基于 jboss netty 的封闭网络环境中通过 WebSocket 连接有限数量的 Android 设备(150 个)。 netty服务器…
将 Post 或 PostAndAsyncReply 与 F# 的 MailboxProcessor 一起使用吗?
我见过不同的片段演示 Put 消息,该消息使用 F# 的 MailboxProcessor 返回 unit。在某些情况下,仅使用 Post 方法,而另一些则使用 PostAndAsyncReply…
无法解释在 scala shell 中执行的示例的行为
LS 我刚刚使用 Odersky 等人的“Scala 编程”来学习 Scala。 在关于演员的章节中,我遇到了无法解释的行为。更具体地说,当尝试向“self”发送消息时…
使用 Akka 在 Scala 中快速复制大量文件
我想知道在 Scala 中将文件 src 复制到 dest 的最佳方法是什么,该文件将被包装在 Akka Actor 中,并可能在多台机器上使用 RemoteActor。 我有大量图…
处理应用程序级并发 - 我有什么选择?
我们有一个薄 Web 层 (Scalatra),它将传入的 HTTP 请求转换为发送到的事件(案例类) 线程绑定事件处理参与者。某些事件包含聚合根的 id,由于各种原…
Scala actor 的问题
为什么这不起作用? scala> actor { loop { receive { | case s:String => s + " :)" | }}} res0: scala.actors.Actor = scala.actors.Actor$$anon$1@…
在 scala actor 中传递集合
当我需要将类型化集合传递给参与者时,我在 react 方法中收到“未检查”警告: val actor = actor { loop { react { case a:List[String] => // do so…
pykka -- 演员很慢?
我目前正在尝试 Actor-concurreny(在 Python 上),因为我想了解更多相关信息。因此我选择了 pykka,但当我测试它时,它的速度比普通函数慢一半以上…