From bfd6bccd72edcf2c3194e46cd083d37345167014 Mon Sep 17 00:00:00 2001
From: Michael Minella <mminella@gopivotal.com>
Date: Mon, 16 Dec 2013 14:33:24 -0600
Subject: [PATCH] Added synchronization to the setting of partition data

---
 .../batch/core/jsr/partition/PartitionCollectorAdapter.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/partition/PartitionCollectorAdapter.java b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/partition/PartitionCollectorAdapter.java
index bfe102be4..1677a721a 100644
--- a/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/partition/PartitionCollectorAdapter.java
+++ b/spring-batch-core/src/main/java/org/springframework/batch/core/jsr/partition/PartitionCollectorAdapter.java
@@ -54,7 +54,9 @@ public class PartitionCollectorAdapter implements ChunkListener {
 	@Override
 	public void afterChunk(ChunkContext context) {
 		try {
-			partitionQueue.add(collector.collectPartitionData());
+			synchronized (partitionQueue) {
+				partitionQueue.add(collector.collectPartitionData());
+			}
 		} catch (Throwable e) {
 			throw new BatchRuntimeException("An error occured while collecting data from the PartionCollector", e);
 		}