org.oddjob.framework.extend

Class SimultaneousStructural

java.lang.Object

org.oddjob.framework.extend.BaseComponent

org.oddjob.framework.extend.BasePrimary

org.oddjob.framework.extend.StructuralJob<java.lang.Object>

org.oddjob.framework.extend.SimultaneousStructural

All Implemented Interfaces:

java.io.Serializable, java.lang.Runnable, ArooaContextAware, ArooaSessionAware, Forceable, PropertyChangeNotifier, Iconic, LogEnabled, Resettable, Stateful, Stoppable, Structural

Direct Known Subclasses:

ParallelJob, StateReflector

public abstract class SimultaneousStructural
extends StructuralJob<java.lang.Object>
implements Stoppable

An abstract base class for Structural jobs where all child jobs can run simultaneously.

See Also:

Serialized Form

Author:

rob

Field Summary

Fields inherited from class org.oddjob.framework.extend.StructuralJob

childHelper, destroy, stop, structuralState

Constructor Summary

Constructors

Constructor and Description
SimultaneousStructural() Create a new instance.

Method Summary

Modifier and Type	Method and Description
protected void	execute() Execute this job.
java.util.concurrent.ExecutorService	getExecutorService() Getter for executor service.
boolean	isJoin() Should execution wait for all jobs to be executed before returning to calling code.
protected void	onStop() Allow sub classes to do something on stop.
void	setExecutorService(java.util.concurrent.ExecutorService executorService) Set the ExecutorService.
void	setJobs(int index, java.lang.Object child) Add a child job.
protected void	startChildStateReflector() Start the child state reflector.

Methods inherited from class org.oddjob.framework.extend.StructuralJob

addStructuralListener, fireDestroyedState, force, getInitialStateOp, getStateChanger, hardReset, iconHelper, isStop, onDestroy, onHardReset, onReset, onSoftReset, postStop, removeStructuralListener, run, softReset, stateHandler, stop, stopChildStateReflector, waitForChildrenOnStop

Methods inherited from class org.oddjob.framework.extend.BasePrimary

configure, getName, logger, logger, loggerName, save, setName, toString

Methods inherited from class org.oddjob.framework.extend.BaseComponent

addIconListener, addPropertyChangeListener, addStateListener, configure, destroy, firePropertyChange, getArooaSession, iconForId, initialise, lastStateEvent, onConfigured, onInitialised, removeIconListener, removePropertyChangeListener, removeStateListener, save, setArooaContext, setArooaSession

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.oddjob.Stoppable

stop

Methods inherited from interface org.oddjob.Stateful

addStateListener, lastStateEvent, removeStateListener

Constructor Detail

SimultaneousStructural

public SimultaneousStructural()

Create a new instance.

Method Detail

setExecutorService

@Inject
public void setExecutorService(java.util.concurrent.ExecutorService executorService)

Set the ExecutorService.

Property: executorService

Description: The ExecutorService to use. This will be automatically set by Oddjob.

Required: No.

Parameters:

executorService - The Executor Service.

getExecutorService

public java.util.concurrent.ExecutorService getExecutorService()

Getter for executor service.

Returns:

The executor service or null if not set.

setJobs

public void setJobs(int index,
                    java.lang.Object child)

Add a child job.

Property: jobs

Description: The child jobs.

Required: No, but pointless if missing.

Parameters:

child - A child

execute

protected void execute()
                throws java.lang.InterruptedException,
                       java.util.concurrent.ExecutionException

Description copied from class: StructuralJob

Execute this job.

Specified by:

execute in class StructuralJob<java.lang.Object>

Throws:

java.lang.InterruptedException

java.util.concurrent.ExecutionException

onStop

protected void onStop()
               throws FailedToStopException

Description copied from class: StructuralJob

Allow sub classes to do something on stop.

Overrides:

onStop in class StructuralJob<java.lang.Object>

Throws:

FailedToStopException

startChildStateReflector

protected void startChildStateReflector()

Description copied from class: StructuralJob

Start the child state reflector. Sub classes override this if they need to start the child state reflector at a different time.

Overrides:

startChildStateReflector in class StructuralJob<java.lang.Object>

isJoin

public boolean isJoin()

Should execution wait for all jobs to be executed before returning to calling code.

This property is intended to be overridden by sub classes that wish to give that choice to users.

Returns:

true for execution to wait for children. False for completion to be asynchronous.