From 32347d136cfbf8c6215c33c96ab4a005b2eb4afc Mon Sep 17 00:00:00 2001 From: Michiel Meeuwissen Date: Sat, 19 Oct 2024 18:37:38 +0200 Subject: [PATCH] thread safety. --- .../org/meeuw/test/math/streams/CartesianSpliteratorTest.java | 3 ++- 1 file changed, 2 insertions(+), 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 index fc9bb11a..01c76147 100644 --- 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 cartesianSpliterator = new CartesianSpliterator<>(iterate, dim); - final List result = new ArrayList<>(); + final List 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());