thread safety.

mihxil · Oct 19, 2024 · 32347d1 · 32347d1
1 parent a47bf23
commit 32347d1
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/mihxil-math/src/test/java/org/meeuw/test/math/streams/CartesianSpliteratorTest.java b/mihxil-math/src/test/java/org/meeuw/test/math/streams/CartesianSpliteratorTest.java
@@ -19,6 +19,7 @@
 
 import java.io.*;
 import java.util.*;
+import java.util.concurrent.CopyOnWriteArrayList;
 import java.util.concurrent.atomic.AtomicLong;
 import java.util.function.Consumer;
 import java.util.function.Supplier;
@@ -245,7 +246,7 @@ public void infiniteStreamSplit(int dim) {
             () -> Stream.iterate(1, i -> i + 2).spliterator();
         CartesianSpliterator<Integer> cartesianSpliterator =
             new CartesianSpliterator<>(iterate, dim);
-        final List<Integer[]> result = new ArrayList<>();
+        final List<Integer[]> result = new CopyOnWriteArrayList<>();
         assertThat(cartesianSpliterator.estimateSize()).isEqualTo(Long.MAX_VALUE);
         StreamSupport.stream(cartesianSpliterator, true).limit(100).forEach(a -> {
             log.info("{} ({})", Arrays.asList(a), Thread.currentThread().getName());