svn commit: r1431461 - /openejb/trunk/openejb/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java

[rm...@apache.org]

Author: rmannibucau
Date: Thu Jan 10 16:09:54 2013
New Revision: 1431461

URL: http://svn.apache.org/viewvc?rev=1431461&view=rev
Log:
better check for threads size

Modified:
    openejb/trunk/openejb/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java

Modified: openejb/trunk/openejb/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java
URL: http://svn.apache.org/viewvc/openejb/trunk/openejb/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java?rev=1431461&r1=1431460&r2=1431461&view=diff
==============================================================================
--- openejb/trunk/openejb/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java (original)
+++ openejb/trunk/openejb/server/openejb-server/src/main/java/org/apache/openejb/server/ServicePool.java Thu Jan 10 16:09:54 2013
@@ -55,8 +55,9 @@ public class ServicePool extends ServerS
     public ServicePool(final ServerService next, int threads, int queue, final boolean block) {
         super(next);
 
-        if (threads < 1) {
-            threads = 1;
+        int core = 2;
+        if (threads < core) {
+            threads = core;
         }
 
         if (queue < 1) {
@@ -72,7 +73,7 @@ public class ServicePool extends ServerS
          is true then a final attempt is made to run the process in the current thread (the service thread).
          */
 
-        threadPool = new ThreadPoolExecutor(2, threads, 1, TimeUnit.MINUTES, new LinkedBlockingQueue<Runnable>(queue));
+        threadPool = new ThreadPoolExecutor(core, threads, 1, TimeUnit.MINUTES, new LinkedBlockingQueue<Runnable>(queue));
         threadPool.setThreadFactory(new ThreadFactory() {
 
             private final AtomicInteger i = new AtomicInteger(0);