edu.isi.pegasus.common.util
public class StreamGobbler extends Thread
Thread.State, Thread.UncaughtExceptionHandler
Modifier and Type | Field and Description |
---|---|
private StreamGobblerCallback |
mCallback
The callback to be used.
|
private InputStream |
mIPStream
The input stream that is to be read from.
|
private LogManager |
mLogger
The handle to the logging object.
|
private OutputStream |
mOPStream
The output stream to which the contents have to be redirected to.
|
private String |
mPrompt
The prompt that is to be written to the output stream.
|
private boolean |
mStarted
A boolean indicating whether the thread has started or not.
|
MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY
Constructor and Description |
---|
StreamGobbler(InputStream is,
StreamGobblerCallback callback)
The overloaded constructor.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Closes the underneath input and output stream that were opened.
|
protected void |
finalize()
Closes the open connections to the streams whenever this object
is destroyed.
|
void |
redirect(OutputStream ops,
String prompt)
Sets the output stream to which to redirect the contents of the input
stream.
|
void |
run()
The main method of the gobbler, that does all the work.
|
activeCount, checkAccess, clone, 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, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
private InputStream mIPStream
private OutputStream mOPStream
private StreamGobblerCallback mCallback
private String mPrompt
private boolean mStarted
private LogManager mLogger
public StreamGobbler(InputStream is, StreamGobblerCallback callback)
is
- the input stream from which to read from.callback
- the callback to call when a line is read.public void redirect(OutputStream ops, String prompt)
ops
- the output stream.prompt
- the prompt for the output stream.public void run()
protected void finalize()
public void close()