scala - 创建并行执行列表组合器

Question

我有一个函数可以将 List[B] 分成两半并返回元组。我需要释放组合器来并行执行它们。

如果我做类似 fl.map(x => x.map(...)) 的事情，它就不是并行的。

object Parallel {

  implicit class ParList[A](fl: Future[List[A]]) {

    private def split[B](l: List[B]): (List[B], List[B]) = l.splitAt(l.length / 2)

    def paralFilter(f: A => Boolean): Future[List[A]] = ???

    def paralFold(init: A)(f: (A, A) => A): Future[A] = ???
  }

我知道我必须通过 split[B] 按元素拆分列表并并行执行带有元素的组合器。我该怎么做？

Answer 1

要实现此目的，请使用 scala.collection.Parallelized 的 par 方法:

object Parallel {

  implicit class ParList[A](fl: Future[List[A]]) {

    private def split[B](l: List[B]): (List[B], List[B]) = l.splitAt(l.length / 2)

    def paralFilter(f: A => Boolean)(implicit ec:ExecutionContext): Future[List[A]] = 
      fl.map(_.par.filter(f).toList)

    def paralFold(init: A)(f: (A, A) => A)(implicit ec:ExecutionContext): Future[A] =
      fl.map(_.par.fold(init)(f))
  }
}