summaryrefslogtreecommitdiff
path: root/src/actors/scala/actors/Scheduler.scala
diff options
context:
space:
mode:
authorPhilipp Haller <hallerp@gmail.com>2009-07-02 19:18:06 +0000
committerPhilipp Haller <hallerp@gmail.com>2009-07-02 19:18:06 +0000
commitc044b2e8c9181507d391c59219d240353219ebef (patch)
tree1c6bd4f57db79f470863951c7bd836db6dcc8a05 /src/actors/scala/actors/Scheduler.scala
parent57e0d0250df1552bbe518cb011b4ed74fdd9b7e3 (diff)
downloadscala-c044b2e8c9181507d391c59219d240353219ebef.tar.gz
scala-c044b2e8c9181507d391c59219d240353219ebef.tar.bz2
scala-c044b2e8c9181507d391c59219d240353219ebef.zip
Switched to ForkJoinScheduler as default.
Diffstat (limited to 'src/actors/scala/actors/Scheduler.scala')
-rw-r--r--src/actors/scala/actors/Scheduler.scala6
1 files changed, 4 insertions, 2 deletions
diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala
index abda6d329e..bd083691e0 100644
--- a/src/actors/scala/actors/Scheduler.scala
+++ b/src/actors/scala/actors/Scheduler.scala
@@ -25,6 +25,7 @@ object Scheduler extends DelegatingScheduler {
Debug.info("initializing "+this+"...")
def makeNewScheduler: IScheduler = {
+/*
val workQueue = new LinkedBlockingQueue[Runnable](100000)
val threadPool = new ThreadPoolExecutor(ThreadPoolConfig.corePoolSize,
ThreadPoolConfig.maxPoolSize,
@@ -32,8 +33,9 @@ object Scheduler extends DelegatingScheduler {
TimeUnit.MILLISECONDS,
workQueue)
val s = new SimpleExecutorScheduler(threadPool, true)
- //val s = new ForkJoinScheduler
- //Debug.info(this+": starting new "+s)
+*/
+ val s = new ForkJoinScheduler
+ Debug.info(this+": starting new "+s+" ["+s.getClass+"]")
s.start()
s
}