com.buglabs.osgi.filesystem.util
Class AbstractPipeThread

java.lang.Object
  java.lang.Thread
      com.buglabs.osgi.filesystem.util.AbstractPipeThread

All Implemented Interfaces:

java.lang.Runnable

Direct Known Subclasses:

PipeReaderThread, PipeWriterThread

public abstract class AbstractPipeThread
extends java.lang.Thread

Push output of reader to clients on other side of pipe.

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

protected LogService	log
protected java.io.File	pipe

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

AbstractPipeThread(java.io.File pipe, LogService log)
Create writer

Method Summary

protected java.io.File	createPipe(java.io.File file) Create a pipe file
abstract void	shutdown() Exit writing thread.

Methods inherited from class java.lang.Thread

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

Methods inherited from class java.lang.Object

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

Field Detail

pipe

protected final java.io.File pipe

log

protected final LogService log

Constructor Detail

AbstractPipeThread

public AbstractPipeThread(java.io.File pipe,
                          LogService log)

Create writer

Parameters:

pipe -

reader -

Method Detail

shutdown

public abstract void shutdown()

Exit writing thread.

createPipe

protected java.io.File createPipe(java.io.File file)
                           throws java.io.IOException,
                                  java.lang.InterruptedException

Create a pipe file

Parameters:

file -

Returns:

Throws:

java.io.IOException

java.lang.InterruptedException