com.revolsys.parallel.process

Class AbstractOutProcess<T>

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

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

All Implemented Interfaces:

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

Direct Known Subclasses:

IterableProcess, ReaderProcess

public abstract class AbstractOutProcess<T>
extends AbstractProcess
implements OutProcess<T>

Constructor Summary

Constructors

Constructor and Description
AbstractOutProcess()
AbstractOutProcess(Channel<T> out)
AbstractOutProcess(int outBufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	destroy()
Channel<T>	getOut()
int	getOutBufferSize()
protected void	init()
void	run()
protected abstract void	run(Channel<T> out)
void	setOut(Channel<T> out)
void	setOutBufferSize(int outBufferSize)

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

AbstractOutProcess

public AbstractOutProcess()

AbstractOutProcess

public AbstractOutProcess(Channel<T> out)

AbstractOutProcess

public AbstractOutProcess(int outBufferSize)

Method Detail

destroy

protected void destroy()

getOut

public Channel<T> getOut()

Specified by:

getOut in interface OutProcess<T>

Returns:

the out

getOutBufferSize

public int getOutBufferSize()

init

protected void init()

run

public final void run()

Specified by:

run in interface Runnable

run

protected abstract void run(Channel<T> out)

setOut

public void setOut(Channel<T> out)

Specified by:

setOut in interface OutProcess<T>

Parameters:

out - the out to set

setOutBufferSize

public void setOutBufferSize(int outBufferSize)