org.mule.config

Class ImmutableThreadingProfile

java.lang.Object

org.mule.config.ImmutableThreadingProfile

All Implemented Interfaces:

ThreadingProfile, MuleContextAware

public class ImmutableThreadingProfile
extends Object
implements ThreadingProfile

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ImmutableThreadingProfile.DefaultWorkManagerFactory

Nested classes/interfaces inherited from interface org.mule.api.config.ThreadingProfile

ThreadingProfile.WorkManagerFactory

Field Summary

Fields inherited from interface org.mule.api.config.ThreadingProfile

DEFAULT_DO_THREADING, DEFAULT_MAX_BUFFER_SIZE, DEFAULT_MAX_THREAD_TTL, DEFAULT_MAX_THREADS_ACTIVE, DEFAULT_MAX_THREADS_IDLE, DEFAULT_POOL_EXHAUST_ACTION, DEFAULT_THREAD_WAIT_TIMEOUT, DEFAULT_THREADING_PROFILE, POOL_EXHAUSTED_ACTIONS, WHEN_EXHAUSTED_ABORT, WHEN_EXHAUSTED_DISCARD, WHEN_EXHAUSTED_DISCARD_OLDEST, WHEN_EXHAUSTED_RUN, WHEN_EXHAUSTED_WAIT

Constructor Summary

Constructors

Constructor and Description
ImmutableThreadingProfile(int maxThreadsActive, int maxThreadsIdle, int maxBufferSize, long threadTTL, long threadWaitTimeout, int poolExhaustedAction, boolean doThreading, RejectedExecutionHandler rejectedExecutionHandler, ThreadFactory threadFactory)
ImmutableThreadingProfile(ThreadingProfile tp)

Method Summary

Methods

Modifier and Type	Method and Description
ExecutorService	createPool()
ExecutorService	createPool(String name)
ScheduledExecutorService	createScheduledPool(String name)
WorkManager	createWorkManager(String name, int shutdownTimeout)
int	getMaxBufferSize()
int	getMaxThreadsActive()
int	getMaxThreadsIdle()
MuleContext	getMuleContext()
int	getPoolExhaustedAction()
ThreadPoolFactory	getPoolFactory()
RejectedExecutionHandler	getRejectedExecutionHandler()
ThreadFactory	getThreadFactory()
long	getThreadTTL()
long	getThreadWaitTimeout()
ThreadingProfile.WorkManagerFactory	getWorkManagerFactory()
boolean	isDoThreading()
void	setDoThreading(boolean doThreading)
void	setMaxBufferSize(int maxBufferSize)
void	setMaxThreadsActive(int maxThreadsActive)
void	setMaxThreadsIdle(int maxThreadsIdle)
void	setMuleContext(MuleContext context)
void	setPoolExhaustedAction(int poolExhaustPolicy)
void	setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
void	setThreadFactory(ThreadFactory threadFactory)
void	setThreadTTL(long threadTTL)
void	setThreadWaitTimeout(long threadWaitTimeout)
void	setWorkManagerFactory(ThreadingProfile.WorkManagerFactory workManagerFactory)
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

ImmutableThreadingProfile

public ImmutableThreadingProfile(int maxThreadsActive,
                         int maxThreadsIdle,
                         int maxBufferSize,
                         long threadTTL,
                         long threadWaitTimeout,
                         int poolExhaustedAction,
                         boolean doThreading,
                         RejectedExecutionHandler rejectedExecutionHandler,
                         ThreadFactory threadFactory)

ImmutableThreadingProfile

public ImmutableThreadingProfile(ThreadingProfile tp)

Method Detail

getMaxThreadsActive

public int getMaxThreadsActive()

Specified by:

getMaxThreadsActive in interface ThreadingProfile

getMaxThreadsIdle

public int getMaxThreadsIdle()

Specified by:

getMaxThreadsIdle in interface ThreadingProfile

getThreadTTL

public long getThreadTTL()

Specified by:

getThreadTTL in interface ThreadingProfile

getThreadWaitTimeout

public long getThreadWaitTimeout()

Specified by:

getThreadWaitTimeout in interface ThreadingProfile

getPoolExhaustedAction

public int getPoolExhaustedAction()

Specified by:

getPoolExhaustedAction in interface ThreadingProfile

getRejectedExecutionHandler

public RejectedExecutionHandler getRejectedExecutionHandler()

Specified by:

getRejectedExecutionHandler in interface ThreadingProfile

getThreadFactory

public ThreadFactory getThreadFactory()

Specified by:

getThreadFactory in interface ThreadingProfile

setMaxThreadsActive

public void setMaxThreadsActive(int maxThreadsActive)

Specified by:

setMaxThreadsActive in interface ThreadingProfile

setMaxThreadsIdle

public void setMaxThreadsIdle(int maxThreadsIdle)

Specified by:

setMaxThreadsIdle in interface ThreadingProfile

setThreadTTL

public void setThreadTTL(long threadTTL)

Specified by:

setThreadTTL in interface ThreadingProfile

setThreadWaitTimeout

public void setThreadWaitTimeout(long threadWaitTimeout)

Specified by:

setThreadWaitTimeout in interface ThreadingProfile

setPoolExhaustedAction

public void setPoolExhaustedAction(int poolExhaustPolicy)

Specified by:

setPoolExhaustedAction in interface ThreadingProfile

setRejectedExecutionHandler

public void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)

Specified by:

setRejectedExecutionHandler in interface ThreadingProfile

setThreadFactory

public void setThreadFactory(ThreadFactory threadFactory)

Specified by:

setThreadFactory in interface ThreadingProfile

getMaxBufferSize

public int getMaxBufferSize()

Specified by:

getMaxBufferSize in interface ThreadingProfile

setMaxBufferSize

public void setMaxBufferSize(int maxBufferSize)

Specified by:

setMaxBufferSize in interface ThreadingProfile

getWorkManagerFactory

public ThreadingProfile.WorkManagerFactory getWorkManagerFactory()

Specified by:

getWorkManagerFactory in interface ThreadingProfile

setWorkManagerFactory

public void setWorkManagerFactory(ThreadingProfile.WorkManagerFactory workManagerFactory)

Specified by:

setWorkManagerFactory in interface ThreadingProfile

createWorkManager

public WorkManager createWorkManager(String name,
                            int shutdownTimeout)

Specified by:

createWorkManager in interface ThreadingProfile

createPool

public ExecutorService createPool()

Specified by:

createPool in interface ThreadingProfile

createPool

public ExecutorService createPool(String name)

Specified by:

createPool in interface ThreadingProfile

isDoThreading

public boolean isDoThreading()

Specified by:

isDoThreading in interface ThreadingProfile

setDoThreading

public void setDoThreading(boolean doThreading)

Specified by:

setDoThreading in interface ThreadingProfile

getPoolFactory

public ThreadPoolFactory getPoolFactory()

Specified by:

getPoolFactory in interface ThreadingProfile

createScheduledPool

public ScheduledExecutorService createScheduledPool(String name)

Specified by:

createScheduledPool in interface ThreadingProfile

setMuleContext

public void setMuleContext(MuleContext context)

Specified by:

setMuleContext in interface MuleContextAware

getMuleContext

public MuleContext getMuleContext()

Specified by:

getMuleContext in interface ThreadingProfile

toString

public String toString()

Overrides:

toString in class Object