Module org.apache.jena.geosparql

Package org.apache.jena.geosparql.spatial.task

Class TaskThread

java.lang.Object

java.lang.Thread

org.apache.jena.geosparql.spatial.task.TaskThread

All Implemented Interfaces:

Runnable, BasicTask, org.apache.jena.sparql.engine.iterator.Abortable

public abstract class TaskThread
extends Thread
implements BasicTask

Thread base class that provides a abort() method that can run a custom action (in addition to setting the interrupted flag) as well as a doAfterRun() method for cleaning up after execution (only gets called if there is a prior call to run).

Nested Class Summary

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

Thread.Builder, Thread.State, Thread.UncaughtExceptionHandler

Nested classes/interfaces inherited from interface org.apache.jena.geosparql.spatial.task.BasicTask

BasicTask.TaskListener<T extends BasicTask>

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor	Description
TaskThread(String label, BasicTask.TaskListener<BasicTask> taskListener)
TaskThread(String label, BasicTask.TaskListener<BasicTask> taskListener, AtomicBoolean requestingCancel)

Method Summary

Modifier and Type	Method	Description
void	abort()
long	getAbortTime()
long	getCreationTime()
long	getEndTime()
String	getLabel()	A label for the task.
long	getStartTime()
String	getStatusMessage()	Get the last status message of the task.
TaskState	getTaskState()
Throwable	getThrowable()	If non null, the throwable that is the cause for an exceptional termination of the task.
boolean	isAborting()	Whether abort has been called.
final void	run()
abstract void	runActual()	The actual "run" method that must be implemented.
final void	runInternal()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, 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, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.apache.jena.geosparql.spatial.task.BasicTask

isTerminated

Constructor Details

TaskThread

public TaskThread(String label,
 BasicTask.TaskListener<BasicTask> taskListener)

TaskThread

public TaskThread(String label,
 BasicTask.TaskListener<BasicTask> taskListener,
 AtomicBoolean requestingCancel)

Method Details

getLabel

public String getLabel()

Description copied from interface: BasicTask

A label for the task.

Specified by:

getLabel in interface BasicTask

getTaskState

public TaskState getTaskState()

Specified by:

getTaskState in interface BasicTask

getThrowable

public Throwable getThrowable()

Description copied from interface: BasicTask

If non null, the throwable that is the cause for an exceptional termination of the task.

Specified by:

getThrowable in interface BasicTask

getCreationTime

public long getCreationTime()

Specified by:

getCreationTime in interface BasicTask

getStartTime

public long getStartTime()

Specified by:

getStartTime in interface BasicTask

getEndTime

public long getEndTime()

Specified by:

getEndTime in interface BasicTask

getAbortTime

public long getAbortTime()

Specified by:

getAbortTime in interface BasicTask

getStatusMessage

public String getStatusMessage()

Description copied from interface: BasicTask

Get the last status message of the task. May be null.

Specified by:

getStatusMessage in interface BasicTask

run

public final void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread

runInternal

public final void runInternal()

runActual

public abstract void runActual()
                        throws Exception

The actual "run" method that must be implemented.

Throws:

Exception

abort

public void abort()

Specified by:

abort in interface org.apache.jena.sparql.engine.iterator.Abortable

Specified by:

abort in interface BasicTask

isAborting

public boolean isAborting()

Description copied from interface: BasicTask

Whether abort has been called.

Specified by:

isAborting in interface BasicTask