Scala 中的进程级并行性答案

【问题标题】：Process-level parallelism in ScalaScala 中的进程级并行性
【发布时间】：2013-10-26 01:23:31
【问题描述】：

我想在 Scala 中结合使用反射和并行处理，但我被 reflection's lack of thread safety 所困扰。所以，我正在考虑只在自己的进程（而不是线程）中运行每个任务。有什么简单的方法可以做到这一点？

例如，有没有办法配置.par 使其生成进程，而不是线程？还是有一些函数fork 接受闭包并在新进程中运行它？

编辑：期货显然是一个不错的选择。但是，我仍然需要弄清楚如何在单独的进程中运行它们。

编辑 2：即使使用 Akka 的“fork-join-executor”调度程序，我仍然遇到并发问题，这听起来确实应该是分叉进程。但是，当我在 Futures 中运行 ManagementFactory.getRuntimeMXBean().getName() 时，似乎一切都在同一个进程中。这是检查实际进程级并行性的正确方法吗？我是否使用了正确的 Akka 调度程序？

编辑 3：我意识到反射很糟糕。不幸的是，它在我需要的库中使用。

【问题讨论】：

听起来大多数与缺乏线程安全性相关的反射问题都可以通过在每个线程上使用单独的类加载器来解决。其他人对此有什么想法吗？
如果您是 Scala 的新手，您几乎可以肯定不希望通过反射来解决编程或设计问题。 Scala 编程和设计的一个非常重要的原则是静态类型。你应该知道“预先”（当你编写代码时）你的程序在输入什么类型。所谓的“动态类型”是一种含糊不清的说法，“你知道我的意思，编译器，对吧？”最终会适得其反的编程，至少在大型系统中是这样。避免它！
可以发布一个示例代码来演示该问题吗？

标签： scala concurrency akka

【解决方案1】：

您是否研究过 Scala Actors 或 Akka？使用 Scala 可能没有比并行和异步编程更令人信服的理由了。它融入了语言。看看这些设施。我很确定你会找到你需要的。

【讨论】：

嗯，不，但既然你提到它，我完全应该有。但我从未直接使用过它。这个简单用例的任何指针？
抱歉，我不太了解您想提供哪些帮助。我可以说 Akka 可能是矫枉过正。演员应该足够了。如果您可以摆脱单调的交付，这应该会有所帮助：youtube.com/watch?v=bNLeo36pFls
看起来 Akka Futures 可以解决问题，只要它们被配置为在自己的进程中运行：doc.akka.io/docs/akka/2.2.3/scala/futures.html

【解决方案2】：

关于您在这里尝试解决的问题的信息很少......以前的答案几乎是在球上 - 看看演员等......Akka，你可能会发现你不需要做任何太复杂的事情。多线程环境中的自省/反思通常意味着在分解手头的问题方面的混乱且没有经过深思熟虑的策略。

【讨论】：

不幸的是，反射是不可避免的，因为它现在已经融入了（非常有用的）scala-pickling。
那么是序列化及其复杂性的问题吗？