Playing with Akka futures

RV Akka futures 120306

import java.util.concurrent.Executors
import scala.io.Source
import akka.dispatch.ExecutionContext
import akka.util.duration._
import akka.dispatch.Future

implicit val ec = ExecutionContext.fromExecutorService(Executors.newCachedThreadPool())

val words = Source.fromFile("/usr/share/dict/words").getLines

// this blows up -- presumably because I'm loading all of words into memory

Future.traverse(words.toTraversable)(w => Future {
  (w.hashCode, w.length)
} onSuccess { 
  case (hashCode, length) => println("HASH: %d\tLENGTH: %d".format(hashCode, length))
})