org.eigenbase.test
Class ExclusivePipeTest.Consumer

java.lang.Object
  java.lang.Thread
      org.eigenbase.test.ExclusivePipeTest.Consumer

All Implemented Interfaces:

Runnable

Enclosing class:

ExclusivePipeTest

private static class ExclusivePipeTest.Consumer
extends Thread

Consumer thread reads words from a pipe, comparing with the list of expected words, until it has read all of the words it expects to see.

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

private byte[]	bytes
private ExclusivePipe	pipe
private boolean	succeeded
private Throwable	thrown

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

ExclusivePipeTest.Consumer(ExclusivePipe pipe)

Method Summary

void

run()

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, 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

private final ExclusivePipe pipe

bytes

private final byte[] bytes

succeeded

private boolean succeeded

thrown

private Throwable thrown

Constructor Detail

ExclusivePipeTest.Consumer

ExclusivePipeTest.Consumer(ExclusivePipe pipe)

Method Detail

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread