Package org.openiam.concurrent
Class OpenIAMThreadPoolTaskExecutor
- java.lang.Object
-
- org.springframework.util.CustomizableThreadCreator
-
- org.springframework.scheduling.concurrent.CustomizableThreadFactory
-
- org.springframework.scheduling.concurrent.ExecutorConfigurationSupport
-
- org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
- org.openiam.concurrent.OpenIAMThreadPoolTaskExecutor
-
- All Implemented Interfaces:
Serializable,Executor,ThreadFactory,org.springframework.beans.factory.Aware,org.springframework.beans.factory.BeanNameAware,org.springframework.beans.factory.DisposableBean,org.springframework.beans.factory.InitializingBean,org.springframework.core.task.AsyncListenableTaskExecutor,org.springframework.core.task.AsyncTaskExecutor,org.springframework.core.task.TaskExecutor,org.springframework.scheduling.SchedulingTaskExecutor
public class OpenIAMThreadPoolTaskExecutor extends org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description OpenIAMThreadPoolTaskExecutor(AuditLogSupplier auditLogSupplier)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ThreadPoolExecutorgetThreadPoolExecutor()protected ExecutorServiceinitializeExecutor(ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler)voidsetAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)voidsetQueueCapacity(int queueCapacity)voidsetRequestorIDProvider(SecurityInfoProvider requestorIDProvider)-
Methods inherited from class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
cancelRemainingTask, createQueue, execute, execute, getActiveCount, getCorePoolSize, getKeepAliveSeconds, getMaxPoolSize, getPoolSize, getQueueCapacity, getQueueSize, setCorePoolSize, setKeepAliveSeconds, setMaxPoolSize, setPrestartAllCoreThreads, setTaskDecorator, submit, submit, submitListenable, submitListenable
-
Methods inherited from class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport
afterPropertiesSet, destroy, initialize, setAwaitTerminationMillis, setAwaitTerminationSeconds, setBeanName, setRejectedExecutionHandler, setThreadFactory, setThreadNamePrefix, setWaitForTasksToCompleteOnShutdown, shutdown
-
Methods inherited from class org.springframework.scheduling.concurrent.CustomizableThreadFactory
newThread
-
Methods inherited from class org.springframework.util.CustomizableThreadCreator
createThread, getDefaultThreadNamePrefix, getThreadGroup, getThreadNamePrefix, getThreadPriority, isDaemon, nextThreadName, setDaemon, setThreadGroup, setThreadGroupName, setThreadPriority
-
-
-
-
Constructor Detail
-
OpenIAMThreadPoolTaskExecutor
public OpenIAMThreadPoolTaskExecutor(AuditLogSupplier auditLogSupplier)
-
-
Method Detail
-
initializeExecutor
protected ExecutorService initializeExecutor(ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler)
- Overrides:
initializeExecutorin classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
getThreadPoolExecutor
public ThreadPoolExecutor getThreadPoolExecutor() throws IllegalStateException
- Overrides:
getThreadPoolExecutorin classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor- Throws:
IllegalStateException
-
setQueueCapacity
public void setQueueCapacity(int queueCapacity)
- Overrides:
setQueueCapacityin classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
setAllowCoreThreadTimeOut
public void setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)
- Overrides:
setAllowCoreThreadTimeOutin classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
setRequestorIDProvider
public void setRequestorIDProvider(SecurityInfoProvider requestorIDProvider)
-
-