summaryrefslogtreecommitdiff
path: root/src/actors/scala/actors/Scheduler.scala
diff options
context:
space:
mode:
authorPhilipp Haller <hallerp@gmail.com>2009-06-06 07:01:02 +0000
committerPhilipp Haller <hallerp@gmail.com>2009-06-06 07:01:02 +0000
commita2166dec9d687347a08c9e6a95e07f1a67f0d370 (patch)
treee9ed8cdfc9576cfedb77d2c04c675951942fea49 /src/actors/scala/actors/Scheduler.scala
parentc260301efef7c83d6fb8094954ae0ae555dc5b0f (diff)
downloadscala-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.scala3
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
}