fix(s3stream): use thread safe data structures to prevent race condition

Signed-off-by: Shichao Nie <[email protected]>

s3stream/src/main/java/com/automq/stream/s3/cache/StreamReader.java

@@ -27,8 +27,6 @@
 import io.opentelemetry.instrumentation.annotations.WithSpan;
 import java.util.ArrayList;
 import java.util.Collections;
-import java.util.HashMap;
-import java.util.HashSet;
 import java.util.LinkedList;
 import java.util.List;
 import java.util.Map;
@@ -555,8 +553,8 @@ public ReadContext(long startOffset, int maxBytes) {
             this.objects = new LinkedList<>();
             this.objectIndex = 0;
             this.streamDataBlocksPair = new LinkedList<>();
-            this.objectReaderMap = new HashMap<>();
-            this.taskKeySet = new HashSet<>();
+            this.objectReaderMap = new ConcurrentHashMap<>();
+            this.taskKeySet = ConcurrentHashMap.newKeySet();
             this.nextStartOffset = startOffset;
             this.nextMaxBytes = maxBytes;
             this.timer = new TimerUtil();