com.exalead.papi.framework.pipeline

Class ThreadPoolExecutorNotifier

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

com.exalead.papi.framework.pipeline.ThreadPoolExecutorNotifier

All Implemented Interfaces:

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

public class ThreadPoolExecutorNotifier
extends java.util.concurrent.ThreadPoolExecutor

Author:

Boiteux

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
class	ThreadPoolExecutorNotifier.CallerRunner
static class	ThreadPoolExecutorNotifier.ClassLoaderThreadFactory

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

Constructor Summary

Constructors

Constructor and Description
ThreadPoolExecutorNotifier(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.lang.ClassLoader classLoader)
ThreadPoolExecutorNotifier(int corePoolSize, int maximumPoolSize, long keepAliveTime, java.util.concurrent.TimeUnit unit, java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue, java.lang.ClassLoader classLoader, java.util.concurrent.ThreadFactory threadFactory)

Method Summary

Modifier and Type	Method and Description
void	afterExecute(java.lang.Runnable r, java.lang.Throwable t)
void	execute(java.lang.Runnable r)
void	waitJobsCompleted()

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

Constructor Detail

ThreadPoolExecutorNotifier

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

ThreadPoolExecutorNotifier

public ThreadPoolExecutorNotifier(int corePoolSize,
                                  int maximumPoolSize,
                                  long keepAliveTime,
                                  java.util.concurrent.TimeUnit unit,
                                  java.util.concurrent.BlockingQueue<java.lang.Runnable> workQueue,
                                  java.lang.ClassLoader classLoader,
                                  java.util.concurrent.ThreadFactory threadFactory)

Method Detail

execute

public void execute(java.lang.Runnable r)

Specified by:

execute in interface java.util.concurrent.Executor

Overrides:

execute in class java.util.concurrent.ThreadPoolExecutor

afterExecute

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

Overrides:

afterExecute in class java.util.concurrent.ThreadPoolExecutor

waitJobsCompleted

public void waitJobsCompleted()
                       throws java.lang.Exception

Throws:

java.lang.Exception