com.revolsys.parallel.process

Class AbstractInProcess<T>

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

com.revolsys.parallel.process.AbstractInProcess<T>

All Implemented Interfaces:

InProcess<T>, Process, Runnable, org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanNameAware

Direct Known Subclasses:

BaseInProcess, Delta, OrderedEqualCompareProcessor

public abstract class AbstractInProcess<T>
extends AbstractProcess
implements InProcess<T>

Constructor Summary

Constructors

Constructor and Description
AbstractInProcess()
AbstractInProcess(Channel<T> in)
AbstractInProcess(int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	destroy()
Channel<T>	getIn()
int	getInBufferSize()
protected void	init()
void	run()
protected abstract void	run(Channel<T> in)
void	setIn(Channel<T> in)
void	setInBufferSize(int inBufferSize)

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

Methods inherited from interface com.revolsys.parallel.process.Process

getBeanName, getProcessNetwork, setProcessNetwork

Methods inherited from interface org.springframework.beans.factory.BeanNameAware

setBeanName

Constructor Detail

AbstractInProcess

public AbstractInProcess()

AbstractInProcess

public AbstractInProcess(Channel<T> in)

AbstractInProcess

public AbstractInProcess(int bufferSize)

Method Detail

destroy

protected void destroy()

getIn

public Channel<T> getIn()

Specified by:

getIn in interface InProcess<T>

Returns:

the in

getInBufferSize

public int getInBufferSize()

Returns:

the bufferSize

init

protected void init()

run

public final void run()

Specified by:

run in interface Runnable

run

protected abstract void run(Channel<T> in)

setIn

public void setIn(Channel<T> in)

Specified by:

setIn in interface InProcess<T>

Parameters:

in - the in to set

setInBufferSize

public void setInBufferSize(int inBufferSize)

Parameters:

bufferSize - the bufferSize to set