Scala中带有futures的异步IO

Question

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 _))

null

Answer 1

在Scala2.10中使用Futures。他们是Scala团队、Akka团队和Twitter之间的联合工作，以达成一个更标准化的未来API和实现，供跨框架使用。我们刚刚在以下网址发布了一份指南：http://docs.scala-lang.org/overviews/core/futures.html

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

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)

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

null