diff -r e723f041b6d0 -r 326e8a7ea287 src/Pure/Concurrent/future.scala --- a/src/Pure/Concurrent/future.scala Fri Apr 25 21:31:39 2014 +0200 +++ b/src/Pure/Concurrent/future.scala Fri Apr 25 22:10:03 2014 +0200 @@ -10,16 +10,23 @@ import scala.util.{Success, Failure} -import scala.concurrent.{Future => Scala_Future, Promise => Scala_Promise, Await} +import scala.concurrent.{ExecutionContext, ExecutionContextExecutor, + Future => Scala_Future, Promise => Scala_Promise, Await} import scala.concurrent.duration.Duration -import scala.concurrent.ExecutionContext.Implicits.global object Future { + lazy val execution_context: ExecutionContextExecutor = + ExecutionContext.fromExecutorService(Simple_Thread.default_pool) + def value[A](x: A): Future[A] = new Finished_Future(x) - def fork[A](body: => A): Future[A] = new Pending_Future(Scala_Future[A](body)) - def promise[A]: Promise[A] = new Promise_Future[A](Scala_Promise[A]) + + def fork[A](body: => A): Future[A] = + new Pending_Future(Scala_Future[A](body)(execution_context)) + + def promise[A]: Promise[A] = + new Promise_Future[A](Scala_Promise[A]) } trait Future[A] @@ -62,7 +69,8 @@ override def is_finished: Boolean = future.isCompleted def join: A = Await.result(future, Duration.Inf) - override def map[B](f: A => B): Future[B] = new Pending_Future[B](future.map(f)) + override def map[B](f: A => B): Future[B] = + new Pending_Future[B](future.map(f)(Future.execution_context)) } private class Promise_Future[A](promise: Scala_Promise[A])