scala - future - map 与平面图

Question

我已经阅读了有关map和flatMap的文档，并且我了解flatMap用于接受Future参数并返回另一个Future的操作。我不完全理解的是为什么我要这样做。举个例子:

用户点击了我的网络服务，要求“做某事”

我下载了一个文件(很慢)

我处理文件(占用大量CPU)

渲染结果

我了解我希望以后使用它来下载文件，但是我有两个选择来对其进行重新处理:

val downloadFuture = Future {/* downloadFile */}
val processFuture = downloadFuture map {/* processFile */}
processFuture onSuccess { case r => renderResult(r) }

要么

val downloadFuture = Future {/* download the file */}
val processFuture = downloadFuture flatMap { Future {/* processFile */} }
processFuture onSuccess { case r => renderResult(r) }

通过添加调试语句(Thread.currentThread().getId)，我发现在两种情况下，process和render都在同一线程中发生(使用ExecutionContext.Implicits.global)。

我是否会简单地使用flatMap解耦downloadFile和processFile，并确保processFile始终在Future中运行，即使它不是从downloadFile映射的也是如此？

Answer 1

ensure that processFile always runs in a Future even if it was not mapped from downloadFile?

对，那是正确的。

但是，大多数情况下，您不会直接使用Future { ... }，而是会使用返回Future的函数(来自其他库或您自己的函数)。

想象以下功能:

def getFileNameFromDB{id: Int) : Future[String] = ???
def downloadFile(fileName: String) : Future[java.io.File] = ???
def processFile(file: java.io.File) : Future[ProcessResult] = ???

您可以使用flatMap组合它们:

val futResult: Future[ProcessResult] =
  getFileNameFromDB(1).flatMap( name =>
    downloadFile(name).flatMap( file =>
       processFile(file)
    )
  )

或使用来理解:

val futResult: Future[ProcessResult] =
  for {
    name <- getFileNameFromDB(1)
    file <- downloadFile(name)
    result <- processFile(file)
  } yield result

大多数情况下，您不会调用onSuccess(或onComplete)。通过使用这些函数之一，您可以注册一个回调函数，该函数将在Future完成时执行。

如果在我们的示例中，您想呈现文件处理的结果，则将返回类似Future[Result]的内容，而不是调用futResult.onSuccess(renderResult)。在最后一种情况下，您的返回类型将为Unit，因此您无法真正返回任何内容。

在Play Framework中，它可能类似于:

def giveMeAFile(id: Int) = Action.async {
  for {
    name <- getFileNameFromDB(1)
    file <- downloadFile(name)
    processed <- processFile(file)
  } yield Ok(processed.byteArray).as(processed.mimeType))
}