Class ExternalProcessExecutor.WorkerChannel

java.lang.Object

org.ojalgo.concurrent.ExternalProcessExecutor.WorkerChannel

Enclosing class:

ExternalProcessExecutor

private static final class ExternalProcessExecutor.WorkerChannel
extends Object

A per-thread, persistent channel to a child JVM. Not thread-safe; each instance must only be used from its owning thread. Kills and restarts the underlying process on demand.

Field Summary

Fields

Modifier and Type	Field	Description
private InputStream	myChildErr
private final ExternalProcessExecutor.RingBufferOutput	myErrBuffer
private Thread	myErrDrainer
private InputStream	myFromChild
private final ProcessOptions	myOptions
private final Thread	myOwnerThread
private Process	myProcess
private OutputStream	myToChild
private static final int	STDERR_MAX_BYTES

Constructor Summary

Constructors

Modifier	Constructor	Description
private	WorkerChannel(ProcessOptions options, Thread owner, Process proc, OutputStream toChild, InputStream fromChild, InputStream err, Thread errDrainer, ExternalProcessExecutor.RingBufferOutput errBuffer)

Method Summary

Modifier and Type	Method	Description
private static void	destroyProcessTree(Process proc)
(package private) String	getCapturedStderr()
(package private) boolean	isAlive()
(package private) void	kill()
(package private) ProcessOptions	options()
(package private) static ExternalProcessExecutor.WorkerChannel	start(ProcessOptions options)
(package private) ExternalProcessExecutor.ProcessResponse	transact(ExternalProcessExecutor.ProcessRequest req, Duration timeout)

Methods inherited from class Object

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

Field Details

STDERR_MAX_BYTES

private static final int STDERR_MAX_BYTES

See Also:

• Constant Field Values

myChildErr

private InputStream myChildErr

myErrBuffer

private final ExternalProcessExecutor.RingBufferOutput myErrBuffer

myErrDrainer

private Thread myErrDrainer

myFromChild

private InputStream myFromChild

myOptions

private final ProcessOptions myOptions

myOwnerThread

private final Thread myOwnerThread

myProcess

private Process myProcess

myToChild

private OutputStream myToChild

Constructor Details

WorkerChannel

private WorkerChannel(ProcessOptions options,
 Thread owner,
 Process proc,
 OutputStream toChild,
 InputStream fromChild,
 InputStream err,
 Thread errDrainer,
 ExternalProcessExecutor.RingBufferOutput errBuffer)

Method Details

destroyProcessTree

private static void destroyProcessTree(Process proc)

start

static ExternalProcessExecutor.WorkerChannel start(ProcessOptions options)
                                            throws Exception

Throws:

Exception

getCapturedStderr

String getCapturedStderr()

isAlive

boolean isAlive()

kill

void kill()

options

ProcessOptions options()

transact

ExternalProcessExecutor.ProcessResponse transact(ExternalProcessExecutor.ProcessRequest req,
 Duration timeout)
                                          throws Exception

Throws:

Exception