er.extensions.concurrency

Class ERXTaskThread

java.lang.Object

java.lang.Thread

er.extensions.concurrency.ERXTaskThread

All Implemented Interfaces:

Runnable

public class ERXTaskThread
extends Thread

This is the custom Thread subclass that is used for running background tasks. This Thread subclass is automatically created by the ERXTaskThreadFactory which in turn is used by the ERXTaskThreadPoolExecutor The purpose of this subclass is

• to identify threads that were created by ERXTaskThreadFactory using instanceof when enumerating all threads
• to store a reference to the task itself in this Thread subclass while the task is executing making it easy to get a reference to tasks for application monitoring
• provide related static utility methods to find all tasks or tasks of a certain class that are currently running and that were created by ERXTaskThreadFactory

A user does not generally need to instantiate this class. This class is generally used by ExecutorService instances that are created by ERXExecutorService static utility methods.

See Also:

ERXTaskThreadPoolExecutor, ERXExecutorService, ERXTaskThreadFactory

Author:

kieran

Nested Class Summary

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

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
ERXTaskThread(Runnable target)

Method Summary

Modifier and Type	Method and Description
String	elapsedTime()
void	setTask(Runnable task)
void	startStopWatch()
void	stopStopWatch()
Runnable	task()
static <T> NSArray<T>	taskForTaskClass(Class<T> clazz)
static NSArray	taskInfos()
static NSArray	tasks()

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, run, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

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

Constructor Detail

ERXTaskThread

public ERXTaskThread(Runnable target)

Method Detail

task

public Runnable task()

Returns:

the current task being executed

setTask

public void setTask(Runnable task)

Parameters:

task - the current task being executed TODO: Check if the Runnable is a Future wrapping the real task and unwrap it.

tasks

public static NSArray tasks()

Returns:

NSArray of background tasks

taskInfos

public static NSArray taskInfos()

Returns:

NSArray of ERXTaskInfo

taskForTaskClass

public static <T> NSArray<T> taskForTaskClass(Class<T> clazz)

startStopWatch

public void startStopWatch()

elapsedTime

public String elapsedTime()

stopStopWatch

public void stopStopWatch()