summaryrefslogtreecommitdiff
path: root/src/actors/scala/actors/SimpleExecutorScheduler.scala
diff options
context:
space:
mode:
Diffstat (limited to 'src/actors/scala/actors/SimpleExecutorScheduler.scala')
-rw-r--r--src/actors/scala/actors/SimpleExecutorScheduler.scala5
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) {}