svn commit: r1375132 - in /openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb: async/AsynchronousPool.java util/DaemonThreadFactory.java

[rmannibucau]

Author: rmannibucau
Date: Mon Aug 20 17:38:50 2012
New Revision: 1375132

URL: http://svn.apache.org/viewvc?rev=1375132&view=rev
Log:
max pool size should be >= core pool size + some cosmetic for thread name of 
async pool

Modified:
    
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/async/AsynchronousPool.java
    
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/util/DaemonThreadFactory.java

Modified: 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/async/AsynchronousPool.java
URL: 
http://svn.apache.org/viewvc/openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/async/AsynchronousPool.java?rev=1375132&r1=1375131&r2=1375132&view=diff
==============================================================================
--- 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/async/AsynchronousPool.java
 (original)
+++ 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/async/AsynchronousPool.java
 Mon Aug 20 17:38:50 2012
@@ -61,7 +61,7 @@ public class AsynchronousPool {
 
         final String id = appContext.getId();
         final int corePoolSize = options.get("AsynchronousPool.CorePoolSize", 
10);
-        final int maximumPoolSize = 
options.get("AsynchronousPool.MaximumPoolSize", 20);
+        final int maximumPoolSize = 
Math.max(options.get("AsynchronousPool.MaximumPoolSize", 20), corePoolSize);
         final Duration keepAliveTime = 
options.get("AsynchronousPool.KeepAliveTime", new Duration(60, 
TimeUnit.SECONDS));
 
         return new AsynchronousPool(id, corePoolSize, maximumPoolSize, 
keepAliveTime);

Modified: 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/util/DaemonThreadFactory.java
URL: 
http://svn.apache.org/viewvc/openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/util/DaemonThreadFactory.java?rev=1375132&r1=1375131&r2=1375132&view=diff
==============================================================================
--- 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/util/DaemonThreadFactory.java
 (original)
+++ 
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/util/DaemonThreadFactory.java
 Mon Aug 20 17:38:50 2012
@@ -48,7 +48,7 @@ public class DaemonThreadFactory impleme
 
     @Override
     public Thread newThread(Runnable runnable) {
-        Thread t = new Thread(runnable, (name + "-" + ids.incrementAndGet()));
+        Thread t = new Thread(runnable, name.trim() + " - " + 
ids.incrementAndGet());
         t.setDaemon(true);
         return t;
     }