com.opencsv.bean.concurrent

Class IntolerantThreadPoolExecutor

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

com.opencsv.bean.concurrent.IntolerantThreadPoolExecutor

All Implemented Interfaces:

Executor, ExecutorService

public class IntolerantThreadPoolExecutor
extends ThreadPoolExecutor

This ThreadPoolExecutor automatically shuts down on any failed thread. This is the historically established precedent for dealing with input errors in opencsv. This implementation expects all uncaught exceptions from its threads to be wrapped in a RuntimeException. The number of threads in the pool is fixed.

Since:

4.0

Author:

Andrew Rucker Jones

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 and Description
IntolerantThreadPoolExecutor() Constructor for a thread pool executor that stops by itself as soon as any thread throws an exception.

Method Summary

Methods

Modifier and Type	Method and Description
protected void	afterExecute(Runnable r, Throwable t) Shuts the Executor down if the thread ended in an exception.
Throwable	getTerminalException() If an unrecoverable exception was thrown during processing, it can be retrieved here.

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

Constructor Detail

IntolerantThreadPoolExecutor

public IntolerantThreadPoolExecutor()

Constructor for a thread pool executor that stops by itself as soon as any thread throws an exception. Threads never time out and the queue for inbound work is unbounded.

Method Detail

afterExecute

protected void afterExecute(Runnable r,
                Throwable t)

Shuts the Executor down if the thread ended in an exception.

Overrides:

afterExecute in class ThreadPoolExecutor

Parameters:

r -

t -

getTerminalException

public Throwable getTerminalException()

If an unrecoverable exception was thrown during processing, it can be retrieved here.

Returns:

The exception that halted one of the threads, which caused the executor to shut itself down