diff options
Diffstat (limited to 'src/actors')
-rw-r--r-- | src/actors/scala/actors/FJTaskScheduler2.scala | 6 | ||||
-rw-r--r-- | src/actors/scala/actors/Scheduler.scala | 4 |
2 files changed, 5 insertions, 5 deletions
diff --git a/src/actors/scala/actors/FJTaskScheduler2.scala b/src/actors/scala/actors/FJTaskScheduler2.scala index c797279602..a7b63aa795 100644 --- a/src/actors/scala/actors/FJTaskScheduler2.scala +++ b/src/actors/scala/actors/FJTaskScheduler2.scala @@ -14,7 +14,7 @@ import scala.collection.mutable.{ArrayBuffer, Buffer, HashMap, Queue, Stack, Has * @version 0.9.9 * @author Philipp Haller */ -class FJTaskScheduler2(core: Int, max: Int) extends Thread with IScheduler { +class FJTaskScheduler2 extends Thread with IScheduler { // as long as this thread runs, JVM should not exit setDaemon(false) @@ -26,11 +26,11 @@ class FJTaskScheduler2(core: Int, max: Int) extends Thread with IScheduler { val initCoreSize = if (null ne coreProp) Integer.parseInt(coreProp) - else core + else 4 val maxSize = if (null ne maxProp) Integer.parseInt(maxProp) - else max + else 256 private var coreSize = initCoreSize diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala index 6c71841ef5..64478262ea 100644 --- a/src/actors/scala/actors/Scheduler.scala +++ b/src/actors/scala/actors/Scheduler.scala @@ -28,7 +28,7 @@ import scala.collection.mutable.{ArrayBuffer, Buffer, HashMap, Queue, Stack, Has object Scheduler { private var sched: IScheduler = { - var s: IScheduler = new FJTaskScheduler2(4, 256) + var s: IScheduler = new FJTaskScheduler2 s.start() s } @@ -50,7 +50,7 @@ object Scheduler { def restart(): Unit = synchronized { sched = { - var s: IScheduler = new FJTaskScheduler2(4, 256) + var s: IScheduler = new FJTaskScheduler2 s.asInstanceOf[FJTaskScheduler2].setPendingCount(pendingCount) s.start() s |