如何将 scala actor 添加到现有程序而不干扰正常终止行为？

Question

该程序在执行 main() 后不会退出。

object Main
{
    def main(args: Array[String]) {
        ... // existing code
        f()
        ... // existing code
    }
    def f() {
        import scala.actors.Actor._
        val a = actor {
            loop {
                react {
                case msg: String => System.out.println(msg)
                }
            }
        }
        a ! "hello world"
    }
}

由于这种意想不到的副作用，使用 actor 可能会被视为侵入性的。

假设参与者必须继续运行直到程序终止，您将如何在所有终止情况下保留原始行为？

Answer 1

2.8 中有一个 DaemonActor 类允许这样做。在 2.7.x I 中，您可以侵入自定义调度程序，即使仍然存在实时演员，该调度程序也不会阻止关闭，或者如果您想要一种简单的方法，您可以在 main 末尾调用 System.exit() 。

如果您将 Actor 视为一种轻量级线程，那么大多数时候您需要一个实时 Actor 来防止程序终止。否则，如果您有一个程序在 Actor 中完成所有工作，则需要在主线程上放置一些东西以使其保持活动状态，直到所有 Actor 完成为止。

Answer 2

上例中的主线程完成后，程序仍然有一个非守护线程在运行 actor。使用 Thread.destroy() 或 System.exit() 粗暴地终止正在运行的线程通常是一个坏主意，因为结果可能对您的程序非常不利，包括但不限于数据损坏和死锁。这就是为什么 Thread.destroy() 和类似方法在 Java 中首先被弃用的原因。正确的方法是在线程中显式实现终止逻辑。对于 Scala actor，归结为向所有正在运行的 actor 发送一条 Stop 消息，并让它们在收到消息后退出。通过这种方法，您的示例将如下所示：

object Main
{
    case object Stop
    def main(args: Array[String]) {
        ... // existing code
        val a = f()
        a ! "hello world"
        ... // existing code
        a ! Stop
    }
    def f() = {
        import scala.actors.Actor._
        actor {
            loop {
                react {
                   case msg: String => System.out.println(msg)
                   case Stop => exit()
                }
            }
        }
    }
}