4

下面的 Haskell 代码使用par和pseq做一些多核数字运算作为玩具来显示正在使用的几个内核。在 Scala 中表达这一点的最简单和最惯用的方式是什么？Futures and Promises 看起来很有希望（咳咳），我一直在看scalaz.concurrent，例如这个例子，但我找不到文档来解释这一切。

import Control.Parallel

main = a `par` b `par` c `pseq` print (a + b + c)
  where
      a = ack 3 10
      b = fac 42
      c = fib 35

fac 0 = 1
fac n = n * fac (n-1)

ack 0 n = n+1
ack m 0 = ack (m-1) 1
ack m n = ack (m-1) (ack m (n-1))

fib 0 = 0
fib 1 = 1
fib n = fib (n-1) + fib (n-2)
4

2 回答 2

4

您可以像这样在 Scala 中翻译您的示例：

import concurrent.{Await, Future, future}
import concurrent.ExecutionContext.Implicits.global
import concurrent.duration.Duration

object Main extends App {

  val fac: Int => Int = {
    case 0 => 1
    case n => n * fac(n-1)
  }

  val ack: (Int, Int) => Int = {
    case (0, n) => n + 1
    case (m, 0) => ack (m-1, 1)
    case (m, n) => ack (m-1, ack(m, n-1))
  }

  val fib: Int => Int = {
    case 0 => 0
    case 1 => 1
    case n => fib(n-1) + fib(n-2)
  }

  val fa = future { ack(3, 10) }
  val fb = future { fac(42) }
  val fc = future { fib(35) }

  val x = for (((a, b), c) <- fa zip fb zip fc) yield (a + b + c)

  val result = Await.result(x, Duration.Inf) //awaiting synchronously after the result
  println(s"Value is: $result")

}

该future { fib(3, 10) }位将创建一个异步计算，该计算将在不同的执行线程上运行并返回一个Future对象。然后，您可以将所有未来组合成一个大未来，该未来将提供所有结果的列表，使用Future.sequence.

我们可以将后一个future的结果映射到结果的总和中，从而获得最终值。

有了这个最终的未来，我们可以做几件事。我们可以进一步组合它，或者我们可以在其上附加回调，或者我们可以同步等待指定的持续时间。在我的示例中，我在结果之后以同步方式等待无限时间。

于 2013-04-02T20:06:05.583 回答
1

我建议您使用期货，因为它们是自 2.10 以来标准库的一部分并且非常易于使用。我不会移植你的代码，而是给你一个例子，让你有个想法。

// not tailrec, will stack overflow for larger numbers
def fib(x: Int): Int = x match {
  case 0 | 1 => x
  case x => fib(x-1) + fib(x-2)
}

import scala.concurrent._
import ExecutionContext.Implicits.global

// create all the futures
val futures = Seq(future(fib(3)), future(fib(4)), future(fib(5)))

// make a Future[Seq[Int]] out of Seq[Future[Int]] and sum the ints
val sumFuture = Future.sequence(futures).map(_.sum)

// if the future is completed successfully print the result
sumFuture.onSuccess {
  case x => println(x)
}
于 2013-04-02T19:57:13.600 回答