У меня есть такой участок кода:
private List<NtId> getNtIds(List<String> ids) {
List<NtId> ntIdList = new CopyOnWriteArrayList<>();
int step = 10000;
int stepsNumber = ids.size() / step + ids.size() % step == 0 ? 0 : 1;
CountDownLatch countDownLatch = new CountDownLatch(stepsNumber);
for (int i = 0; i < stepsNumber - 1; ++i) {
int current = i * step;
new Thread(() -> {
ntIdList.addAll(ntIdRepository.findDistinctByNtIdIn(ids.subList(current, current + step)));
countDownLatch.countDown();
}).start();
}
int lastStep = stepsNumber * step;
new Thread(() -> {
ntIdList.addAll(ntIdRepository.findDistinctByNtIdIn(ids.subList(lastStep, lastStep + ids.size() % step)));
countDownLatch.countDown();
}).start();
try {
countDownLatch.await();
} catch (InterruptedException e) {
e.printStackTrace();
}
return ntIdList;
}
Смысл его заключается в том, что на вход поступает список из id
и по ним надо выгрузить объекты. База данных не принимает список более 1000 значений и поэтому, чтобы ускорить процесс делаю обработку во многих потоках.
Проблема в том, что при изменениях переменной step
меняется и результат, чего быть не должно. В чем я ошибаюсь и как можно улучшить этот участок ?