diff options
author | Philipp Haller <hallerp@gmail.com> | 2009-06-06 07:01:02 +0000 |
---|---|---|
committer | Philipp Haller <hallerp@gmail.com> | 2009-06-06 07:01:02 +0000 |
commit | a2166dec9d687347a08c9e6a95e07f1a67f0d370 (patch) | |
tree | e9ed8cdfc9576cfedb77d2c04c675951942fea49 /src/actors/scala/actors/Scheduler.scala | |
parent | c260301efef7c83d6fb8094954ae0ae555dc5b0f (diff) | |
download | scala-a2166dec9d687347a08c9e6a95e07f1a67f0d370.tar.gz scala-a2166dec9d687347a08c9e6a95e07f1a67f0d370.tar.bz2 scala-a2166dec9d687347a08c9e6a95e07f1a67f0d370.zip |
Include 1.5 backport of Java 7 ForkJoinPool.
Diffstat (limited to 'src/actors/scala/actors/Scheduler.scala')
-rw-r--r-- | src/actors/scala/actors/Scheduler.scala | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala index a7935edabf..5f5f1705e7 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,6 +33,8 @@ object Scheduler extends DelegatingScheduler { TimeUnit.MILLISECONDS, workQueue) val s = new SimpleExecutorScheduler(threadPool, true) + */ + val s = new ForkJoinScheduler s.start() s } |