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 ThreadPoolExecutor
getThreadPoolExecutor()
protected ExecutorService
initializeExecutor(ThreadFactory threadFactory, RejectedExecutionHandler rejectedExecutionHandler)
void
setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)
void
setQueueCapacity(int queueCapacity)
void
setRequestorIDProvider(SecurityInfoProvider requestorIDProvider)
-
Methods inherited from class org.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
cancelRemainingTask, createQueue, execute, execute, getActiveCount, getCorePoolSize, getKeepAliveSeconds, getMaxPoolSize, getPoolSize, 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:
initializeExecutor
in classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
getThreadPoolExecutor
public ThreadPoolExecutor getThreadPoolExecutor() throws IllegalStateException
- Overrides:
getThreadPoolExecutor
in classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
- Throws:
IllegalStateException
-
setQueueCapacity
public void setQueueCapacity(int queueCapacity)
- Overrides:
setQueueCapacity
in classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
setAllowCoreThreadTimeOut
public void setAllowCoreThreadTimeOut(boolean allowCoreThreadTimeOut)
- Overrides:
setAllowCoreThreadTimeOut
in classorg.springframework.scheduling.concurrent.ThreadPoolTaskExecutor
-
setRequestorIDProvider
public void setRequestorIDProvider(SecurityInfoProvider requestorIDProvider)
-
-