diff options
Diffstat (limited to 'src/actors/scala/actors/SimpleExecutorScheduler.scala')
-rw-r--r-- | src/actors/scala/actors/SimpleExecutorScheduler.scala | 5 |
1 files changed, 3 insertions, 2 deletions
diff --git a/src/actors/scala/actors/SimpleExecutorScheduler.scala b/src/actors/scala/actors/SimpleExecutorScheduler.scala index d6b2104939..4c07ec5c5a 100644 --- a/src/actors/scala/actors/SimpleExecutorScheduler.scala +++ b/src/actors/scala/actors/SimpleExecutorScheduler.scala @@ -48,7 +48,8 @@ class SimpleExecutorScheduler(protected var executor: ExecutorService) extends I executor execute task } catch { case ree: RejectedExecutionException => - Debug.info("caught "+ree) + // run task on current thread + task.run() } } @@ -73,7 +74,7 @@ class SimpleExecutorScheduler(protected var executor: ExecutorService) extends I * has not been shut down. */ def isActive = - !executor.isShutdown() + (executor ne null) && !executor.isShutdown() def newActor(a: Actor) {} |