org.mule.config
Class MutableThreadingProfile

java.lang.Object
  extended by org.mule.config.MutableThreadingProfile
All Implemented Interfaces:
ThreadingProfile, MuleContextAware

public class MutableThreadingProfile
extends Object
implements ThreadingProfile

Partial mutability for a threading profile. A typical use case for this class is to copy an existing immutable threading profile via a copying constructor, modify values and reconfigure a thread pool (if the latter supports it).

The following parameters are copied locally and can be modified directly:

The following parameters re-use the same object reference as the original threading profile and are not deep clones of those:


Nested Class Summary
 
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
MutableThreadingProfile(ThreadingProfile tp)
           
 
Method Summary
 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 muleContext)
           
 void setPoolExhaustedAction(int poolExhaustedAction)
           
 void setRejectedExecutionHandler(RejectedExecutionHandler rejectedExecutionHandler)
           
 void setThreadFactory(ThreadFactory threadFactory)
           
 void setThreadTTL(long threadTTL)
           
 void setThreadWaitTimeout(long threadWaitTimeout)
           
 void setWorkManagerFactory(ThreadingProfile.WorkManagerFactory workManagerFactory)
           
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

MutableThreadingProfile

public MutableThreadingProfile(ThreadingProfile tp)
Method Detail

createPool

public ExecutorService createPool()
Specified by:
createPool in interface ThreadingProfile

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 poolExhaustedAction)
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(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 muleContext)
Specified by:
setMuleContext in interface MuleContextAware

getMuleContext

public MuleContext getMuleContext()
Specified by:
getMuleContext in interface ThreadingProfile


Copyright © 2003-2014 MuleSoft, Inc.. All Rights Reserved.