在Akka演员中使用future.sequence的替代方法

Question

null

case RetrieveData(userId, `type`, id, lang, paging, timeRange, platform) => {
      val sen = sender

      val result: Future[Seq[Map[String, Any]]] = if (paging.getOrElse(Paging(0, 0)) == Paging(0, 0)) Future.successful(Seq.empty)
      else {
        val start = System.currentTimeMillis()

        val profileF = profileActor ? Get(userId)

        Future.sequence(Seq(profileF, getSymbols(`type`, id), getData(paging, timeRange, platform)).map { result =>
          logger.info(s"Got ${result.size} news in ${System.currentTimeMillis() - start} ms")
          result
        }.recover { case ex: Throwable =>
          logger.error(s"Failure on getting data: ${ex.getMessage}", ex)
          Seq.empty
        }
      }

      result.pipeTo(sen)
    }

函数getAndProcessData包含并行执行3个Future.Sequence。

现在，随着我对Akka的阅读越来越多，我发现使用ask会创建另一个actor Listener。问题是：

1. 正如我们广泛使用的ask，它是否会导致系统中使用多个线程，有时可能会导致线程饥饿？
2. 使用future.map也往往意味着不同的线程。我读到过一个线程演员的幻觉，它可以很容易地通过混合未来打破。
3. 此外，这是否会对性能产生不良影响？
4. 我们是否需要将sender存储在temp变量send中，因为我们正在使用pipeto？我们能不能只做管道（发送者）。另外，几乎每个接收回调中声明sen是否浪费了很多资源？我希望它的引用将在操作完成后被删除。
5. 有没有机会以更好的方式设计这样一个系统，meadning说我们不用map或者问那么多？我看了一些例子，当您只是将replyTo引用传递给某个actor时，使用tell而不是ask。此外，在某些情况下，发送消息给self而不是回复原始发件人可以代替使用Future.map。但是，我们想要并行执行3个异步操作并将格式化的数据返回给发送者，如何设计它呢？我们需要完成所有这3个操作才能格式化数据。

我尽量不包括很多例子，希望你能理解我们的顾虑和问题。很多问题，但我真的很想了解它是如何工作的，简单明了

提前致谢

Answer 1

如果您想并行执行3件事情，您将需要创建3个future值，这些值可能会使用3个线程，这是无法避免的。

我不确定map的问题是什么，但这段代码中只有一个调用，这是不必要的。

以下是清理代码以避免创建不必要的future值（未经测试！）的一种方法：

case RetrieveData(userId, `type`, id, lang, paging, timeRange, platform) =>
  if (paging.forall(_ == Paging(0, 0))) {
    sender ! Seq.empty
  } else {
    val sen = sender
    val start = System.currentTimeMillis()

    val resF = Seq(
      profileActor ? Get(userId),
      getSymbols(`type`, id),
      getData(paging, timeRange, platform),
    )

    Future.sequence(resF).onComplete {
      case Success(result) =>
        val dur = System.currentTimeMillis() - start
        logger.info(s"Got ${result.size} news in $dur ms")

        sen ! result
      case Failure(ex)
        logger.error(s"Failure on getting data: ${ex.getMessage}", ex)

        sen ! Seq.empty
    }
  }