com.revolsys.parallel.channel

Class NamedChannelBundle<T>

java.lang.Object

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

public class NamedChannelBundle<T>
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected Map<String,Queue<T>>	valueQueueByName The ChannelValueStore used to store the valueQueueByName for the Channel

Constructor Summary

Constructors

Constructor and Description
NamedChannelBundle()
NamedChannelBundle(String name)

Method Summary

Methods

Modifier and Type	Method and Description
void	close()
String	getName()
boolean	isClosed()
void	notifyReaders()
T	read() Reads an Object from the Channel.
T	read(Collection<String> names)
T	read(long timeout) Reads an Object from the Channel.
T	read(long timeout, Collection<String> names)
T	read(long timeout, String... names)
T	read(String... names)
void	readConnect()
void	readDisconnect()
Collection<T>	remove(String name)
void	write(String name, T value) Writes a named Object to the Channel.
void	writeConnect()
void	writeDisconnect()

Methods inherited from class java.lang.Object

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

Field Detail

valueQueueByName

protected Map<String,Queue<T>> valueQueueByName

The ChannelValueStore used to store the valueQueueByName for the Channel

Constructor Detail

NamedChannelBundle

public NamedChannelBundle()

NamedChannelBundle

public NamedChannelBundle(String name)

Method Detail

close

public void close()

getName

public String getName()

isClosed

public boolean isClosed()

notifyReaders

public void notifyReaders()

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.

Returns:

The object returned from the Channel.

read

public T read(Collection<String> names)

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.

Parameters:

timeout - The maximum time to wait in milliseconds.

Returns:

The object returned from the Channel.

read

public T read(long timeout,
     Collection<String> names)

read

public T read(long timeout,
     String... names)

read

public T read(String... names)

readConnect

public void readConnect()

readDisconnect

public void readDisconnect()

remove

public Collection<T> remove(String name)

write

public void write(String name,
         T value)

Writes a named 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. The channel can never be full so it does not block on write.

Parameters:

value - The object to write to the Channel.

writeConnect

public void writeConnect()

writeDisconnect

public void writeDisconnect()