Author: dblevins
Date: Mon Aug 20 17:29:52 2012
New Revision: 1375121
URL: http://svn.apache.org/viewvc?rev=1375121&view=rev
Log:
TimeUnit should default to SECONDS
OPENEJB-1895 - Refactored @Asynchronous support
TOMEE-382 - configuration for asynch task pool
Modified:
openejb/trunk/openejb/container/openejb-core/src/main/java/org/apache/openejb/async/AsynchronousPool.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=1375121&r1=1375120&r2=1375121&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:29:52 2012
@@ -48,11 +48,12 @@ public class AsynchronousPool {
public AsynchronousPool(String id, int corePoolSize, int maximumPoolSize,
Duration keepAliveTime) {
this.blockingQueue = new LinkedBlockingQueue<Runnable>();
+ final TimeUnit unit = (keepAliveTime.getUnit() != null) ?
keepAliveTime.getUnit() : TimeUnit.SECONDS;
this.executor = new ThreadPoolExecutor(
corePoolSize,
maximumPoolSize,
keepAliveTime.getTime(),
- keepAliveTime.getUnit(), blockingQueue, new
DaemonThreadFactory("@Asynchronous", id));
+ unit, blockingQueue, new DaemonThreadFactory("@Asynchronous",
id));
}
public static AsynchronousPool create(AppContext appContext) {
