org.jactr.core.concurrent

Class ExecutorServices

java.lang.Object

org.jactr.core.concurrent.ExecutorServices

public class ExecutorServices
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	BACKGROUND
static java.lang.String	INLINE
static java.util.concurrent.ExecutorService	INLINE_EXECUTOR
static java.lang.Runnable	NOOP_RUNNABLE
static java.lang.String	PERIODIC
static java.lang.String	POOL

Constructor Summary

Constructors

Constructor and Description
ExecutorServices()

Method Summary

Modifier and Type	Method and Description
static void	addExecutor(java.lang.String name, java.util.concurrent.ExecutorService service)
static java.util.concurrent.ExecutorService	getExecutor(java.lang.String name)
static void	getExecutorNames(java.util.Collection<java.lang.String> container)
static void	initialize()
static void	removeExecutor(java.lang.String name)
static void	shutdown(long millisecondsToWait) shutdown and wait for the shutdown of all the executors that are currently installed.
static boolean	waitFor(java.util.concurrent.ExecutorService executor, long waitInMs) wait for a specific executor to finish its processing load

Methods inherited from class java.lang.Object

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

Field Detail

INLINE

public static final java.lang.String INLINE

See Also:

Constant Field Values

BACKGROUND

public static final java.lang.String BACKGROUND

See Also:

Constant Field Values

PERIODIC

public static final java.lang.String PERIODIC

See Also:

Constant Field Values

POOL

public static final java.lang.String POOL

See Also:

Constant Field Values

INLINE_EXECUTOR

public static final java.util.concurrent.ExecutorService INLINE_EXECUTOR

NOOP_RUNNABLE

public static final java.lang.Runnable NOOP_RUNNABLE

Constructor Detail

ExecutorServices

public ExecutorServices()

Method Detail

initialize

public static void initialize()

removeExecutor

public static void removeExecutor(java.lang.String name)

addExecutor

public static void addExecutor(java.lang.String name,
                               java.util.concurrent.ExecutorService service)

getExecutor

public static java.util.concurrent.ExecutorService getExecutor(java.lang.String name)

getExecutorNames

public static void getExecutorNames(java.util.Collection<java.lang.String> container)

waitFor

public static boolean waitFor(java.util.concurrent.ExecutorService executor,
                              long waitInMs)

wait for a specific executor to finish its processing load

Parameters:

executor -

waitInMs -

Returns:

true if the block was reached, false if timeout or exception

shutdown

public static void shutdown(long millisecondsToWait)

shutdown and wait for the shutdown of all the executors that are currently installed. if millisecondsToWait is 0, it will wait indefinitely