com.revolsys.parallel.channel

Class AbstractChannelOutput<T>

java.lang.Object

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

All Implemented Interfaces:

ChannelOutput<T>

public abstract class AbstractChannelOutput<T>
extends Object
implements ChannelOutput<T>

Constructor Summary

Constructors

Constructor and Description
AbstractChannelOutput() Constructs a new Channel with a ZeroBuffer ChannelValueStore.
AbstractChannelOutput(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
protected abstract void	doWrite(T value)
String	getName()
boolean	isClosed()
String	toString()
void	write(T value) Writes an Object to the Channel.
void	writeConnect()
void	writeDisconnect()

Methods inherited from class java.lang.Object

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

Constructor Detail

AbstractChannelOutput

public AbstractChannelOutput()

Constructs a new Channel with a ZeroBuffer ChannelValueStore.

AbstractChannelOutput

public AbstractChannelOutput(String name)

Method Detail

close

public void close()

doWrite

protected abstract void doWrite(T value)

getName

public String getName()

isClosed

public boolean isClosed()

toString

public String toString()

Overrides:

toString in class Object

write

public void write(T value)

Writes an Object to the Channel. This method also ensures only one of the writers can actually be writing at any time. All other writers are blocked until it completes the write.

Specified by:

write in interface ChannelOutput<T>

Parameters:

value - The object to write to the Channel.

writeConnect

public void writeConnect()

Specified by:

writeConnect in interface ChannelOutput<T>

writeDisconnect

public void writeDisconnect()

Specified by:

writeDisconnect in interface ChannelOutput<T>