heros.solver

Class CountingThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

heros.solver.CountingThreadPoolExecutor

All Implemented Interfaces:

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

public class CountingThreadPoolExecutor
extends java.util.concurrent.ThreadPoolExecutor

A ThreadPoolExecutor which keeps track of the number of spawned tasks to allow clients to await their completion.

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
protected java.lang.Throwable	exception
protected static Logger	logger
protected CountLatch	numRunningTasks

Constructor Summary

Constructors

Constructor and Description
CountingThreadPoolExecutor(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)
void	awaitCompletion() Awaits the completion of all spawned tasks.
void	awaitCompletion(long timeout, java.util.concurrent.TimeUnit unit) Awaits the completion of all spawned tasks.
void	execute(java.lang.Runnable command)
java.lang.Throwable	getException() Returns the exception thrown during task execution (if any).

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

allowCoreThreadTimeOut, allowsCoreThreadTimeOut, awaitTermination, beforeExecute, 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, terminated, 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

logger

protected static final Logger logger

numRunningTasks

protected final CountLatch numRunningTasks

exception

protected volatile java.lang.Throwable exception

Constructor Detail

CountingThreadPoolExecutor

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

Method Detail

execute

public void execute(java.lang.Runnable command)

Specified by:

execute in interface java.util.concurrent.Executor

Overrides:

execute 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

awaitCompletion

public void awaitCompletion()
                     throws java.lang.InterruptedException

Awaits the completion of all spawned tasks.

Throws:

java.lang.InterruptedException

awaitCompletion

public void awaitCompletion(long timeout,
                            java.util.concurrent.TimeUnit unit)
                     throws java.lang.InterruptedException

Awaits the completion of all spawned tasks.

Throws:

java.lang.InterruptedException

getException

public java.lang.Throwable getException()

Returns the exception thrown during task execution (if any).