diff options
author | Aleksandar Prokopec <axel22@gmail.com> | 2012-02-16 13:47:59 +0100 |
---|---|---|
committer | Aleksandar Prokopec <axel22@gmail.com> | 2012-02-16 17:51:09 +0100 |
commit | ab84c8d9a97b41728e77f7808eda2748d052ca06 (patch) | |
tree | c56341a3ec7b4a7032574500784a8389feac9581 /src | |
parent | 53b05bb12f5a7a50448bcac9434389bf95273c45 (diff) | |
download | scala-ab84c8d9a97b41728e77f7808eda2748d052ca06.tar.gz scala-ab84c8d9a97b41728e77f7808eda2748d052ca06.tar.bz2 scala-ab84c8d9a97b41728e77f7808eda2748d052ca06.zip |
Disable execution context and futures implementation in the default package.
Fixed some tests so that they work now.
The Transactions.scala test was failing when defined in scala.concurrent
package, reporting that type `_$1` is defined twice. Until we figure out
the reason for this, the package name in that test is renamed.
Diffstat (limited to 'src')
-rw-r--r-- | src/library/scala/concurrent/default/SchedulerImpl.scala.disabled (renamed from src/library/scala/concurrent/default/SchedulerImpl.scala) | 0 | ||||
-rw-r--r-- | src/library/scala/concurrent/default/TaskImpl.scala.disabled (renamed from src/library/scala/concurrent/default/TaskImpl.scala) | 0 | ||||
-rw-r--r-- | src/library/scala/concurrent/impl/AbstractPromise.java (renamed from src/library/scala/concurrent/akka/AbstractPromise.java) | 2 | ||||
-rw-r--r-- | src/library/scala/concurrent/impl/ExecutionContextImpl.scala (renamed from src/library/scala/concurrent/akka/ExecutionContextImpl.scala) | 4 | ||||
-rw-r--r-- | src/library/scala/concurrent/impl/Future.scala (renamed from src/library/scala/concurrent/akka/Future.scala) | 2 | ||||
-rw-r--r-- | src/library/scala/concurrent/impl/Promise.scala (renamed from src/library/scala/concurrent/akka/Promise.scala) | 3 | ||||
-rw-r--r-- | src/library/scala/concurrent/impl/package.scala (renamed from src/library/scala/concurrent/akka/package.scala) | 2 | ||||
-rw-r--r-- | src/library/scala/concurrent/package.scala | 6 |
8 files changed, 10 insertions, 9 deletions
diff --git a/src/library/scala/concurrent/default/SchedulerImpl.scala b/src/library/scala/concurrent/default/SchedulerImpl.scala.disabled index 745d2d1a15..745d2d1a15 100644 --- a/src/library/scala/concurrent/default/SchedulerImpl.scala +++ b/src/library/scala/concurrent/default/SchedulerImpl.scala.disabled diff --git a/src/library/scala/concurrent/default/TaskImpl.scala b/src/library/scala/concurrent/default/TaskImpl.scala.disabled index 94e54cb372..94e54cb372 100644 --- a/src/library/scala/concurrent/default/TaskImpl.scala +++ b/src/library/scala/concurrent/default/TaskImpl.scala.disabled diff --git a/src/library/scala/concurrent/akka/AbstractPromise.java b/src/library/scala/concurrent/impl/AbstractPromise.java index 38c74edf2f..5280d67854 100644 --- a/src/library/scala/concurrent/akka/AbstractPromise.java +++ b/src/library/scala/concurrent/impl/AbstractPromise.java @@ -6,7 +6,7 @@ ** |/ ** \* */ -package scala.concurrent.akka; +package scala.concurrent.impl; diff --git a/src/library/scala/concurrent/akka/ExecutionContextImpl.scala b/src/library/scala/concurrent/impl/ExecutionContextImpl.scala index 2bc846ba3c..af0eb66292 100644 --- a/src/library/scala/concurrent/akka/ExecutionContextImpl.scala +++ b/src/library/scala/concurrent/impl/ExecutionContextImpl.scala @@ -6,7 +6,7 @@ ** |/ ** \* */ -package scala.concurrent.akka +package scala.concurrent.impl @@ -93,7 +93,7 @@ class ExecutionContextImpl(executorService: ExecutorService) extends ExecutionCo _taskStack.remove() } - private[akka] def dispatchFuture(task: () => Unit, force: Boolean = false): Unit = + private[impl] def dispatchFuture(task: () => Unit, force: Boolean = false): Unit = _taskStack.get match { case stack if (stack ne null) && !force => stack push task case _ => this.execute( diff --git a/src/library/scala/concurrent/akka/Future.scala b/src/library/scala/concurrent/impl/Future.scala index 2633e751bd..3664241ec0 100644 --- a/src/library/scala/concurrent/akka/Future.scala +++ b/src/library/scala/concurrent/impl/Future.scala @@ -6,7 +6,7 @@ ** |/ ** \* */ -package scala.concurrent.akka +package scala.concurrent.impl diff --git a/src/library/scala/concurrent/akka/Promise.scala b/src/library/scala/concurrent/impl/Promise.scala index 8ecffec2aa..3f9970b178 100644 --- a/src/library/scala/concurrent/akka/Promise.scala +++ b/src/library/scala/concurrent/impl/Promise.scala @@ -6,7 +6,7 @@ ** |/ ** \* */ -package scala.concurrent.akka +package scala.concurrent.impl @@ -21,6 +21,7 @@ import scala.annotation.tailrec //import scala.concurrent.NonDeterministic + trait Promise[T] extends scala.concurrent.Promise[T] with Future[T] { def future = this diff --git a/src/library/scala/concurrent/akka/package.scala b/src/library/scala/concurrent/impl/package.scala index 8c059b8e71..72add73167 100644 --- a/src/library/scala/concurrent/akka/package.scala +++ b/src/library/scala/concurrent/impl/package.scala @@ -15,7 +15,7 @@ import scala.util.Duration -package object akka { +package object impl { private val toBoxed = Map[Class[_], Class[_]]( classOf[Boolean] -> classOf[jl.Boolean], diff --git a/src/library/scala/concurrent/package.scala b/src/library/scala/concurrent/package.scala index 35b8cf6664..0725332c5e 100644 --- a/src/library/scala/concurrent/package.scala +++ b/src/library/scala/concurrent/package.scala @@ -25,12 +25,12 @@ package object concurrent { /** A global execution environment for executing lightweight tasks. */ lazy val executionContext = - new akka.ExecutionContextImpl(java.util.concurrent.Executors.newCachedThreadPool()) + new impl.ExecutionContextImpl(java.util.concurrent.Executors.newCachedThreadPool()) /** A global service for scheduling tasks for execution. */ - lazy val scheduler = - new default.SchedulerImpl + // lazy val scheduler = + // new default.SchedulerImpl val handledFutureException: PartialFunction[Throwable, Throwable] = { case t: Throwable if isFutureThrowable(t) => t |