com.haulmont.cuba.core.sys

Class CubaThreadPoolTaskScheduler

java.lang.Object

org.springframework.util.CustomizableThreadCreator

org.springframework.scheduling.concurrent.CustomizableThreadFactory

org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler

com.haulmont.cuba.core.sys.CubaThreadPoolTaskScheduler

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.Executor, java.util.concurrent.ThreadFactory, java.util.EventListener, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean, org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>, org.springframework.core.task.AsyncListenableTaskExecutor, org.springframework.core.task.AsyncTaskExecutor, org.springframework.core.task.TaskExecutor, org.springframework.scheduling.SchedulingTaskExecutor, org.springframework.scheduling.TaskScheduler

public class CubaThreadPoolTaskScheduler
extends org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler
implements org.springframework.context.ApplicationContextAware, org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected static class	CubaThreadPoolTaskScheduler.TaskDecorator<V>

Field Summary

Fields

Modifier and Type	Field and Description
protected org.springframework.context.ApplicationContext	applicationContext
protected StatisticsAccumulator	statisticsAccumulator

Fields inherited from class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

logger

Fields inherited from interface org.springframework.core.task.AsyncTaskExecutor

TIMEOUT_IMMEDIATE, TIMEOUT_INDEFINITE

Constructor Summary

Constructors

Constructor and Description
CubaThreadPoolTaskScheduler()

Method Summary

Modifier and Type	Method and Description
protected java.util.concurrent.ScheduledExecutorService	createExecutor(int poolSize, java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)
protected <V> java.util.concurrent.RunnableScheduledFuture<V>	decorate(java.util.concurrent.Callable<V> callable, java.util.concurrent.RunnableScheduledFuture<V> task)
protected <V> java.util.concurrent.RunnableScheduledFuture<V>	decorate(java.lang.Runnable runnable, java.util.concurrent.RunnableScheduledFuture<V> task)
void	onApplicationEvent(org.springframework.context.event.ContextClosedEvent event)
void	setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
void	setStatisticsAccumulator(StatisticsAccumulator statisticsAccumulator)

Methods inherited from class org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler

cancelRemainingTask, execute, execute, getActiveCount, getPoolSize, getScheduledExecutor, getScheduledThreadPoolExecutor, initializeExecutor, isRemoveOnCancelPolicy, schedule, schedule, scheduleAtFixedRate, scheduleAtFixedRate, scheduleWithFixedDelay, scheduleWithFixedDelay, setErrorHandler, setPoolSize, setRemoveOnCancelPolicy, submit, submit, submitListenable, submitListenable

Methods inherited from class org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

afterPropertiesSet, destroy, initialize, 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.springframework.scheduling.SchedulingTaskExecutor

prefersShortLivedTasks

Methods inherited from interface org.springframework.scheduling.TaskScheduler

schedule, scheduleAtFixedRate, scheduleAtFixedRate, scheduleWithFixedDelay, scheduleWithFixedDelay

Field Detail

applicationContext

protected org.springframework.context.ApplicationContext applicationContext

statisticsAccumulator

protected StatisticsAccumulator statisticsAccumulator

Constructor Detail

CubaThreadPoolTaskScheduler

public CubaThreadPoolTaskScheduler()

Method Detail

setApplicationContext

public void setApplicationContext(org.springframework.context.ApplicationContext applicationContext)
                           throws org.springframework.beans.BeansException

Specified by:

setApplicationContext in interface org.springframework.context.ApplicationContextAware

Throws:

org.springframework.beans.BeansException

setStatisticsAccumulator

public void setStatisticsAccumulator(StatisticsAccumulator statisticsAccumulator)

createExecutor

protected java.util.concurrent.ScheduledExecutorService createExecutor(int poolSize,
                                                                       java.util.concurrent.ThreadFactory threadFactory,
                                                                       java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)

Overrides:

createExecutor in class org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler

decorate

protected <V> java.util.concurrent.RunnableScheduledFuture<V> decorate(java.lang.Runnable runnable,
                                                                       java.util.concurrent.RunnableScheduledFuture<V> task)

decorate

protected <V> java.util.concurrent.RunnableScheduledFuture<V> decorate(java.util.concurrent.Callable<V> callable,
                                                                       java.util.concurrent.RunnableScheduledFuture<V> task)

onApplicationEvent

public void onApplicationEvent(@Nonnull
                               org.springframework.context.event.ContextClosedEvent event)

Specified by:

onApplicationEvent in interface org.springframework.context.ApplicationListener<org.springframework.context.event.ContextClosedEvent>