Data
- The type of data this pipeline sends and receives. Must be serializable.Addr
- The type of the address that the underlying communication protocol uses.public abstract class DataPipeManager<Data extends java.io.Serializable,Addr>
extends java.lang.Thread
Constructor and Description |
---|
DataPipeManager(DataPipe<Data,Addr> pipe)
Mandatory constructor class
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Close the data pipe.
|
void |
sendData(Data message,
Addr ip_address)
Method floated from data pipe: Interface for threaded sending of singleton data
|
void |
sendData(Data message,
Addr ip_address,
boolean threaded)
Method floated from data pipe: Interface for sending of singleton data.
|
void |
sendData(java.util.List<Data> messages,
Addr ip_address)
Method floated from data pipe: Send the given list of data to the given address
|
void |
sendData(java.util.List<Data> messages,
Addr ip_address,
boolean threaded)
Method floated from data pipe: Creates a thread that sends the given data
|
void |
sendDataThreaded(Data message,
Addr ip_address)
Method floated from data pipe: Creates a thread that sends the given data
|
void |
sendDataThreaded(java.util.List<Data> messages,
Addr ip_address)
Method floated from data pipe: A general send data interface.
|
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public void sendData(java.util.List<Data> messages, Addr ip_address, boolean threaded)
data_list
- list of data to send.address
- the recipient of the data.public void sendData(Data message, Addr ip_address, boolean threaded)
data
- the data to send.ip_address
- the recipient of the data.threaded
- true if data is to be sent by a dedicated thread.public void sendData(java.util.List<Data> messages, Addr ip_address)
data_list
- list of data to send.address
- the recipient of the data.public void sendData(Data message, Addr ip_address)
data
- the data to send.ip_address
- the recipient of the data.public void sendDataThreaded(java.util.List<Data> messages, Addr ip_address)
data_list
- list of data to send.address
- the recipient of the data.threaded
- true if data is to be sent by a dedicated thread.public void sendDataThreaded(Data message, Addr ip_address)
data_list
- list of data to send.address
- the recipient of the data.public void close()