Class ExternalProcessExecutor

java.lang.Object

org.ojalgo.concurrent.ExternalProcessExecutor

public final class ExternalProcessExecutor
extends Object

Execute submitted tasks/methods in external JVM processes with arbitrary Serializable arguments/return. Provides hard cancellation/timeout via process kill. Each executor thread owns a persistent child process kept alive across tasks until the owner thread is interrupted or the process is killed due to failure/timeout. This enables reusing JVM warm state for a sequence of tasks.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) static class	ExternalProcessExecutor.IPC	Inter-Process Communication
(package private) static final class	ExternalProcessExecutor.ProcessRequest
(package private) static final class	ExternalProcessExecutor.ProcessResponse
private static final class	ExternalProcessExecutor.ProcessTask<T>
private static final class	ExternalProcessExecutor.RingBufferOutput	Ring buffer OutputStream that retains only the last N bytes written.
private static final class	ExternalProcessExecutor.WorkerChannel	A per-thread, persistent channel to a child JVM.

Field Summary

Fields

Modifier and Type	Field	Description
private final ExecutorService	myExecutorService

Constructor Summary

Constructors

Constructor	Description
ExternalProcessExecutor(ExecutorService executor)

Method Summary

Modifier and Type	Method	Description
<T, C extends Callable<T> & Serializable> Future<T>	call(C callable)
<T, C extends Callable<T> & Serializable> Future<T>	call(C callable, ProcessOptions options)
<T> Future<T>	execute(Class<?> owner, String name, Class<?>[] parameters, Object... arguments)
<T> Future<T>	execute(Class<?> owner, String name, Class<?>[] parameters, ProcessOptions options, Object... arguments)
<T> Future<T>	execute(Method method, Object... arguments)
<T> Future<T>	execute(Method method, ProcessOptions options, Object... arguments)
<T> Future<T>	execute(MethodDescriptor method, Object... arguments)
<T> Future<T>	execute(MethodDescriptor method, ProcessOptions options, Object... arguments)
static ExternalProcessExecutor	newInstance()
static ExternalProcessExecutor	newInstance(int nThreads)	Create an executor backed by a fixed-size pool.
<R extends Runnable & Serializable> Future<Void>	run(R runnable)
<R extends Runnable & Serializable> Future<Void>	run(R runnable, ProcessOptions options)

Methods inherited from class Object

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

Field Details

myExecutorService

private final ExecutorService myExecutorService

Constructor Details

ExternalProcessExecutor

ExternalProcessExecutor(ExecutorService executor)

Method Details

newInstance

public static ExternalProcessExecutor newInstance()

newInstance

public static ExternalProcessExecutor newInstance(int nThreads)

Create an executor backed by a fixed-size pool. The pool size effectively caps the number of persistent worker processes running concurrently.

call

public <T, C extends Callable<T> & Serializable>
Future<T> call(C callable)

call

public <T, C extends Callable<T> & Serializable>
Future<T> call(C callable,
 ProcessOptions options)

execute

public <T> Future<T> execute(Class<?> owner,
 String name,
 Class<?>[] parameters,
 Object... arguments)

execute

public <T> Future<T> execute(Class<?> owner,
 String name,
 Class<?>[] parameters,
 ProcessOptions options,
 Object... arguments)

execute

public <T> Future<T> execute(Method method,
 Object... arguments)

execute

public <T> Future<T> execute(Method method,
 ProcessOptions options,
 Object... arguments)

execute

public <T> Future<T> execute(MethodDescriptor method,
 Object... arguments)

execute

public <T> Future<T> execute(MethodDescriptor method,
 ProcessOptions options,
 Object... arguments)

run

public <R extends Runnable & Serializable>
Future<Void> run(R runnable)

run

public <R extends Runnable & Serializable>
Future<Void> run(R runnable,
 ProcessOptions options)