com.revolsys.parallel.process

Class AbstractResetableProcess

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractResetableProcess

All Implemented Interfaces:

Process, Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

public abstract class AbstractResetableProcess
extends AbstractProcess

Constructor Summary

Constructors

Constructor and Description
AbstractResetableProcess()
AbstractResetableProcess(long waitTime)

Method Summary

Methods

Modifier and Type	Method and Description
protected abstract boolean	execute()
protected void	finishExecution(UUID id)
int	getExecutionCount()
String	getStatus()
long	getWaitTime()
void	hardReset() The hard reset causes the scheduler loop to restart ignoring all current executing requests.
void	pause() The pause causes the scheduler to sleep until a soft or hard reset is initiated.
protected void	postRun()
protected void	preRun()
protected void	reset()
void	run()
protected void	setStatus(String status)
void	setWaitTime(long waitTime)
void	softReset() The soft reset causes the scheduler loop to restart after all current executing requests have completed.
protected UUID	startExecution()
protected void	waitOnExecutions()

Methods inherited from class com.revolsys.parallel.process.AbstractProcess

getBeanName, getProcessNetwork, setBeanName, setProcessNetwork, stop, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractResetableProcess

public AbstractResetableProcess()

AbstractResetableProcess

public AbstractResetableProcess(long waitTime)

Method Detail

execute

protected abstract boolean execute()

finishExecution

protected void finishExecution(UUID id)

getExecutionCount

@ManagedAttribute
public int getExecutionCount()

getStatus

@ManagedAttribute
public String getStatus()

getWaitTime

public long getWaitTime()

hardReset

@ManagedOperation
public void hardReset()

The hard reset causes the scheduler loop to restart ignoring all current executing requests. Upon reset the counts of executing requests and the status of all jobs will be updated to ensure consistency.

pause

@ManagedOperation
public void pause()

The pause causes the scheduler to sleep until a soft or hard reset is initiated.

postRun

protected void postRun()

preRun

protected void preRun()

reset

protected void reset()

run

public void run()

setStatus

protected void setStatus(String status)

setWaitTime

public void setWaitTime(long waitTime)

softReset

@ManagedOperation
public void softReset()

The soft reset causes the scheduler loop to restart after all current executing requests have completed. Upon reset the counts of executing requests and the status of all jobs will be updated to ensure consistency.

startExecution

protected UUID startExecution()

waitOnExecutions

protected void waitOnExecutions()