Package com.pnfsoftware.jeb.util.concurrent

Class ThreadEx<V>

java.lang.Object

java.lang.Thread

com.pnfsoftware.jeb.util.concurrent.ThreadEx<V>

Type Parameters:

V - computation result type

All Implemented Interfaces:

Runnable

public final class ThreadEx<V>
extends Thread

An extension of Thread supporting the execution of Callable as well as Runnable. Two additional get() and get(timeout) methods, not unlike Future's get(), allow querying and waiting for the execution result. When executing a Runnable, get() will always return null. An exception occurring during the execution of the thread is collected and re-thrown inside an ExecutionException object.

Nested Class Summary

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
ThreadEx(Runnable runnable)	Create a thread that executes a runnable.
ThreadEx(Callable<V> callable)	Create a thread that executes a callable.

Method Summary

Modifier and Type	Method	Description
V	get()	Waits if necessary for the computation to complete, and then retrieves its result.
V	get(long millis)	Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.
final void	run()	Execute the configured runnable or callable.

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, interrupt, interrupted, isAlive, isDaemon, isInterrupted, isVirtual, join, join, join, join, ofPlatform, ofVirtual, onSpinWait, resume, 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

Constructor Details

ThreadEx

public ThreadEx(Runnable runnable)

Create a thread that executes a runnable.

Parameters:

runnable - non-null runnable to execute

ThreadEx

public ThreadEx(Callable<V> callable)

Create a thread that executes a callable.

Parameters:

callable - non-null callable to execute

Method Details

run

public final void run()

Execute the configured runnable or callable.

Specified by:

run in interface Runnable

Overrides:

run in class Thread

get

public V get()
      throws ExecutionException,
InterruptedException

Waits if necessary for the computation to complete, and then retrieves its result.

Returns:

the computed result; always null for a Runnable

Throws:

ExecutionException - if the computation threw an exception

InterruptedException - if the current thread was interrupted while waiting

get

public V get(long millis)
      throws ExecutionException,
InterruptedException,
TimeoutException

Waits if necessary for at most the given time for the computation to complete, and then retrieves its result, if available.

Parameters:

millis - the maximum time to wait, in milliseconds; 0 means wait forever

Returns:

the computed result; always null for a Runnable

Throws:

ExecutionException - if the computation threw an exception

InterruptedException - if the current thread was interrupted while waiting

TimeoutException - if the wait timed out