Futureを使ってみる。 Scala 2.10.0

gistfile1.scala

import scala.concurrent._

/* futureを使うときにExecutionContextが必要。 */
implicit val execctx = ExecutionContext.global

/* futureはscala.concurrentパッケージに定義されているシンタックスシュガー  */
val a = future { Thread sleep 100000 ; "hoge" }

/* 次のFutureの処理を合成 */
val b = a flatMap ( (str:String) => future { "fuga" + str } )

/* 成功したら結果を出力 */
b.onSuccess{case a => println(a)}

//=> "fugahoge"