com.revolsys.parallel.channel

Class AbstractChannelInput<T>

java.lang.Object

com.revolsys.parallel.channel.AbstractChannelInput<T>

All Implemented Interfaces:

ChannelInput<T>, Iterable<T>

public abstract class AbstractChannelInput<T>
extends Object
implements ChannelInput<T>

Constructor Summary

Constructors

Constructor and Description
AbstractChannelInput()
AbstractChannelInput(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected abstract T	doRead()
protected abstract T	doRead(long timeout)
String	getName()
boolean	isClosed()
Iterator<T>	iterator()
T	read() Reads an Object from the Channel.
T	read(long timeout) Reads an Object from the Channel.
void	readConnect()
void	readDisconnect()
String	toString()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractChannelInput

public AbstractChannelInput()

AbstractChannelInput

public AbstractChannelInput(String name)

Method Detail

close

public void close()

doRead

protected abstract T doRead()

doRead

protected abstract T doRead(long timeout)

getName

public String getName()

isClosed

public boolean isClosed()

iterator

public Iterator<T> iterator()

Specified by:

iterator in interface Iterable<T>

read

public T read()

Reads an Object from the Channel. This method also ensures only one of the readers can actually be reading at any time. All other readers are blocked until it completes the read.

Specified by:

read in interface ChannelInput<T>

Returns:

The object returned from the Channel.

read

public T read(long timeout)

Reads an Object from the Channel. This method also ensures only one of the readers can actually be reading at any time. All other readers are blocked until it completes the read. If no data is available to be read after the timeout the method will return null.

Specified by:

read in interface ChannelInput<T>

Parameters:

timeout - The maximum time to wait in milliseconds.

Returns:

The object returned from the Channel.

readConnect

public void readConnect()

Specified by:

readConnect in interface ChannelInput<T>

readDisconnect

public void readDisconnect()

Specified by:

readDisconnect in interface ChannelInput<T>

toString

public String toString()

Overrides:

toString in class Object