Package gda.scan

Class NoExceptionThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

gda.scan.NoExceptionThreadPoolExecutor

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService

public class NoExceptionThreadPoolExecutor
extends ThreadPoolExecutor

Subclass of ThreadPoolExecutor that rejects any new task submissions following observation of an exception a task. The method raiseExceptionIfSeen will raise the Exception observed in the task.

Nested Class Summary

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

ThreadPoolExecutor.AbortPolicy, ThreadPoolExecutor.CallerRunsPolicy, ThreadPoolExecutor.DiscardOldestPolicy, ThreadPoolExecutor.DiscardPolicy

Constructor Summary

Constructors

Constructor	Description
NoExceptionThreadPoolExecutor(BlockingQueue<Runnable> workQueue, ThreadFactory threadFactory, MultithreadedScanDataPointPipeline.ScannableSpecificExecutorService positionCallableService)

Method Summary

Modifier and Type	Method	Description
protected void	afterExecute(Runnable r, Throwable t)
void	raiseExceptionIfSeen()

Methods inherited from class java.util.concurrent.ThreadPoolExecutor

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

Methods inherited from interface java.util.concurrent.ExecutorService

close

Constructor Details

NoExceptionThreadPoolExecutor

public NoExceptionThreadPoolExecutor(BlockingQueue<Runnable> workQueue,
 ThreadFactory threadFactory,
 MultithreadedScanDataPointPipeline.ScannableSpecificExecutorService positionCallableService)

Method Details

raiseExceptionIfSeen

public void raiseExceptionIfSeen()
                          throws Exception

Throws:

Exception

afterExecute

protected void afterExecute(Runnable r,
 Throwable t)

Overrides:

afterExecute in class ThreadPoolExecutor