Interface SchedulerServiceProviderHolder.SchedulerProvider
- Enclosing class:
- SchedulerServiceProviderHolder
public static interface SchedulerServiceProviderHolder.SchedulerProvider
Provider for thread pools which allow scheduling capabilities. It is expected that the thread
pools entire lifecycle (start to stop) is done through the same provider instance.
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
getFixedSizeScheduler
(int minimumThreads, String poolName) getScheduler
(int minimumThreads, String poolName, int maximumPoolSize) Request to get a scheduler with a minimum number of AVAILABLE threads.Default Timeout scheduler.
-
Method Details
-
getScheduler
DynamicSizedSchedulerInterface getScheduler(int minimumThreads, String poolName, int maximumPoolSize) Request to get a scheduler with a minimum number of AVAILABLE threads.- Parameters:
minimumThreads
- Minimum number of available threads for the returned schedulerpoolName
- name of pool to identify threadsmaximumPoolSize
- maximum pool size- Returns:
- A new scheduler that is ready to accept tasks
-
getFixedSizeScheduler
-
getTimeoutScheduler
ScheduledThreadPoolExecutor getTimeoutScheduler()Default Timeout scheduler.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]
- Returns:
- A new scheduler that is ready to accept tasks
-
getBulkScheduler
ThreadPoolExecutor getBulkScheduler() -
close
void close()
-