Class BeanExecutor<T>

java.lang.Object

java.util.concurrent.AbstractExecutorService

java.util.concurrent.ThreadPoolExecutor

com.opencsv.bean.concurrent.IntolerantThreadPoolExecutor<String[]>

com.opencsv.bean.concurrent.BeanExecutor<T>

Type Parameters:

T - The type of the bean being converted

All Implemented Interfaces:

AutoCloseable, Executor, ExecutorService, Spliterator<String[]>

public class BeanExecutor<T>
extends IntolerantThreadPoolExecutor<String[]>

A specific derivative of IntolerantThreadPoolExecutor intended for submitting beans to be converted to Strings for writing.

Since:

5.0

Nested Class Summary

Nested classes/interfaces inherited from class ThreadPoolExecutor

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

Nested classes/interfaces inherited from interface Spliterator

Spliterator.OfDouble, Spliterator.OfInt, Spliterator.OfLong, Spliterator.OfPrimitive<T,T_CONS,T_SPLITR>

Field Summary

Fields inherited from class IntolerantThreadPoolExecutor

accumulateThread, errorLocale, expectedRecords, resultQueue, thrownExceptionsQueue

Fields inherited from interface Spliterator

CONCURRENT, DISTINCT, IMMUTABLE, NONNULL, ORDERED, SIZED, SORTED, SUBSIZED

Constructor Summary

Constructors

Constructor	Description
BeanExecutor(boolean orderedResults, Locale errorLocale)	The only constructor available for this class.

Method Summary

Modifier and Type	Method	Description
void	submitBean(long lineNumber, MappingStrategy<T> mappingStrategy, T bean, CsvExceptionHandler exceptionHandler)	Submit one bean for conversion.

Methods inherited from class IntolerantThreadPoolExecutor

afterExecute, characteristics, checkExceptions, complete, estimateSize, getCapturedExceptions, getTerminalException, prepare, shutdownNow, tryAdvance, trySplit

Methods inherited from class 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, terminated, toString

Methods inherited from class AbstractExecutorService

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

Methods inherited from class Object

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

Methods inherited from interface ExecutorService

close

Methods inherited from interface Spliterator

forEachRemaining, getComparator, getExactSizeIfKnown, hasCharacteristics

Constructor Details

BeanExecutor

public BeanExecutor(boolean orderedResults,
 Locale errorLocale)

The only constructor available for this class.

Parameters:

orderedResults - Whether order should be preserved in the results

errorLocale - The locale to use for error messages

Method Details

submitBean

public void submitBean(long lineNumber,
 MappingStrategy<T> mappingStrategy,
 T bean,
 CsvExceptionHandler exceptionHandler)

Submit one bean for conversion.

Parameters:

lineNumber - Which record in the output file is being processed

mappingStrategy - The mapping strategy to be used

bean - The bean to be transformed into a line of output

exceptionHandler - The handler for exceptions thrown during record processing