cpDelQueue.addAll(lcpDelQueue);
long nextRowCount = getRowCount();
if (nextRowCount == currentRowCount.get()) {
Thread.sleep(1000);
}
<BUG>if (onlyDelQueue.size() > 100 && m_shouldContinue.get()) {
List<Long> workList = new ArrayList<Long>();
onlyDelQueue.drainTo(workList, 100);
CountDownLatch odlatch = new CountDownLatch(workList.size());</BUG>
for (Long lcid : workList) {

cpDelQueue.addAll(lcpDelQueue);
long nextRowCount = getRowCount();
if (nextRowCount == currentRowCount.get()) {
Thread.sleep(1000);
}
if (onlyDelQueue.size() > 0 && m_shouldContinue.get()) {
List<Long> workList = new ArrayList<Long>();
onlyDelQueue.drainTo(workList);
CountDownLatch odlatch = new CountDownLatch(workList.size());
for (Long lcid : workList) {
