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

protected Log

logger

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

muleContext

Constructor Summary

DefaultThreadPoolFactory()

Method Summary

protected void	configureThreadFactory(String name, ThreadingProfile tp, ThreadPoolExecutor pool)
ThreadPoolExecutor	createPool(String name, ThreadingProfile tp)
ScheduledThreadPoolExecutor	createScheduledPool(String name, ThreadingProfile tp)
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 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)

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)