diff options
author | Philipp Haller <hallerp@gmail.com> | 2009-05-29 16:32:40 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2009-05-29 16:32:40 +0000 |
commit | 84aabc85f18294803213e91c8c3ff8ae5f18ff5b (patch) | |
tree | ab6455eccfcfb9a70a8b7c5c6d173b1e6ff63a72 | |
parent | 7487070c4a8dcfee78b6f3647b477347a95f02b4 (diff) | |
download | scala-84aabc85f18294803213e91c8c3ff8ae5f18ff5b.tar.gz scala-84aabc85f18294803213e91c8c3ff8ae5f18ff5b.tar.bz2 scala-84aabc85f18294803213e91c8c3ff8ae5f18ff5b.zip |
Null pointer check and disabled optimization.
-rw-r--r-- | src/actors/scala/actors/Scheduler.scala | 12 |
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 } } |