斯卡拉管道 - 用于构建DAG工作流程的DSL

Question

我很好奇斯卡拉目前的库& Akka，这将允许我优雅地构建工作流程管道。

就我而言，工作流程仅仅是操作的DAG，因此演员/阿卡感觉非常合适。

我的问题是最好的方法是什么？有类似反应流的Libs允许流水线真正优雅的组合，但他们似乎非常注重记录。

我的用例是在它们之间传递消息的操作流。未来的作文很好，但一段时间后语法变得笨拙。也许有更好的scalaz和不成形的东西。

什么是使用消息传递为计算步骤的流水线构建DSL的方法和工具？

Answer 1

如果您的流水线非常像方法调用链，使用方法调用链！

没有必要让解决方案比需要更复杂;如果它是通过一系列方法调用很好地建模的，那就使用它。 （或功能，你可以撰写。）

如果你需要稍微复杂一些，但你实际上不需要任何消息传递，你可能需要像AsyncFP或Scala.Rx。

如果您需要多核解决方案，但您的方法调用看起来很类似，那么在一站式内部有一系列方法调用。您可以使用Akka流而不用担心有用的计算比率的开销。

Answer 2

虽然还处于早期开发阶段（写入前1.0版本），但您应该看看akka-streams，这正是一种描述计算图形然后异步运行的方法。