svn commit: r1071005 - /synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java

[supun]

Author: supun
Date: Tue Feb 15 18:33:50 2011
New Revision: 1071005

URL: http://svn.apache.org/viewvc?rev=1071005&view=rev
Log:
changing the thread pool to have the default as a unbounded queue

Modified:
    
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java

Modified: 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java
URL: 
http://svn.apache.org/viewvc/synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java?rev=1071005&r1=1071004&r2=1071005&view=diff
==============================================================================
--- 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java
 (original)
+++ 
synapse/trunk/java/modules/core/src/main/java/org/apache/synapse/util/concurrent/SynapseThreadPool.java
 Tue Feb 15 18:33:50 2011
@@ -30,7 +30,7 @@ public class SynapseThreadPool extends T
     public static final int SYNAPSE_CORE_THREADS  = 20;
     public static final int SYNAPSE_MAX_THREADS   = 100;
     public static final int SYNAPSE_KEEP_ALIVE    = 5;
-    public static final int SYNAPSE_THREAD_QLEN   = 10;
+    public static final int SYNAPSE_THREAD_QLEN   = -1;
     public static final String SYNAPSE_THREAD_GROUP     = 
"synapse-thread-group";
     public static final String SYNAPSE_THREAD_ID_PREFIX = "SynapseWorker";
 
@@ -81,7 +81,7 @@ public class SynapseThreadPool extends T
     public SynapseThreadPool(int corePoolSize, int maxPoolSize, long 
keepAliveTime, int qlen,
         String threadGroup, String threadIdPrefix) {
         super(corePoolSize, maxPoolSize, keepAliveTime, TimeUnit.SECONDS,
-            new LinkedBlockingQueue<Runnable>(qlen),
+            qlen > 0 ? new LinkedBlockingQueue<Runnable>(qlen) : new 
LinkedBlockingDeque<Runnable>(),
             new SynapseThreadFactory(new ThreadGroup(threadGroup), 
threadIdPrefix));
     }
 }