diff options
| -rw-r--r-- | src/actors/scala/actors/Scheduler.scala | 12 |
1 files changed, 8 insertions, 4 deletions
diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala index f4fed33d94..f61d44a5a7 100644 --- a/src/actors/scala/actors/Scheduler.scala +++ b/src/actors/scala/actors/Scheduler.scala @@ -14,7 +14,6 @@ package scala.actors import compat.Platform import java.lang.{Runnable, Thread, InterruptedException} -import java.util.logging.{Logger, FileHandler, Level} import scala.collection.Set import scala.collection.mutable.{ArrayBuffer, Buffer, HashMap, Queue, Stack, HashSet} @@ -24,7 +23,7 @@ import scala.collection.mutable.{ArrayBuffer, Buffer, HashMap, Queue, Stack, Has * <code>Actor</code> to execute tasks of an execution of a * reactor. * - * @version 0.9.0 + * @version 0.9.2 * @author Philipp Haller */ object Scheduler { @@ -43,8 +42,13 @@ object Scheduler { s = if (olderThanJDK5) new TickedScheduler - else - new JDK5Scheduler(4, 32) + else { + val corePoolSize = + Integer.parseInt(java.lang.System.getProperty("actors.corePoolSize")) + val maxPoolSize = + Integer.parseInt(java.lang.System.getProperty("actors.maxPoolSize")) + new JDK5Scheduler(corePoolSize, maxPoolSize) + } s.start() s } |