org.springframework.scheduling.concurrent

Class ExecutorConfigurationSupport

java.lang.Object

org.springframework.util.CustomizableThreadCreator

org.springframework.scheduling.concurrent.CustomizableThreadFactory

org.springframework.scheduling.concurrent.ExecutorConfigurationSupport

All Implemented Interfaces:

java.io.Serializable, java.util.concurrent.ThreadFactory, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.DisposableBean, org.springframework.beans.factory.InitializingBean

Direct Known Subclasses:

ScheduledExecutorFactoryBean, ThreadPoolExecutorFactoryBean, ThreadPoolTaskExecutor, ThreadPoolTaskScheduler

public abstract class ExecutorConfigurationSupport
extends CustomizableThreadFactory
implements org.springframework.beans.factory.BeanNameAware, org.springframework.beans.factory.InitializingBean, org.springframework.beans.factory.DisposableBean

Base class for classes that are setting up a java.util.concurrent.ExecutorService (typically a ThreadPoolExecutor). Defines common configuration settings and common lifecycle handling.

Since:

3.0

Author:

Juergen Hoeller

See Also:

ExecutorService, Executors, ThreadPoolExecutor, Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected org.apache.commons.logging.Log	logger

Constructor Summary

Constructors

Constructor and Description
ExecutorConfigurationSupport()

Method Summary

Methods

Modifier and Type	Method and Description
void	afterPropertiesSet() Calls initialize() after the container applied all property values.
void	destroy() Calls shutdown when the BeanFactory destroys the task executor instance.
void	initialize() Set up the ExecutorService.
protected abstract java.util.concurrent.ExecutorService	initializeExecutor(java.util.concurrent.ThreadFactory threadFactory, java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler) Create the target ExecutorService instance.
void	setBeanName(java.lang.String name)
void	setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler) Set the RejectedExecutionHandler to use for the ThreadPoolExecutor.
void	setThreadFactory(java.util.concurrent.ThreadFactory threadFactory) Set the ThreadFactory to use for the ThreadPoolExecutor's thread pool.
void	setThreadNamePrefix(java.lang.String threadNamePrefix)
void	setWaitForTasksToCompleteOnShutdown(boolean waitForJobsToCompleteOnShutdown) Set whether to wait for scheduled tasks to complete on shutdown.
void	shutdown() Perform a shutdown on the ThreadPoolExecutor.

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

Field Detail

logger

protected final org.apache.commons.logging.Log logger

Constructor Detail

ExecutorConfigurationSupport

public ExecutorConfigurationSupport()

Method Detail

setThreadFactory

public void setThreadFactory(java.util.concurrent.ThreadFactory threadFactory)

Set the ThreadFactory to use for the ThreadPoolExecutor's thread pool. Default is the ThreadPoolExecutor's default thread factory.

See Also:

Executors.defaultThreadFactory()

setThreadNamePrefix

public void setThreadNamePrefix(java.lang.String threadNamePrefix)

Overrides:

setThreadNamePrefix in class org.springframework.util.CustomizableThreadCreator

setRejectedExecutionHandler

public void setRejectedExecutionHandler(java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)

Set the RejectedExecutionHandler to use for the ThreadPoolExecutor. Default is the ThreadPoolExecutor's default abort policy.

See Also:

ThreadPoolExecutor.AbortPolicy

setWaitForTasksToCompleteOnShutdown

public void setWaitForTasksToCompleteOnShutdown(boolean waitForJobsToCompleteOnShutdown)

Set whether to wait for scheduled tasks to complete on shutdown.

Default is "false". Switch this to "true" if you prefer fully completed tasks at the expense of a longer shutdown phase.

See Also:

ExecutorService.shutdown(), ExecutorService.shutdownNow()

setBeanName

public void setBeanName(java.lang.String name)

Specified by:

setBeanName in interface org.springframework.beans.factory.BeanNameAware

afterPropertiesSet

public void afterPropertiesSet()

Calls initialize() after the container applied all property values.

Specified by:

afterPropertiesSet in interface org.springframework.beans.factory.InitializingBean

See Also:

initialize()

initialize

public void initialize()

Set up the ExecutorService.

initializeExecutor

protected abstract java.util.concurrent.ExecutorService initializeExecutor(java.util.concurrent.ThreadFactory threadFactory,
                                                      java.util.concurrent.RejectedExecutionHandler rejectedExecutionHandler)

Create the target ExecutorService instance. Called by afterPropertiesSet.

Parameters:

threadFactory - the ThreadFactory to use

rejectedExecutionHandler - the RejectedExecutionHandler to use

Returns:

a new ExecutorService instance

See Also:

afterPropertiesSet()

destroy

public void destroy()

Calls shutdown when the BeanFactory destroys the task executor instance.

Specified by:

destroy in interface org.springframework.beans.factory.DisposableBean

See Also:

shutdown()

shutdown

public void shutdown()

Perform a shutdown on the ThreadPoolExecutor.

See Also:

ExecutorService.shutdown()