From 5ec37d5d00e58a16a7eae877ac40e827ca98a6f9 Mon Sep 17 00:00:00 2001 From: dsyer Date: Thu, 4 Jun 2009 16:59:19 +0000 Subject: [PATCH] RESOLVED - issue BATCH-1272: Write skips do not work in a multi-threaded step Fixed boolean logic in repeat callback --- .../batch/core/scope/context/StepContextRepeatCallback.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/StepContextRepeatCallback.java b/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/StepContextRepeatCallback.java index 37be3ecd2..3581fc0c3 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/StepContextRepeatCallback.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/StepContextRepeatCallback.java @@ -77,7 +77,7 @@ public abstract class StepContextRepeatCallback implements RepeatCallback { try { logger.debug("Chunk execution starting: worker count="+workerCount.get()+", queue size="+attributeQueue.size()); return RepeatStatus.continueIf(doInChunkContext(context, chunkContext).isContinuable() - || (attributeQueue.isEmpty() && workerCount.get()>1)); + || !attributeQueue.isEmpty() || workerCount.get()>1); } finally { workerCount.decrementAndGet();