Сохранение итогов каждого потока Spring Batch

Я реализую пакетное приложение Spring, которое выполняет некоторые обновления базы данных. Здесь нет файлов ввода/вывода, только прямые обновления базы данных.

Программа выложена так:

1. Подготовительный тасклет вызывает процедуру БД, чтобы получить все параметры задания и работу, которую необходимо выполнить.
2. работа отправляется в разделитель, где работа делится на потоки
3. Тасклет вызова запускается и вызывает в каждом потоке вызов другой процедуры, которая выполняет фактические обновления в базе данных.
4. После того, как все потоки завершены, вызывается процедура «конец», чтобы закрыть любую регистрацию БД.

Моя проблема находится между шагами 3 и 4. После того, как каждый поток выполнен, он собирает выходные параметры процедуры, один из которых - сколько работы было фактически обновлено. Я хочу иметь возможность вести подсчет всех потоков и того, сколько работы было проделано всеми. Затем эта информация будет передана на шаг 4, который включит эти итоги в таблицы регистрации БД.

В настоящее время я добавляю любой результат процедуры на шаге 3 в Map<String, String> resultMap и вижу общее количество каждого потока. Моя проблема заключается в том, как передать ВСЕ потоки на шаг 4.

Я попытался объявить пару переменных в верхней части тасклета вызова, которые будут использоваться для сохранения текущей суммы. Проблема в том, что их значения сбрасываются после каждого потока, хотя я использую += при назначении значений из карты.

public class SpringBatchInvocationTasklet  implements Tasklet, StepExecutionListener {

   int totalWork = 0;
   int totalWorkProcessed = 0;


    @Override
   public RepeatStatus execute(StepContribution arg0, ChunkContext chunkContext) throws Exception {
      Map<String, String> resultMap = SpringBatchDAO.process(workList, dbLogId, commitVal, userName, threadNo);

      totalWork += Integer.parseInt(resultMap.get(SpringBatchConstants.TOTAL_WORK));
      totalWorkProcessed += Integer.parseInt(resultMap.get(SpringBatchConstants.TOTAL_WORK_PROCESSED));

    }
}

Подводя итог, мне нужно иметь возможность получить текущую сумму всех потоков для той работы, которую они все сделали, и передать ее в конечный процесс.

Спасибо за любую помощь в этом!