summaryrefslogtreecommitdiff
path: root/src/library
diff options
context:
space:
mode:
authorAleksandar Prokopec <axel22@gmail.com>2012-02-16 13:47:59 +0100
committerAleksandar Prokopec <axel22@gmail.com>2012-02-16 17:51:09 +0100
commitab84c8d9a97b41728e77f7808eda2748d052ca06 (patch)
treec56341a3ec7b4a7032574500784a8389feac9581 /src/library
parent53b05bb12f5a7a50448bcac9434389bf95273c45 (diff)
downloadscala-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/library')
-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.scala6
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