Package org.jruby.util

Class ShellLauncher.StreamPumper

java.lang.Object

java.lang.Thread

org.jruby.util.ShellLauncher.StreamPumper

All Implemented Interfaces:

Runnable, ShellLauncher.Pumper

Enclosing class:

ShellLauncher

private static class ShellLauncher.StreamPumper
extends Thread
implements ShellLauncher.Pumper

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface org.jruby.util.ShellLauncher.Pumper

ShellLauncher.Pumper.Slave

Field Summary

Fields

Modifier and Type	Field	Description
private final InputStream	in
private final boolean	onlyIfAvailable
private final OutputStream	out
private boolean	quit
private final Ruby	runtime
private final ShellLauncher.Pumper.Slave	slave
private final Object	sync
private final Object	waitLock

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
StreamPumper(Ruby runtime, InputStream in, OutputStream out, boolean avail, ShellLauncher.Pumper.Slave slave, Object sync)

Method Summary

Modifier and Type	Method	Description
void	quit()
void	run()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, onSpinWait, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.jruby.util.ShellLauncher.Pumper

start

Field Details

in

private final InputStream in

out

private final OutputStream out

onlyIfAvailable

private final boolean onlyIfAvailable

waitLock

private final Object waitLock

sync

private final Object sync

slave

private final ShellLauncher.Pumper.Slave slave

quit

private volatile boolean quit

runtime

private final Ruby runtime

Constructor Details

StreamPumper

StreamPumper(Ruby runtime,
 InputStream in,
 OutputStream out,
 boolean avail,
 ShellLauncher.Pumper.Slave slave,
 Object sync)

Method Details

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

quit

public void quit()

Specified by:

quit in interface ShellLauncher.Pumper