org.oddjob.scheduling

Class DefaultExecutors

java.lang.Object

org.oddjob.scheduling.DefaultExecutors

All Implemented Interfaces:

OddjobExecutors, Stoppable

public class DefaultExecutors
extends java.lang.Object
implements OddjobExecutors, Stoppable

Provide Simple Oddjob Services.

Author:

rob

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	POOL_SIZE_PROPERTY

Constructor Summary

Constructors

Constructor and Description
DefaultExecutors() Create a new instance.

Method Summary

Modifier and Type	Method and Description
java.lang.String	getPoolBaseName()
java.util.concurrent.ExecutorService	getPoolExecutor() Provide a ExecutorService.
int	getPoolSize() Get the pool size for the scheduled executor.
java.util.concurrent.ScheduledExecutorService	getScheduledExecutor() Provide a ScheduledExecutorService.
boolean	isShareServices()
void	setPoolBaseName(java.lang.String poolBaseName)
void	setPoolSize(int poolSize) Set the pool size for the scheduled executor.
void	setShareServices(boolean shareServices) Share the same service between the executor service and the scheduled executor service.
void	stop() Stop the services.
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

POOL_SIZE_PROPERTY

public static final java.lang.String POOL_SIZE_PROPERTY

See Also:

Constant Field Values

Constructor Detail

DefaultExecutors

public DefaultExecutors()

Create a new instance. The scheduler is initialised with a fixed pool size that is either from the system property or based on the number of available processors discovered at runtime. The pool size can also be set by the property.

Parameters:

poolBaseName - Name that will prefix threads.

Method Detail

stop

public void stop()

Stop the services.

Specified by:

stop in interface Stoppable

getScheduledExecutor

public java.util.concurrent.ScheduledExecutorService getScheduledExecutor()

Description copied from interface: OddjobExecutors

Provide a ScheduledExecutorService.

Specified by:

getScheduledExecutor in interface OddjobExecutors

Returns:

A ScheduledExecutorService. Never null.

getPoolExecutor

public java.util.concurrent.ExecutorService getPoolExecutor()

Description copied from interface: OddjobExecutors

Provide a ExecutorService. Implementations are free to use OddjobExecutors.getScheduledExecutor() for this, or provide something different.

Specified by:

getPoolExecutor in interface OddjobExecutors

Returns:

An ExecutorService. Never null.

getPoolSize

public int getPoolSize()

Get the pool size for the scheduled executor.

Returns:

setPoolSize

public void setPoolSize(int poolSize)

Set the pool size for the scheduled executor.

Parameters:

poolSize - The pool size.

isShareServices

public boolean isShareServices()

setShareServices

public void setShareServices(boolean shareServices)

Share the same service between the executor service and the scheduled executor service.

Parameters:

shareServices -

getPoolBaseName

public java.lang.String getPoolBaseName()

setPoolBaseName

public void setPoolBaseName(java.lang.String poolBaseName)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object