diff options
author | Philipp Haller <hallerp@gmail.com> | 2009-07-02 19:18:06 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2009-07-02 19:18:06 +0000 |
commit | c044b2e8c9181507d391c59219d240353219ebef (patch) | |
tree | 1c6bd4f57db79f470863951c7bd836db6dcc8a05 /src/actors/scala/actors/Scheduler.scala | |
parent | 57e0d0250df1552bbe518cb011b4ed74fdd9b7e3 (diff) | |
download | scala-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.scala | 6 |
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 } |