compbio.engine.local

Class LocalExecutorService

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

compbio.engine.local.LocalExecutorService

All Implemented Interfaces:

java.util.concurrent.Executor, java.util.concurrent.ExecutorService

public final class LocalExecutorService
extends java.util.concurrent.ThreadPoolExecutor

Nested Class Summary

Nested classes/interfaces inherited from class java.util.concurrent.ThreadPoolExecutor

java.util.concurrent.ThreadPoolExecutor.AbortPolicy, java.util.concurrent.ThreadPoolExecutor.CallerRunsPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardOldestPolicy, java.util.concurrent.ThreadPoolExecutor.DiscardPolicy

Field Summary

Fields

Modifier and Type	Field and Description
private static LocalExecutorService	INSTANCE
private static org.apache.log4j.Logger	log
private java.util.concurrent.atomic.AtomicLong	numTasks
private java.lang.ThreadLocal<java.lang.Long>	startTime
private static java.lang.String	threadNumPropName
private java.util.concurrent.atomic.AtomicLong	totalTime

Constructor Summary

Constructors

Modifier	Constructor and Description
private	LocalExecutorService(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)

Method Summary

Modifier and Type	Method and Description
protected void	afterExecute(java.lang.Runnable r, java.lang.Throwable t)
protected void	beforeExecute(java.lang.Thread t, java.lang.Runnable r)
boolean	canAcceptMoreWork() If the Executor queue is empty
static LocalExecutorService	getExecutor() This method returns the single instance of CachedThreadPoolExecutor which it cashes internally
private static LocalExecutorService	init()
static void	shutDown() This stops all executing processes via interruption.
protected void	terminated()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, execute, finalize, getActiveCount, getCompletedTaskCount, getCorePoolSize, getKeepAliveTime, getLargestPoolSize, getMaximumPoolSize, getPoolSize, getQueue, getRejectedExecutionHandler, getTaskCount, getThreadFactory, isShutdown, isTerminated, isTerminating, prestartAllCoreThreads, prestartCoreThread, purge, remove, setCorePoolSize, setKeepAliveTime, setMaximumPoolSize, setRejectedExecutionHandler, setThreadFactory, shutdown, shutdownNow, toString

Methods inherited from class java.util.concurrent.AbstractExecutorService

invokeAll, invokeAll, invokeAny, invokeAny, newTaskFor, newTaskFor, submit, submit, submit

Methods inherited from class java.lang.Object

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

Field Detail

log

private static final org.apache.log4j.Logger log

threadNumPropName

private static final java.lang.String threadNumPropName

See Also:

Constant Field Values

INSTANCE

private static LocalExecutorService INSTANCE

startTime

private final java.lang.ThreadLocal<java.lang.Long> startTime

numTasks

private final java.util.concurrent.atomic.AtomicLong numTasks

totalTime

private final java.util.concurrent.atomic.AtomicLong totalTime

Constructor Detail

LocalExecutorService

private LocalExecutorService(int corePoolSize,
                             int maximumPoolSize,
                             long keepAliveTime,
                             java.util.concurrent.TimeUnit unit,
                             java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue)

Method Detail

getExecutor

public static LocalExecutorService getExecutor()

This method returns the single instance of CachedThreadPoolExecutor which it cashes internally

Returns:

the instance

init

private static LocalExecutorService init()

shutDown

public static void shutDown()

This stops all executing processes via interruption. Thus it is vital that all processes that use this service respond to interruption Stops internal executor service which captures streams of native executables. This method is intended for stopping service if deployed in the web application context. There is NO NEED of using this method otherwise as the executor service is taken care of internally.

canAcceptMoreWork

public boolean canAcceptMoreWork()

If the Executor queue is empty

Returns:

true is not all threads are busy, false otherwise

beforeExecute

protected void beforeExecute(java.lang.Thread t,
                             java.lang.Runnable r)

Overrides:

beforeExecute in class java.util.concurrent.ThreadPoolExecutor

afterExecute

protected void afterExecute(java.lang.Runnable r,
                            java.lang.Throwable t)

Overrides:

afterExecute in class java.util.concurrent.ThreadPoolExecutor

terminated

protected void terminated()

Overrides:

terminated in class java.util.concurrent.ThreadPoolExecutor