summaryrefslogtreecommitdiff
path: root/src/actors/scala/actors/Scheduler.scala
diff options
context:
space:
mode:
authorPhilipp Haller <hallerp@gmail.com>2009-12-03 14:49:39 +0000
committerPhilipp Haller <hallerp@gmail.com>2009-12-03 14:49:39 +0000
commit7feaefb229d567a5f56e8a29746d49db77f63314 (patch)
tree435ac9447d4c9168085bbfb1f9fb2643433e656f /src/actors/scala/actors/Scheduler.scala
parent43d9fc12486e4e26be18eb0251c3479e9f559cd9 (diff)
downloadscala-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.scala21
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