Package org.apache.axis2.transport.base.threads

Class WorkerPoolFactory

java.lang.Object

org.apache.axis2.transport.base.threads.WorkerPoolFactory

public class WorkerPoolFactory
extends Object

Worker pool factory. For the moment this always creates NativeWorkerPool instances since we assume that we are running on Java 1.5 or above.

Constructor Summary

Constructors

Constructor	Description
WorkerPoolFactory()

Method Summary

Modifier and Type	Method	Description
static WorkerPool	getWorkerPool(int core, int max, int keepAlive, int queueLength, int waterMark, String threadGroupName, String threadGroupId)
static WorkerPool	getWorkerPool(int core, int max, int keepAlive, int queueLength, String threadGroupName, String threadGroupId)
static WorkerPool	getWorkerPool(int core, int max, int keepAlive, int queueLength, String threadGroupName, String threadGroupId, BlockingQueue<Runnable> queue)

Methods inherited from class java.lang.Object

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

Constructor Detail

WorkerPoolFactory

public WorkerPoolFactory()

Method Detail

getWorkerPool

public static WorkerPool getWorkerPool(int core,
                                       int max,
                                       int keepAlive,
                                       int queueLength,
                                       String threadGroupName,
                                       String threadGroupId)

getWorkerPool

public static WorkerPool getWorkerPool(int core,
                                       int max,
                                       int keepAlive,
                                       int queueLength,
                                       int waterMark,
                                       String threadGroupName,
                                       String threadGroupId)

getWorkerPool

public static WorkerPool getWorkerPool(int core,
                                       int max,
                                       int keepAlive,
                                       int queueLength,
                                       String threadGroupName,
                                       String threadGroupId,
                                       BlockingQueue<Runnable> queue)