68

假设我要从某些 URL 下载一个（可能很大的）图像列表。我正在使用 Scala，所以我要做的是：

import scala.actors.Futures._

// Retrieve URLs from somewhere
val urls: List[String] = ...

// Download image (blocking operation)
val fimages: List[Future[...]] = urls.map (url => future { download url })

// Do something (display) when complete
fimages.foreach (_.foreach (display _))

我对 Scala 有点陌生，所以这对我来说仍然有点像魔术：

  • 这是正确的方法吗？如果不是，有什么替代方案吗？
  • 如果我要下载 100 个图像，这会一次创建 100 个线程，还是会使用线程池？
  • 最后一条指令 ( display _) 会在主线程上执行吗，如果没有，我如何确保它是？

谢谢你的建议！

4

3 回答 3

135

在 Scala 2.10 中使用期货。他们是 Scala 团队、Akka 团队和 Twitter 之间的联合工作，旨在实现更标准化的未来 API 和跨框架使用的实现。我们刚刚发布了一份指南：http ://docs.scala-lang.org/overviews/core/futures.html

除了完全非阻塞（默认情况下，尽管我们提供了托管阻塞操作的能力）和可组合性之外，Scala 的 2.10 未来还带有一个隐式线程池来执行您的任务，以及一些用于管理超时的实用程序。

import scala.concurrent.{future, blocking, Future, Await, ExecutionContext.Implicits.global}
import scala.concurrent.duration._

// Retrieve URLs from somewhere
val urls: List[String] = ...

// Download image (blocking operation)
val imagesFuts: List[Future[...]] = urls.map {
  url => future { blocking { download url } }
}

// Do something (display) when complete
val futImages: Future[List[...]] = Future.sequence(imagesFuts)
Await.result(futImages, 10 seconds).foreach(display)

上面，我们首先导入了一些东西：

  • future: 用于创造未来的 API。
  • blocking：用于托管阻塞的 API。
  • Future：Future 伴侣对象，其中包含许多用于期货集合的有用方法。
  • Await: 用于阻塞未来的单例对象（将其结果传输到当前线程）。
  • ExecutionContext.Implicits.global：默认的全局线程池，一个 ForkJoin 池。
  • duration._：用于管理超时持续时间的实用程序。

imagesFuts与您最初所做的基本相同 - 这里唯一的区别是我们使用托管阻塞 - blocking。它通知线程池您传递给它的代码块包含长时间运行或阻塞操作。这允许池临时生成新的工作人员，以确保不会发生所有工作人员都被阻塞的情况。这样做是为了防止阻塞应用程序中的饥饿（锁定线程池）。请注意，线程池还知道托管阻塞块中的代码何时完成 - 因此它将在该点移除备用工作线程，这意味着池将收缩回其预期大小。

（如果你想绝对防止创建额外的线程，那么你应该使用 AsyncIO 库，例如 Java 的 NIO 库。）

然后我们使用 Future 伴随对象的集合方法将imagesFutsfrom 转换List[Future[...]]为Future[List[...]].

对象是我们Await如何确保display在调用线程上执行 -Await.result只需强制当前线程等待，直到它传递的未来完成。（这在内部使用托管阻塞。）

于 2012-10-27T11:04:23.713 回答
5 
val all = Future.traverse(urls){ url =>
  val f = future(download url) /*(downloadContext)*/
  f.onComplete(display)(displayContext)
  f
}
Await.result(all, ...)
  1. 在 2.10 中使用 scala.concurrent.Future，现在是 RC。
  2. 它使用隐式 ExecutionContext
  3. 新的 Future 文档明确指出，如果值可用，onComplete（和 foreach）可以立即评估。老演员Future也做同样的事情。根据您对显示的要求，您可以提供合适的 ExecutionContext（例如，单线程执行程序）。如果你只是想让主线程等待加载完成，traverse 会给你一个等待的未来。
于 2012-10-27T08:39:57.813 回答
3

  1. 是的，对我来说似乎很好，但您可能想研究更强大的twitter-util或Akka Future API（Scala 2.10 将有一个这种风格的新 Future 库）。

  2. 它使用线程池。

  3. 不，不会的。为此，您需要使用 GUI 工具包的标准机制（SwingUtilities.invokeLater用于 Swing 或Display.asyncExecSWT）。例如

    fimages.foreach (_.foreach(im => SwingUtilities.invokeLater(new Runnable { display im })))
于 2012-10-27T06:57:26.303 回答