com.aspc.remote.util.misc

Class ThreadPool

java.lang.Object

java.lang.Thread

com.aspc.remote.util.misc.ThreadPool

All Implemented Interfaces:

java.lang.Runnable

public final class ThreadPool
extends java.lang.Thread

Thread Pool
THREAD MODE: MULTI-THREADED

Since:

February 24, 2001, 3:56 PM

Author:

Nigel Leck

Nested Class Summary

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

java.lang.Thread.State, java.lang.Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Method Summary

Modifier and Type	Method and Description
static void	addPurifier(ThreadPurifier purifier) add a thread purifier
static java.lang.String	getName(java.lang.Runnable runner) What is the scheduled runner current name ?
static java.lang.String	getStats() get the stats
static boolean	isAlive(java.lang.Runnable runner) is the scheduled runner alive ?
static boolean	purify() Purify the thread before placing back in the pool
static void	recordState() record the state of the thread before we start.
void	run() run the scheduled runner.
static void	schedule(java.lang.Runnable runner) schedule a runner.
static void	schedule(java.lang.Runnable runner, java.lang.String name) schedule a runner.
static boolean	threadsAvailable() make sure we have a thread to run our task
static void	waitFor(java.lang.Runnable runner) Wait for a scheduled runner.
static void	waitFor(java.lang.Runnable runner, long timeout) Wait for a scheduled runner.

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, 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

Method Detail

schedule

public static void schedule(@Nonnull
                            java.lang.Runnable runner)

schedule a runner.

Parameters:

runner - the runner to be scheduled

threadsAvailable

@CheckReturnValue
public static boolean threadsAvailable()

make sure we have a thread to run our task

Returns:

the value

schedule

public static void schedule(@Nonnull
                            java.lang.Runnable runner,
                            java.lang.String name)

schedule a runner.

Parameters:

runner - the runner to be scheduled

name - the name of the thread to be scheduled

waitFor

public static void waitFor(@Nonnull
                           java.lang.Runnable runner)

Wait for a scheduled runner.

Parameters:

runner - the runner to wait for.

waitFor

public static void waitFor(@Nonnull
                           java.lang.Runnable runner,
                           long timeout)

Wait for a scheduled runner.

Parameters:

runner - the runner to wait for.

timeout - the maximum time to wait in milliseconds.

isAlive

@CheckReturnValue
public static boolean isAlive(@Nonnull
                                                java.lang.Runnable runner)

is the scheduled runner alive ?

Parameters:

runner - the runner to check

Returns:

is alive

getName

@CheckReturnValue
public static java.lang.String getName(@Nonnull
                                                         java.lang.Runnable runner)

What is the scheduled runner current name ?

Parameters:

runner - the runner to check

Returns:

the name

recordState

public static void recordState()

record the state of the thread before we start.

addPurifier

public static void addPurifier(@Nonnull
                               ThreadPurifier purifier)

add a thread purifier

Parameters:

purifier - a purifier to be called.

purify

public static boolean purify()

Purify the thread before placing back in the pool

Returns:

check that the thread is clean.

run

public void run()

run the scheduled runner.

Specified by:

run in interface java.lang.Runnable

Overrides:

run in class java.lang.Thread

getStats

@CheckReturnValue
 @Nonnull
public static java.lang.String getStats()

get the stats

Returns:

the stats