akka将任务分解为更小的部分，并将结果折叠起来

Question

问题是关于阿克卡演员图书馆。A想把一个大任务分成几个小任务，然后把它们的结果合并成一个“大”结果。这将给我更快的计算利润。如果较小的任务是独立的，则可以并行计算它们。

假设我们需要这样计算。函数count2X非常耗时，因此在一个线程中多次使用它并不理想。

//NOT OPTIMAL
def count2X(x: Int) = {
  Thread.sleep(1000)
  x * 2
}

val sum = count2X(1) + count2X(2) + count2X(3)
println(sum)

问题来了。

如何分派任务、收集结果，然后折叠它们，所有这些都使用akka actors？Akka已经提供了这样的功能，还是我需要自己实现？这种方法的最佳实践是什么。

以下是我的问题的“视觉”解释：

             /-> [SMALL_TASK_1] -\
[BIG_TASK] -+--> [SMALL_TASK_1] --> [RESULT_FOLD]
             \-> [SMALL_TASK_1] -/

下面是我的脚手架实现与缺失/坏的实现：）

case class Count2X(x: Int)

class Count2XActor extends Actor {
  def receive = {
    case Count2X(x) => count2X(x); // AND NOW WHAT ?
  }
}

case class CountSumOf2X(a: Int, b: Int, c: Int)

class SumOf2XActor extends Actor {
  val aCounter = context.actorOf(Props[Count2XActor])
  val bCounter = context.actorOf(Props[Count2XActor])
  val cCounter = context.actorOf(Props[Count2XActor])

  def receive = {
    case CountSumOf2X(a, b, c) => // AND NOW WHAT ? aCounter ! Count2X(a); bCounter ! Count2X(b); cCounter ! Count2X(c);
  }
}

val aSystem = ActorSystem("mySystem")
val actor = aSystem.actorOf(Props[SumOf2XActor])

actor ! CountSumOf2X(10, 20, 30)

谢谢你的帮助。

Answer 1

你可以做两件事：

1）使用Akka期货。这些允许您以异步方式调度操作和折叠操作。查看http://doc.akka.io/docs/akka/2.0.4/scala/futures.html了解更多信息。

2） 您可以将工作分派给多个“工作”参与者，然后让一个“主”参与者对其进行聚合，通过在消息中存储信息来跟踪哪些消息处于挂起/处理状态。我这里有一个使用Akka actors的简单股票报价示例：https://github.com/ryanlecompte/quotes

Answer 2

在阿卡，我会这样做：

val a = aCounter ? Count2X(10) mapTo[Int]
val b = bCounter ? Count2X(10) mapTo[Int]
val c = cCounter ? Count2X(10) mapTo[Int]
Await.result(Future.sequence(a, b, c) map (_.sum), 1 second).asInstanceOf[Int]

我相信有一个更好的方法——在所有的未来的-s并行完成后，在这里开始计算结果，对于简单的任务来说，这是可以的，但一般来说，你不应该等待太久