com.adaptris.core.services.splitter

Class ServiceWorkerPool

java.lang.Object

com.adaptris.core.services.splitter.ServiceWorkerPool

public class ServiceWorkerPool
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ServiceWorkerPool.Worker

Constructor Summary

Constructors

Constructor and Description
ServiceWorkerPool(Service s, EventHandler eh, int maxThreads)

Method Summary

Modifier and Type	Method and Description
static void	closeQuietly(org.apache.commons.pool2.ObjectPool<?> pool)
org.apache.commons.pool2.impl.GenericObjectPool<ServiceWorkerPool.Worker>	createCommonsObjectPool()
java.util.concurrent.ExecutorService	createExecutor(java.lang.String prefix)
void	warmup(org.apache.commons.pool2.impl.GenericObjectPool<ServiceWorkerPool.Worker> objectPool)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ServiceWorkerPool

public ServiceWorkerPool(Service s,
                         EventHandler eh,
                         int maxThreads)
                  throws CoreException

Throws:

CoreException

Method Detail

createCommonsObjectPool

public org.apache.commons.pool2.impl.GenericObjectPool<ServiceWorkerPool.Worker> createCommonsObjectPool()
                                                                                                  throws CoreException

Throws:

CoreException

createExecutor

public java.util.concurrent.ExecutorService createExecutor(java.lang.String prefix)

closeQuietly

public static void closeQuietly(org.apache.commons.pool2.ObjectPool<?> pool)

warmup

public void warmup(org.apache.commons.pool2.impl.GenericObjectPool<ServiceWorkerPool.Worker> objectPool)
            throws CoreException

Throws:

CoreException