com.revolsys.gis.parallel

Class IterableProcess<T>

java.lang.Object

com.revolsys.parallel.process.AbstractProcess

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

com.revolsys.gis.parallel.IterableProcess<T>

All Implemented Interfaces:

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

Direct Known Subclasses:

StatisticsRecordIterableProcess

public class IterableProcess<T>
extends AbstractOutProcess<T>

Constructor Summary

Constructors

Constructor and Description
IterableProcess()
IterableProcess(Channel<T> out, Iterable<T> iterable)
IterableProcess(Iterable<T> iterable)
IterableProcess(Iterable<T> iterable, int bufferSize)

Method Summary

Methods

Modifier and Type	Method and Description
Iterable<T>	getIterable()
protected void	run(Channel<T> out)
void	setIterable(Iterable<T> iterable)
String	toString()
protected void	write(Channel<T> out, T object)

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

destroy, getOut, getOutBufferSize, init, run, setOut, setOutBufferSize

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

getBeanName, getProcessNetwork, setBeanName, setProcessNetwork, stop

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

IterableProcess

public IterableProcess()

IterableProcess

public IterableProcess(Channel<T> out,
               Iterable<T> iterable)

IterableProcess

public IterableProcess(Iterable<T> iterable)

IterableProcess

public IterableProcess(Iterable<T> iterable,
               int bufferSize)

Method Detail

getIterable

public Iterable<T> getIterable()

Returns:

the iterable

run

protected void run(Channel<T> out)

Specified by:

run in class AbstractOutProcess<T>

setIterable

public void setIterable(Iterable<T> iterable)

Parameters:

iterable - the iterable to set

toString

public String toString()

Overrides:

toString in class AbstractProcess

write

protected void write(Channel<T> out,
         T object)