org.mule.config.pool

Class DefaultThreadPoolFactory

java.lang.Object

org.mule.config.pool.ThreadPoolFactory

org.mule.config.pool.DefaultThreadPoolFactory

All Implemented Interfaces:

MuleContextAware

public class DefaultThreadPoolFactory
extends ThreadPoolFactory

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger

Fields inherited from class org.mule.config.pool.ThreadPoolFactory

muleContext

Constructor Summary

Constructors

Constructor and Description
DefaultThreadPoolFactory()

Method Summary

Methods

Modifier and Type	Method and Description
protected void	configureThreadFactory(String name, ThreadingProfile tp, ThreadPoolExecutor pool)
ThreadPoolExecutor	createPool(String name, ThreadingProfile tp)
ScheduledThreadPoolExecutor	createScheduledPool(String name, ThreadingProfile tp) By limitations of java's ScheduledThreadPoolExecutor, ThreadingProfile.getMaxThreadsActive() will be ignored and a fixed pool with ThreadingProfile.getMaxThreadsIdle() will be created.
protected ThreadPoolExecutor	internalCreatePool(String name, ThreadingProfile tp, BlockingQueue buffer)
protected ScheduledThreadPoolExecutor	internalCreateScheduledPool(ThreadingProfile tp)

Methods inherited from class org.mule.config.pool.ThreadPoolFactory

newInstance, setMuleContext

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.apache.commons.logging.Log logger

Constructor Detail

DefaultThreadPoolFactory

public DefaultThreadPoolFactory()

Method Detail

createPool

public ThreadPoolExecutor createPool(String name,
                            ThreadingProfile tp)

Specified by:

createPool in class ThreadPoolFactory

createScheduledPool

public ScheduledThreadPoolExecutor createScheduledPool(String name,
                                              ThreadingProfile tp)

Description copied from class: ThreadPoolFactory

By limitations of java's ScheduledThreadPoolExecutor, ThreadingProfile.getMaxThreadsActive() will be ignored and a fixed pool with ThreadingProfile.getMaxThreadsIdle() will be created.

Specified by:

createScheduledPool in class ThreadPoolFactory

configureThreadFactory

protected void configureThreadFactory(String name,
                          ThreadingProfile tp,
                          ThreadPoolExecutor pool)

internalCreatePool

protected ThreadPoolExecutor internalCreatePool(String name,
                                    ThreadingProfile tp,
                                    BlockingQueue buffer)

internalCreateScheduledPool

protected ScheduledThreadPoolExecutor internalCreateScheduledPool(ThreadingProfile tp)