Scala 并行集合、线程终止和 sbt

Question

我正在使用并行集合，当我的应用程序终止时，sbt 问题：

Not interrupting system thread Thread[process reaper,10,system]

每个核心发出一次此消息（准确地说是减一）。

我在 sbt 代码中看到这是设计使然，但我不确定为什么线程不与我的应用程序一起终止。如果您不幸遇到相同的情况，我们将不胜感激...

Answer 1

默认情况下，并行集合由 ForkJoinTasks.defaultForkJoinPool 支持，这是一个 lazy val，因此它是在第一次使用时创建的。

与任何ForkJoinPool 一样，它会一直运行直到明确关闭。池无法知道它是否会接收任何新任务，并且线程创建相对昂贵，因此池在它为空时关闭，然后在添加新任务时重新启动，这将是浪费.所以它的线程会一直徘徊，除非并且直到池被明确关闭。

作为一个设计决策，JVM 不会仅仅因为主线程终止就杀死其他线程；在某些编程风格中，主线程相对较早地终止（例如，考虑 Web 服务器，主线程设置所有内容，启动调度程序线程池，然后退出，但 Web 服务器继续无限期地运行）。

一旦您知道您将不再执行任何并行操作，您就可以调用ForkJoinTasks.defaultForkJoinPool.shutdown()，或者您可以使用由您的代码明确控制的自定义池来创建并行集合。