Merge pull request #194 from ydb-platform/disjoint_set_remove_map_con…

…currency Refactor: change map implementation in disjoint set
ydb-platform · Oct 30, 2023 · bfda182 · bfda182
2 parents bca9e3d + 9b0ef61
commit bfda182
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/topic/src/main/java/tech/ydb/topic/read/impl/DisjointOffsetRangeSet.java b/topic/src/main/java/tech/ydb/topic/read/impl/DisjointOffsetRangeSet.java
@@ -5,15 +5,15 @@
 import java.util.List;
 import java.util.Map;
 import java.util.NavigableMap;
-import java.util.concurrent.ConcurrentSkipListMap;
+import java.util.TreeMap;
 
 import tech.ydb.topic.read.OffsetsRange;
 
 /**
  * @author Nikolay Perfilov
  */
 public class DisjointOffsetRangeSet {
-    private final NavigableMap<Long, OffsetsRangeImpl> ranges = new ConcurrentSkipListMap<>();
+    private final NavigableMap<Long, OffsetsRangeImpl> ranges = new TreeMap<>();
 
     public void add(OffsetsRange rangeToCommit) {
         Map.Entry<Long, OffsetsRangeImpl> floorEntry = ranges.floorEntry(rangeToCommit.getStart());