public static interface SchedulerServiceProviderHolder.SchedulerProvider
Modifier and Type | Method and Description |
---|---|
void |
close() |
java.util.concurrent.ThreadPoolExecutor |
getBulkScheduler() |
java.util.concurrent.ScheduledExecutorService |
getFixedSizeScheduler(int minimumThreads,
java.lang.String poolName) |
DynamicSizedSchedulerInterface |
getScheduler(int minimumThreads,
java.lang.String poolName,
int maximumPoolSize)
Request to get a scheduler with a minimum number of AVAILABLE threads.
|
java.util.concurrent.ScheduledThreadPoolExecutor |
getTimeoutScheduler()
Default Timeout scheduler.
|
DynamicSizedSchedulerInterface getScheduler(int minimumThreads, java.lang.String poolName, int maximumPoolSize)
minimumThreads
- Minimum number of available threads for the returned schedulerpoolName
- name of pool to identify threadsmaximumPoolSize
- maximum pool sizejava.util.concurrent.ScheduledExecutorService getFixedSizeScheduler(int minimumThreads, java.lang.String poolName)
java.util.concurrent.ScheduledThreadPoolExecutor getTimeoutScheduler()
This is a one Thread fixed sized scheduler. This specific scheduler is using java 1.7 RemoveOnCancelPolicy, so the task are removed from queue permitting to avoid memory consumption [CONJ-297]
java.util.concurrent.ThreadPoolExecutor getBulkScheduler()
void close()