|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectorg.mule.config.ThreadingProfile
ThreadingProfile
is used to configure a thread pool. Mule uses a few
different pools i.e. for component threds and message dispatchers. This object makes
it easier to configure the pool.
Nested Class Summary | |
static class |
ThreadingProfile.NamedThreadFactory
|
Field Summary | |
static boolean |
DEFAULT_DO_THREADING
Default value for do threading |
static int |
DEFAULT_MAX_BUFFER_SIZE
Default value for MAX_BUFFER_SIZE |
static long |
DEFAULT_MAX_THREAD_TTL
Default value for MAX_THREAD_TTL |
static int |
DEFAULT_MAX_THREADS_ACTIVE
Default value for MAX_THREADS_ACTIVE |
static int |
DEFAULT_MAX_THREADS_IDLE
Default value for MAX_THREADS_IDLE |
static byte |
DEFAULT_POOL_EXHAUST_ACTION
Default value for POOL_INITIALISATION_POLICY |
static byte |
WHEN_EXHAUSTED_ABORT
|
static byte |
WHEN_EXHAUSTED_DISCARD
|
static byte |
WHEN_EXHAUSTED_DISCARD_OLDEST
|
static byte |
WHEN_EXHAUSTED_RUN
|
static byte |
WHEN_EXHAUSTED_WAIT
|
Constructor Summary | |
ThreadingProfile()
|
|
ThreadingProfile(int maxThreadsActive,
int maxThreadsIdle,
long threadTTL,
byte poolExhaustPolicy,
PooledExecutor.BlockedExecutionHandler blockedExecutionHandler,
ThreadFactory threadFactory)
|
|
ThreadingProfile(ThreadingProfile tp)
|
Method Summary | |
void |
configurePool(PooledExecutor pool)
|
PooledExecutor |
createPool()
|
PooledExecutor |
createPool(java.lang.String name)
|
PooledExecutor.BlockedExecutionHandler |
getBlockedExecutionHandler()
|
int |
getMaxBufferSize()
|
int |
getMaxThreadsActive()
|
int |
getMaxThreadsIdle()
|
byte |
getPoolExhaustedAction()
|
ThreadFactory |
getThreadFactory()
|
long |
getThreadTTL()
|
boolean |
isDoThreading()
|
void |
setBlockedExecutionHandler(PooledExecutor.BlockedExecutionHandler blockedExecutionHandler)
|
void |
setDoThreading(boolean doThreading)
|
void |
setMaxBufferSize(int maxBufferSize)
|
void |
setMaxThreadsActive(int maxThreadsActive)
|
void |
setMaxThreadsIdle(int maxThreadsIdle)
|
void |
setPoolExhaustedAction(byte poolExhaustPolicy)
|
void |
setPoolExhaustedActionString(java.lang.String poolExhaustPolicy)
|
void |
setThreadFactory(ThreadFactory threadFactory)
|
void |
setThreadTTL(long threadTTL)
|
java.lang.String |
toString()
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait |
Field Detail |
public static final byte WHEN_EXHAUSTED_WAIT
public static final byte WHEN_EXHAUSTED_DISCARD
public static final byte WHEN_EXHAUSTED_DISCARD_OLDEST
public static final byte WHEN_EXHAUSTED_ABORT
public static final byte WHEN_EXHAUSTED_RUN
public static final int DEFAULT_MAX_THREADS_ACTIVE
public static final int DEFAULT_MAX_THREADS_IDLE
public static final int DEFAULT_MAX_BUFFER_SIZE
public static final long DEFAULT_MAX_THREAD_TTL
public static final boolean DEFAULT_DO_THREADING
public static final byte DEFAULT_POOL_EXHAUST_ACTION
Constructor Detail |
public ThreadingProfile()
public ThreadingProfile(int maxThreadsActive, int maxThreadsIdle, long threadTTL, byte poolExhaustPolicy, PooledExecutor.BlockedExecutionHandler blockedExecutionHandler, ThreadFactory threadFactory)
public ThreadingProfile(ThreadingProfile tp)
Method Detail |
public int getMaxThreadsActive()
public int getMaxThreadsIdle()
public long getThreadTTL()
public byte getPoolExhaustedAction()
public PooledExecutor.BlockedExecutionHandler getBlockedExecutionHandler()
public ThreadFactory getThreadFactory()
public void setMaxThreadsActive(int maxThreadsActive)
public void setMaxThreadsIdle(int maxThreadsIdle)
public void setThreadTTL(long threadTTL)
public void setPoolExhaustedAction(byte poolExhaustPolicy)
public void setPoolExhaustedActionString(java.lang.String poolExhaustPolicy)
public void setBlockedExecutionHandler(PooledExecutor.BlockedExecutionHandler blockedExecutionHandler)
public void setThreadFactory(ThreadFactory threadFactory)
public int getMaxBufferSize()
public void setMaxBufferSize(int maxBufferSize)
public PooledExecutor createPool()
public PooledExecutor createPool(java.lang.String name)
public void configurePool(PooledExecutor pool)
public boolean isDoThreading()
public void setDoThreading(boolean doThreading)
public java.lang.String toString()
|
|||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |