diff --git a/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/SynchronizationManagerSupport.java b/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/SynchronizationManagerSupport.java index 9f6eb78a0..dea01286e 100644 --- a/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/SynchronizationManagerSupport.java +++ b/spring-batch-core/src/main/java/org/springframework/batch/core/scope/context/SynchronizationManagerSupport.java @@ -15,9 +15,9 @@ */ package org.springframework.batch.core.scope.context; -import java.util.HashMap; import java.util.Map; import java.util.Stack; +import java.util.concurrent.ConcurrentHashMap; import java.util.concurrent.atomic.AtomicInteger; import org.springframework.batch.core.jsr.configuration.support.BatchPropertyContext; @@ -53,12 +53,12 @@ public abstract class SynchronizationManagerSupport { * Reference counter for each execution: how many threads are using the * same one? */ - private final Map counts = new HashMap(); + private final Map counts = new ConcurrentHashMap(); /** * Simple map from a running execution to the associated context. */ - private final Map contexts = new HashMap(); + private final Map contexts = new ConcurrentHashMap(); /** * Getter for the current context if there is one, otherwise returns null.