文件名称：boop:使用 Akka 将函数并行应用于向量
文件大小：6KB
文件格式：ZIP
更新时间：2024-07-01 19:50:23
Scala
#Parallel 和 Concurrent Maps with boop！ 如果您想对 Scala 向量的每个元素应用一个函数，这可以按顺序完成（即使用映射）。 但是，如果您有多个线程可供使用，那么为什么不并行化它呢？ 这可以在 Akka 的帮助下完成。 具体来说，向量被分解为多个分区（在BoopMaster完成），并且在这些分区中的每一个中，函数并行应用于每个向量元素（在BoopManager和Booper ）。 当分区完成时，它们将处理后的向量返回给BoopMaster ，后者将它们组合起来并返回结果。 由于 Akka actor 模型（异步处理向量分区）及其函数式编程功能（传递将应用于向量分区的函数），这在 Scala 中特别容易做到。 考虑一个例子，你有一个字符串向量，你想对每个元素进行字数统计。 这可以通过创建一个BoopMaster演员并将其传递给它所需的参数来完成 向
【文件预览】：
boop-master
----src()
--------main()
----build.sbt(200B)
----README.md(2KB)