从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,但当我测试它时,它的速度比普通函数慢一半以上…
使用 scala actor 时遇到问题
我读到,使用 React 时,所有参与者都可以在单个线程中执行。我经常并行处理一个集合并需要输出结果。我不相信 System.out.println 是线程安全的,所…
seda 和 actor 模型本质上是等价的吗?
SEDA本质上是一组独立的“服务”,它们通过队列相互通信,可以进一步抽象为消息传递。 Actor模型是一组独立的函数,它们之间通过消息传递进行通信。 …