太多线程在多线程步骤中运行

Question

我创建了一个多线程步骤，最大线程限制为10；

private static final int THREAD_NUMBER = 10;

@Bean
public TaskExecutor taskExecutor(){
    SimpleAsyncTaskExecutor simpleAsyncTaskExecutor = new SimpleAsyncTaskExecutor("batch-thread");
    simpleAsyncTaskExecutor.setConcurrencyLimit(THREAD_NUMBER);
    return simpleAsyncTaskExecutor;
}


@Bean
protected Tasklet readHeader() {
    EkuampVorsatzReader ekuampVorsatzReader = new EkuampVorsatzReader();
    return ekuampVorsatzReader;
}

@Bean
public Step stepGetPriceFileHeader(){
    return stepBuilderFactory.get("batch-job_price_file-step-get-pricefile-header").tasklet(readHeader()).build();
}

@Bean
public Step stepGetPriceFileData() {
    return stepBuilderFactory.get("batch-job_price_file-step-get-pricefile-data")
            .<ImportLogEntity, ImportLogEntity>chunk(50)
            .reader(priceFileReader).listener(priceFileReaderListener)
            .writer(priceFileWriter)
            .listener(priceFileStepListener)
            .taskExecutor(taskExecutor())
            .throttleLimit(THREAD_NUMBER)
            .build();
}

@Bean
public Job batchJobPriceFile() {
    Job job = jobBuilderFactory.get("batch-job_price_file")
            .start(stepGetPriceFileHeader())
            .next(stepGetPriceFileData())
            .html" target="_blank">listener(jobExecutionListener)
            .build();
    return job;
}

在处理了200万条记录文件后，我可以在日志文件中看到创建的线程太多，即使我将限制设置为10个线程。你能告诉我为什么吗？非常感谢。

2019-07-02T17:02:298968129857信息[batch-thread35348]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30147 8130108信息之前[batch-thread35341]com。db。wmdl。价格档案。工作一批听众。PriceFileWriterListener（[]）-PriceFileWriterListener-afterWrite；列表大小：50 2019-07-02T17:02:30191 8130152信息[batch-thread35343]com。db。wmdl。价格档案。工作一批听众。PriceFileWriterListener（[]）-PriceFileWriterListener-afterWrite；列表大小：50 2019-07-02T17:02:30219 8130180信息[batch-thread35342]com。db。wmdl。价格档案。工作一批听众。PriceFileWriterListener（[]）-PriceFileWriterListener-afterWrite；列表大小：50 2019-07-02T17:02:30340 8130301信息[batch-thread35344]com。db。wmdl。价格档案。工作一批听众。PriceFileWriterListener（[]）-PriceFileWriterListener-afterWrite；列表大小：50 2019-07-02T17:02:30504 8130465信息[batch-thread35345]com。db。wmdl。价格档案。工作一批听众。PriceFileWriterListener（[]）-PriceFileWriterListener-afterWrite；列表大小：50 2019-07-02T17:02:30513 8130474信息[batch-thread35349]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30513 8130474信息之前[batch-thread35350]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30513 8130474信息之前[batch-thread35351]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30513 8130474信息之前[batch-thread35352]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30513 8130474信息之前[batch-thread35354]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30513 8130474信息之前[batch-thread35353]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-阅读2019-07-02T17:02:30513 8130474信息之前[batch-thread35355]com。db。wmdl。价格档案。工作一批听众。PriceFileReaderListener（[]）-PriceFileReaderListener-在2019-07-02T17:02:30586 8130547信息[QuartzScheduler\u Worker-1]之前。db。wmdl。价格档案。工作一批听众。PriceFileJobListener（[]）-SpringBatchJob[入站id:56435][spring批处理作业执行id:21]导入已完成

Answer 1

SimpleAsyncTaskExecutor不重用线程。以下是其Javadoc的摘录：

注意：此实现不重用线程！考虑使用线程池TaskExecator实现，特别是执行大量短期任务时。

在您的情况下，您可以使用ThreadPoolTaskExecutor并将其maxPoolSize设置为10。