Package com.opencsv.bean.concurrent
This package collects all classes necessary for the parallel processing of
beans.
-
Class Summary Class Description AccumulateCsvResults<T> The accumulator takes two queues of results of transforming text input into bean output or bean input into text output (output and exceptions) and orders them for later consumption.BeanExecutor<T> A specific derivative ofIntolerantThreadPoolExecutor
intended for submitting beans to be converted toString
s for writing.CompleteFileReader<T> Implements a separate thread for reading input and siphoning it to aLineExecutor
.IntolerantThreadPoolExecutor<T> This ThreadPoolExecutor automatically shuts down on any failed thread.LineExecutor<T> A specific derivative ofIntolerantThreadPoolExecutor
intended for submitting lines of input to be converted to beans.ProcessCsvBean<T> A class for converting one bean into its string representation for writing to an output.ProcessCsvLine<T> A class that encapsulates the job of creating a bean from a line of CSV input and making it possible to run those jobs in parallel.SingleLineReader This class exists to isolate the logic for reading a single line of input that is common toCsvToBean.iterator()
andCompleteFileReader
.