Module ojalgo

Package org.ojalgo.concurrent

Class ExternalProcessExecutor.WorkerChannel

java.lang.Object

org.ojalgo.concurrent.ExternalProcessExecutor.WorkerChannel

Enclosing class:

ExternalProcessExecutor

private static final class ExternalProcessExecutor.WorkerChannel
extends java.lang.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 java.io.InputStream	myChildErr
private ExternalProcessExecutor.RingBufferOutput	myErrBuffer
private java.lang.Thread	myErrDrainer
private java.io.InputStream	myFromChild
private ProcessOptions	myOptions
private java.lang.Thread	myOwnerThread
private java.lang.Process	myProcess
private java.io.OutputStream	myToChild
private static int	STDERR_MAX_BYTES

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
private static void	destroyProcessTree(java.lang.Process proc)
(package private) java.lang.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, java.time.Duration timeout)

Methods inherited from class java.lang.Object

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

Field Detail

STDERR_MAX_BYTES

private static final int STDERR_MAX_BYTES

See Also:

Constant Field Values

myChildErr

private java.io.InputStream myChildErr

myErrBuffer

private final ExternalProcessExecutor.RingBufferOutput myErrBuffer

myErrDrainer

private java.lang.Thread myErrDrainer

myFromChild

private java.io.InputStream myFromChild

myOptions

private final ProcessOptions myOptions

myOwnerThread

private final java.lang.Thread myOwnerThread

myProcess

private java.lang.Process myProcess

myToChild

private java.io.OutputStream myToChild

Constructor Detail

WorkerChannel

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

Method Detail

destroyProcessTree

private static void destroyProcessTree(java.lang.Process proc)

start

static ExternalProcessExecutor.WorkerChannel start(ProcessOptions options)
                                            throws java.lang.Exception

Throws:

java.lang.Exception

getCapturedStderr

java.lang.String getCapturedStderr()

isAlive

boolean isAlive()

kill

void kill()

options

ProcessOptions options()

transact

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

Throws:

java.lang.Exception