Module ojalgo

Package org.ojalgo.concurrent

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.

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 java.lang.Object

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

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)