Added the scala.concurrent.TaskRunner and scala...

Added the scala.concurrent.TaskRunner and
scala.concurrent.AsyncInvokable abstractions with corresponding
refactorings in scala.actors and scala.concurrent.

1 files changed, 4 insertions, 3 deletions

diff --git a/src/actors/scala/actors/Scheduler.scala b/src/actors/scala/actors/Scheduler.scala
index cb764e963b..894dbc93e8 100644
--- a/src/actors/scala/actors/Scheduler.scala
+++ b/src/actors/scala/actors/Scheduler.scala
@@ -24,12 +24,13 @@ object Scheduler extends DelegatingScheduler {
   Debug.info("initializing "+this+"...")
 
   def makeNewScheduler: IScheduler = {
-    val workQueue = new LinkedBlockingQueue[Runnable](100000)
+    val workQueue = new LinkedBlockingQueue[Runnable]
     val threadPool = new ThreadPoolExecutor(ThreadPoolConfig.corePoolSize,
                                             ThreadPoolConfig.maxPoolSize,
-                                            50L,
+                                            60000L,
                                             TimeUnit.MILLISECONDS,
-                                            workQueue)
+                                            workQueue,
+                                            new ThreadPoolExecutor.CallerRunsPolicy)
     val s = new ThreadPoolScheduler(threadPool, true)
     //val s = new ForkJoinScheduler
     Debug.info(this+": starting new "+s+" ["+s.getClass+"]")