|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
public interface ThreadingProfile
Mule uses a few different pools i.e. for service threads and message dispatchers.
This interface makes it easier to configure the pool. Pools are created via
ImmutableThreadingProfile.createPool(String)
(which should really be a
separate factory).
ImmutableThreadingProfile
is a simple read-only implementation that makes
a local copy of any ThreadingProfile instance passed to a constructor.
ChainedThreadingProfile
is a mutable implementation that can take default
values from an existing ThreadingProfile. The default values can be either dynamic
(read whenever the value is queried) or static (a local copy of the default is
made when the profile is first constructed).
Nested Class Summary | |
---|---|
static interface |
ThreadingProfile.WorkManagerFactory
|
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 int |
DEFAULT_POOL_EXHAUST_ACTION
Default action to perform on pool exhaustion |
static long |
DEFAULT_THREAD_WAIT_TIMEOUT
Default value for DEFAULT_THREAD_WAIT_TIMEOUT |
static ThreadingProfile |
DEFAULT_THREADING_PROFILE
|
static Map<?,?> |
POOL_EXHAUSTED_ACTIONS
|
static int |
WHEN_EXHAUSTED_ABORT
|
static int |
WHEN_EXHAUSTED_DISCARD
|
static int |
WHEN_EXHAUSTED_DISCARD_OLDEST
|
static int |
WHEN_EXHAUSTED_RUN
|
static int |
WHEN_EXHAUSTED_WAIT
Actions to perform on pool exhaustion |
Methods inherited from interface org.mule.api.context.MuleContextAware |
---|
setMuleContext |
Field Detail |
---|
static final int DEFAULT_MAX_THREADS_ACTIVE
static final int DEFAULT_MAX_THREADS_IDLE
static final int DEFAULT_MAX_BUFFER_SIZE
static final long DEFAULT_MAX_THREAD_TTL
static final long DEFAULT_THREAD_WAIT_TIMEOUT
static final boolean DEFAULT_DO_THREADING
static final int WHEN_EXHAUSTED_WAIT
static final int WHEN_EXHAUSTED_DISCARD
static final int WHEN_EXHAUSTED_DISCARD_OLDEST
static final int WHEN_EXHAUSTED_ABORT
static final int WHEN_EXHAUSTED_RUN
static final int DEFAULT_POOL_EXHAUST_ACTION
static final Map<?,?> POOL_EXHAUSTED_ACTIONS
static final ThreadingProfile DEFAULT_THREADING_PROFILE
Method Detail |
---|
int getMaxThreadsActive()
int getMaxThreadsIdle()
long getThreadTTL()
long getThreadWaitTimeout()
int getPoolExhaustedAction()
RejectedExecutionHandler getRejectedExecutionHandler()
ThreadFactory getThreadFactory()
void setMaxThreadsActive(int maxThreadsActive)
void setMaxThreadsIdle(int maxThreadsIdle)
void setThreadTTL(long threadTTL)
void setThreadWaitTimeout(long threadWaitTimeout)
void setPoolExhaustedAction(int poolExhaustPolicy)
void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
void setThreadFactory(ThreadFactory threadFactory)
int getMaxBufferSize()
void setMaxBufferSize(int maxBufferSize)
ThreadingProfile.WorkManagerFactory getWorkManagerFactory()
void setWorkManagerFactory(ThreadingProfile.WorkManagerFactory workManagerFactory)
WorkManager createWorkManager(String name, int shutdownTimeout)
ExecutorService createPool()
ExecutorService createPool(String name)
boolean isDoThreading()
void setDoThreading(boolean doThreading)
ThreadPoolFactory getPoolFactory()
MuleContext getMuleContext()
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |