diff options
author | Philipp Haller <hallerp@gmail.com> | 2009-12-03 14:49:39 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2009-12-03 14:49:39 +0000 |
commit | 7feaefb229d567a5f56e8a29746d49db77f63314 (patch) | |
tree | 435ac9447d4c9168085bbfb1f9fb2643433e656f /src/actors/scala/actors/Scheduler.scala | |
parent | 43d9fc12486e4e26be18eb0251c3479e9f559cd9 (diff) | |
download | scala-7feaefb229d567a5f56e8a29746d49db77f63314.tar.gz scala-7feaefb229d567a5f56e8a29746d49db77f63314.tar.bz2 scala-7feaefb229d567a5f56e8a29746d49db77f63314.zip |
Use the same thread pool configuration for Daem...
Use the same thread pool configuration for DaemonScheduler.
Diffstat (limited to 'src/actors/scala/actors/Scheduler.scala')
-rw-r--r-- | src/actors/scala/actors/Scheduler.scala | 21 |
1 files changed, 2 insertions, 19 deletions
diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala index 47abf9477e..c10227a9ba 100644 --- a/src/actors/scala/actors/Scheduler.scala +++ b/src/actors/scala/actors/Scheduler.scala @@ -11,7 +11,7 @@ package scala.actors import java.util.concurrent._ -import scheduler.{DelegatingScheduler, ForkJoinScheduler, ResizableThreadPoolScheduler} +import scheduler.{DelegatingScheduler, ForkJoinScheduler, ResizableThreadPoolScheduler, ThreadPoolConfig} /** * The <code>Scheduler</code> object is used by <code>Actor</code> to @@ -24,24 +24,7 @@ object Scheduler extends DelegatingScheduler { Debug.info("initializing "+this+"...") def makeNewScheduler: IScheduler = { - val useForkJoin = try { - val fjProp = System.getProperty("actors.enableForkJoin") - if (fjProp != null) - fjProp.equals("true") - else { - val javaVersion = System.getProperty("java.version") - val jvmVendor = System.getProperty("java.vm.vendor") - Debug.info(this+": java.version = "+javaVersion) - Debug.info(this+": java.vm.vendor = "+jvmVendor) - (javaVersion.indexOf("1.6") != -1 || - javaVersion.indexOf("1.7") != -1) && - // on IBM J9 1.6 do not use ForkJoinPool - (jvmVendor.indexOf("Sun") != -1) - } - } catch { - case se: SecurityException => false - } - val sched = if (!useForkJoin) { + val sched = if (!ThreadPoolConfig.useForkJoin) { val s = new ResizableThreadPoolScheduler(false) s.start() s |