Module ojalgo

Package org.ojalgo.concurrent

Class ProcessAwareThread

java.lang.Object

java.lang.Thread

org.ojalgo.concurrent.ProcessAwareThread

All Implemented Interfaces:

Runnable

final class ProcessAwareThread
extends Thread

A daemon thread that can be bound to an external Process. When this thread is interrupted, it will attempt to forcibly terminate the bound process before delegating to Thread.interrupt().

Typical usage:

 Thread t = DaemonPoolExecutor.newProcessAwareThreadFactory("ojAlgo-proc").newThread(() -> {
     Process p = new ProcessBuilder("sleep", "10").start();
     if (Thread.currentThread() instanceof ProcessAwareThread pat) pat.setProcess(p);
     p.waitFor();
 });
 t.start();
 // later...
 t.interrupt(); // will destroy the process
 

Nested Class Summary

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields

Modifier and Type	Field	Description
private final AtomicReference<Process>	myReference

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ProcessAwareThread(ThreadGroup group, Runnable target, String name)

Method Summary

Modifier and Type	Method	Description
void	interrupt()
(package private) void	setProcess(Process process)

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, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, sleep, start, startVirtualThread, stop, suspend, threadId, toString, yield

Methods inherited from class java.lang.Object

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

Field Details

myReference

private final AtomicReference<Process> myReference

Constructor Details

ProcessAwareThread

ProcessAwareThread(ThreadGroup group,
 Runnable target,
 String name)

Method Details

interrupt

public void interrupt()

Overrides:

interrupt in class Thread

setProcess

void setProcess(Process process)