From b34e68a74ccf0ae55be868adb3cdb8483f5abe9a Mon Sep 17 00:00:00 2001
From: ayanamist <ayanamist@gmail.com>
Date: Wed, 19 May 2021 14:44:01 +0800
Subject: [PATCH] Fix ConcurrentModificationException

---
 .../test/util/data/collect/impl/ListDataCollectorImpl.java  | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/test/src/main/java/org/apache/rocketmq/test/util/data/collect/impl/ListDataCollectorImpl.java b/test/src/main/java/org/apache/rocketmq/test/util/data/collect/impl/ListDataCollectorImpl.java
index 82ab461a..bdd991a3 100644
--- a/test/src/main/java/org/apache/rocketmq/test/util/data/collect/impl/ListDataCollectorImpl.java
+++ b/test/src/main/java/org/apache/rocketmq/test/util/data/collect/impl/ListDataCollectorImpl.java
@@ -43,7 +43,7 @@ public class ListDataCollectorImpl implements DataCollector {
         return datas;
     }
 
-    public void resetData() {
+    public synchronized void resetData() {
         datas.clear();
         unlockIncrement();
     }
@@ -67,7 +67,7 @@ public class ListDataCollectorImpl implements DataCollector {
         return Collections.frequency(datas, data) == 1;
     }
 
-    public Collection<Object> getAllDataWithoutDuplicate() {
+    public synchronized Collection<Object> getAllDataWithoutDuplicate() {
         return new HashSet<Object>(datas);
     }
 
@@ -81,7 +81,7 @@ public class ListDataCollectorImpl implements DataCollector {
         return res;
     }
 
-    public void removeData(Object data) {
+    public synchronized void removeData(Object data) {
         datas.remove(data);
     }
 
-- 
GitLab