Scala 中的 Actor 会无法处理消息吗？ （O'Reilly 的 Scala 编程中的示例）

Question

我对 Scala 完全陌生，并且一直在在线学习 Scala 编程 (O'Reilly)；这样做时，我对 第 1 章，“并发体验”。

具体来说，是运行 scala -cp 的输出。 Shapes-actor-script.scala 应该是：

Circle.draw: Circle(Point(0.0,0.0),1.0)
Rectangle.draw: Rectangle(Point(0.0,0.0),2.0,5.0)
Triangle.draw: Triangle(Point(0.0,0.0),Point(1.0,0.0),Point(0.0,1.0))
Error: Unknown message! 3.14159
exiting...

然而，大约 10% 的情况下，我根本没有得到任何输出，甚至更罕见的是，我只会得到第一行作为输出。我对 Scala 的了解还不够，不知道这是否是正常的，因为 Actor 的工作方式，或者我的 Scala 安装（Arch Linux 上的 Scala 2.8.1）是否有问题。

Actor 是否会无法处理这样的消息（可能是因为示例的编写方式）？或者还有什么我可能会错过的事情吗？

Answer 1

我相信 Scala REPL 在完成运行脚本后正在使用 System.exit(...) 。这将停止进程而不等待任何延迟线程。

这意味着所有消息都将发送给参与者，但参与者可能无法及时处理它们。

为了演示，您可以尝试将 Thread.sleep(1000) 添加到 Shapes-actor.scala 中的每个案例中：

case s: Shape => Thread.sleep(1000);s.draw()
case "exit"   => Thread.sleep(1000);println("exiting..."); exit
case x: Any   => Thread.sleep(1000);println("Error: Unknown message! " + x)

这可能会使脚本每次都失败（在我的机器上就是如此）。如果您随后添加 Thread.sleep(5000) （给予 2 秒的松弛时间），那么每次都应该成功。

解决方案是使用不以 System.exit(...) 结尾的程序。

更新（秒的想法）：

您还可以设置演员在退出时通知：

case "exit"   => Thread.sleep(1000);println("exiting..."); this.synchronized { this.notify }; exit

...然后脚本可以等待通知：

ShapeDrawingActor.synchronized { ShapeDrawingActor.wait(10000) }

Answer 2

很抱歉这么长时间才回复这个帖子（因为我在书中写了这个例子：^/）。我相信真正的问题是 STDOUT 在所有操作系统（和 shell？）环境中默认情况下不会刷新，并且行为似乎根据 Scala 的版本而有所不同。今天晚上，我使用2.7.7编译并运行了代码。 OS X (10.6.6) 上的 2.8.0 和 2.8.1、Java 1.6.0_24-b07-334-10M3326 和 bash。

对于 2.7.7 和 2.8.1，所有输出都在进程退出之前打印。对于 2.8.0，只出现了一些输出！当我将“System.out.flush”添加到 Shapes-actor-script.scala 的末尾时，2.8.0 的所有输出都会被打印。

Answer 3

事实上，这似乎很合理。你看，演员与剧本同时进行，剧本中的台词都没有等待答案。因此，在参与者决定处理任何消息之前，许多消息完全有可能已传递给参与者。

然后就归结为演员应该如何查看邮箱。它可以将其作为队列进行遍历。但它也可以随机地穿过它，这提供了一些有趣的特性。

我的猜测是，Scala 2.7.x（本书撰写时可用的版本）默认使用排队算法，而 2.8.1 版本则使用随机算法。

Answer 4

简单的解决方案，将其添加到 Shapes-actor-script.scala 的末尾：

Thread.sleep(1000)

它将给 actor 在 REPL 终止之前打印所有各种 Shape 消息的时间。