scala中元组的简单并行评估？

Question

如果两个表达式e1和e2只处理不可变数据结构,那么并行计算元组(e1,e2)应该是简单的,只需要评估不同处理器上的两个表达式,不要担心任何交互,因为不应该'是任何.

Scala有很多不可变的数据结构,所以我希望有一种超级简单(写入)的方式来并行评估该元组.就像是

par_tuple : ( Unit -> T1) -> (Unit -> T2) -> (T1, t2)

它们并行计算两个函数,并在两个函数完成时返回.

不过,我还没有看到它.它存在吗？如果不是,你会怎么写呢？

Answer 1

这取决于被评估表达的成本.在当前的体系结构中,有两个表达式涉及少数几十个甚至几百个指令,并不能有效地并行评估.因此,您应该始终确保您执行的工作量不会受到并行化本身成本的影响.

考虑到这个免责声明,在Scala 2.10中,您可以使用Futures来完成此任务:

val f = future { e1 }
val g = future { e2 }
(Await.result(f), Await.result(g))

请注意,不建议使用这种计算方式(上面的内容是故意过于冗长!),因为它涉及阻塞和阻塞平台,例如JVM,在那里没有有效延续的概念,通常是昂贵的(尽管在这种情况下它是适用的超出了这个答案的范围,可能是这个答案者).在大多数情况下,您应该在将来安装一个回调函数,该函数在其值可用时调用.你可以这样做:

val h = for {
  x <- f
  y <- g
} yield (x, y)

其中,h上面是一个新的未来,这将包含值的元组一次都变得可用.

您可以将您的函数重写par_tuple为:

def par_tuple[E1, E2](e1: =>E1, e2: =>E2): Future[(E1, E2)] = {
  val f = future { e1 }
  val g = future { e2 }
  val h: Future[(E1, E2)] = for {
    x <- f
    y <- g
  } yield (x, y)
  h
}

这个方法返回Future你想要的元组 - 一个最终会用你的表达式保存元组的对象.您可以使用其他计算进一步构建此未来,或者如果您确定要阻止,则可以使用另一种变体:

def par_tuple_blocking[E1, E2](e1: =>E1, e2: =>E2): (E1, E2) = Await.result(par_tuple(e1, e2))

阻止,直到元组在将来可用.

在此处查看有关期货,回调和阻止的更多信息.