summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorPhilipp Haller <hallerp@gmail.com>2009-05-29 16:32:40 +0000
committerPhilipp Haller <hallerp@gmail.com>2009-05-29 16:32:40 +0000
commit84aabc85f18294803213e91c8c3ff8ae5f18ff5b (patch)
treeab6455eccfcfb9a70a8b7c5c6d173b1e6ff63a72
parent7487070c4a8dcfee78b6f3647b477347a95f02b4 (diff)
downloadscala-84aabc85f18294803213e91c8c3ff8ae5f18ff5b.tar.gz
scala-84aabc85f18294803213e91c8c3ff8ae5f18ff5b.tar.bz2
scala-84aabc85f18294803213e91c8c3ff8ae5f18ff5b.zip
Null pointer check and disabled optimization.
-rw-r--r--src/actors/scala/actors/Scheduler.scala12
1 files changed, 9 insertions, 3 deletions
diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala
index c7edf8bedf..b6a12b46c8 100644
--- a/src/actors/scala/actors/Scheduler.scala
+++ b/src/actors/scala/actors/Scheduler.scala
@@ -63,13 +63,16 @@ object Scheduler extends IScheduler {
s
}
//Actor.timer = new java.util.Timer
- while (!tasks.isEmpty()) {
- sched.execute(tasks.take().asInstanceOf[FJTask])
+ if (tasks ne null) {
+ while (!tasks.isEmpty()) {
+ sched.execute(tasks.take().asInstanceOf[FJTask])
+ }
+ tasks = null
}
- tasks = null
}
def execute(task: Runnable) {
+/*
val t = currentThread
if (t.isInstanceOf[FJTaskRunner]) {
val tr = t.asInstanceOf[FJTaskRunner]
@@ -77,10 +80,12 @@ object Scheduler extends IScheduler {
def run() { task.run() }
})
} else
+*/
sched execute task
}
def execute(fun: => Unit) {
+/*
val t = currentThread
if (t.isInstanceOf[FJTaskRunner]) {
val tr = t.asInstanceOf[FJTaskRunner]
@@ -88,6 +93,7 @@ object Scheduler extends IScheduler {
def run() { fun }
})
} else
+*/
sched execute { fun }
}