com.opencsv.bean.concurrent

Class AccumulateCsvResults<T>

java.lang.Object

java.lang.Thread

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

Type Parameters:

T - Type of the bean being created

All Implemented Interfaces:

Runnable

public class AccumulateCsvResults<T>
extends Thread

The accumulator takes two queues of results of transforming input into beans (beans an exceptions) and orders them for later consumption. This task is delegated to a separate thread so threads can quickly queue their results in a (synchronized, thread-safe) queue and move on with other work, while the relatively expensive operation of ordering the results doesn't block other threads waiting for access to the ordered map.

Since:

4.0

Author:

Andrew Rucker Jones

Nested Class Summary

Nested classes/interfaces inherited from class java.lang.Thread

Thread.State, Thread.UncaughtExceptionHandler

Field Summary

Fields inherited from class java.lang.Thread

MAX_PRIORITY, MIN_PRIORITY, NORM_PRIORITY

Constructor Summary

Constructors

Constructor and Description
AccumulateCsvResults(BlockingQueue<OrderedObject<T>> resultantBeansQueue, BlockingQueue<OrderedObject<CsvException>> thrownExceptionsQueue, ConcurrentMap<Long,T> resultantBeanMap, ConcurrentMap<Long,CsvException> thrownExceptionsMap) The only accepted constructor for the accumulator.

Method Summary

Methods

Modifier and Type	Method and Description
boolean	isMustStop() Checks whether the accumulator should shut itself down.
void	run()
void	setMustStop(boolean mustStop) Tells the accumulator whether it should stop.

Methods inherited from class java.lang.Thread

activeCount, checkAccess, clone, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield

Methods inherited from class java.lang.Object

equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

AccumulateCsvResults

public AccumulateCsvResults(BlockingQueue<OrderedObject<T>> resultantBeansQueue,
                    BlockingQueue<OrderedObject<CsvException>> thrownExceptionsQueue,
                    ConcurrentMap<Long,T> resultantBeanMap,
                    ConcurrentMap<Long,CsvException> thrownExceptionsMap)

The only accepted constructor for the accumulator.

Parameters:

resultantBeansQueue - A queue of beans coming out of the pool of threads creating them. The accumulator pulls from this queue.

thrownExceptionsQueue - A queue of CsvException and its derivatives coming out of the pool of threads creating beans. The accumulator pulls from this queue.

resultantBeanMap - The (ordered) map of beans that have been created. The accumulator inserts into this map.

thrownExceptionsMap - The (ordered) map of suppressed exceptions thrown during bean creation. The accumulator inserts into this map.

Method Detail

isMustStop

public boolean isMustStop()

Checks whether the accumulator should shut itself down. This method must always be used to check the value of the signal boolean, because it's synchronized.

Returns:

Whether the accumulator should stop

setMustStop

public void setMustStop(boolean mustStop)

Tells the accumulator whether it should stop. This method must always be used to set the value of the signal boolean, because it's synchronized.

Parameters:

mustStop - Whether the accumulator should stop

run

public void run()

Specified by:

run in interface Runnable

Overrides:

run in class Thread