package com.opencsv.bean.concurrent;

import com.opencsv.bean.MappingStrategy;

A specific derivative of IntolerantThreadPoolExecutor intended for submitting beans to be converted to Strings for writing. 
Author:
Andrew Rucker Jones
Type parameters:
<T> – The type of the bean being converted
Since:
5.0/**
 * A specific derivative of {@link IntolerantThreadPoolExecutor} intended for
 * submitting beans to be converted to {@link java.lang.String}s for writing.
 *
 * @param <T> The type of the bean being converted
 * @author Andrew Rucker Jones
 * @since 5.0
 */
public class BeanExecutor<T> extends IntolerantThreadPoolExecutor<String[]> {

    
The only constructor available for this class.
Params:
orderedResults – Whether order should be preserved in the results/**
     * The only constructor available for this class.
     * @param orderedResults Whether order should be preserved in the results
     */
    public BeanExecutor(boolean orderedResults) {super(orderedResults);}

    
Submit one bean for conversion.
Params:
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
throwExceptions – Whether exceptions should be thrown or captured
  for later processing/**
     * Submit one bean for conversion.
     *
     * @param lineNumber Which record in the output file is being processed
     * @param mappingStrategy The mapping strategy to be used
     * @param bean The bean to be transformed into a line of output
     * @param throwExceptions Whether exceptions should be thrown or captured
     *   for later processing
     */
    public void submitBean(
            long lineNumber, MappingStrategy<T> mappingStrategy,
            T bean, boolean throwExceptions) {
        try {
            execute(new ProcessCsvBean<>(lineNumber, mappingStrategy, bean, resultQueue,
                    thrownExceptionsQueue, throwExceptions));
        } catch (Exception e) {
            if(accumulateThread != null) {
                accumulateThread.setMustStop(true);
            }
            throw e;
        }
    }
}