Home
last modified time | relevance | path

Searched refs:parallelStream (Results 1 – 25 of 38) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DConcatTest.java111 Stream<Integer> s1p = c1.parallelStream(); in checkPrerequisites()
112 Stream<Integer> s2p = c2.parallelStream(); in checkPrerequisites()
179 assertRefConcat(c1.parallelStream(), c2.parallelStream(), true, true); in testRefConcat()
181 assertRefConcat(c1.stream(), c2.parallelStream(), true, true); in testRefConcat()
183 assertRefConcat(c1.parallelStream(), c2.stream(), true, true); in testRefConcat()
188 assertRefConcat(c1.parallelStream().unordered(), c2.stream().unordered(), true, false); in testRefConcat()
195 assertIntConcat(c1.parallelStream(), c2.parallelStream(), true, true); in testIntConcat()
197 assertIntConcat(c1.stream(), c2.parallelStream(), true, true); in testIntConcat()
199 assertIntConcat(c1.parallelStream(), c2.stream(), true, true); in testIntConcat()
204 assertIntConcat(c1.parallelStream().unordered(), c2.stream().unordered(), true, false); in testIntConcat()
[all …]
DSummaryStatisticsTest.java49 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingInt(i -> i))); in testIntStatistics()
50 instances.add(countTo(1000).parallelStream().mapToInt(i -> i).summaryStatistics()); in testIntStatistics()
64 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingLong(i -> i))); in testLongStatistics()
65 instances.add(countTo(1000).parallelStream().mapToLong(i -> i).summaryStatistics()); in testLongStatistics()
79 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingDouble(i -> i))); in testDoubleStatistics()
80 instances.add(countTo(1000).parallelStream().mapToDouble(i -> i).summaryStatistics()); in testDoubleStatistics()
DCollectAndSummaryStatisticsTest.java97 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingInt(i -> i))); in testIntStatistics()
98 instances.add(countTo(1000).parallelStream().mapToInt(i -> i).summaryStatistics()); in testIntStatistics()
99 … instances.add(countTo(1000).parallelStream().mapToInt(i -> i).collect(IntSummaryStatistics::new, in testIntStatistics()
102 …instances.add(countTo(1000).parallelStream().mapToInt(i -> i).collect(() -> new IntSummaryStatisti… in testIntStatistics()
131 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingLong(i -> i))); in testLongStatistics()
132 instances.add(countTo(1000).parallelStream().mapToLong(i -> i).summaryStatistics()); in testLongStatistics()
133 … instances.add(countTo(1000).parallelStream().mapToLong(i -> i).collect(LongSummaryStatistics::new, in testLongStatistics()
136 …instances.add(countTo(1000).parallelStream().mapToInt(i -> i).collect(() -> new LongSummaryStatist… in testLongStatistics()
164 instances.add(countTo(1000).parallelStream().collect(Collectors.summarizingDouble(i -> i))); in testDoubleStatistics()
165 instances.add(countTo(1000).parallelStream().mapToDouble(i -> i).summaryStatistics()); in testDoubleStatistics()
[all …]
DSliceOpTest.java61 assertCountSum(countTo(0).parallelStream().skip(0), 0, 0); in testSkip()
62 assertCountSum(countTo(0).parallelStream().skip(4), 0, 0); in testSkip()
63 assertCountSum(countTo(4).parallelStream().skip(4), 0, 0); in testSkip()
64 assertCountSum(countTo(4).parallelStream().skip(2), 2, 7); in testSkip()
65 assertCountSum(countTo(4).parallelStream().skip(0), 4, 10); in testSkip()
84 assertCountSum(countTo(0).parallelStream().limit(4), 0, 0); in testLimit()
85 assertCountSum(countTo(2).parallelStream().limit(4), 2, 3); in testLimit()
86 assertCountSum(countTo(4).parallelStream().limit(4), 4, 10); in testLimit()
87 assertCountSum(countTo(8).parallelStream().limit(4), 4, 10); in testLimit()
DFindAnyOpTest.java60 assertFalse(Collections.emptySet().parallelStream().findAny().isPresent(), "no result"); in testFindAnyParallel()
61 …assertFalse(countTo(1000).parallelStream().filter(x -> x > 1000).findAny().isPresent(), "no result… in testFindAnyParallel()
62 … assertTrue(countTo(1000).parallelStream().filter(pEven).findAny().isPresent(), "with result"); in testFindAnyParallel()
DStreamSpliteratorTest.java321 … SpliteratorTestHelper.testSpliterator(() -> f.apply(data.parallelStream()).spliterator()); in testParSpliterators()
417 … SpliteratorTestHelper.testIntSpliterator(() -> f.apply(data.parallelStream()).spliterator()); in testIntParSpliterators()
510 … SpliteratorTestHelper.testLongSpliterator(() -> f.apply(data.parallelStream()).spliterator()); in testLongParSpliterators()
603 … SpliteratorTestHelper.testDoubleSpliterator(() -> f.apply(data.parallelStream()).spliterator()); in testDoubleParSpliterators()
DSequentialOpTest.java56 …Stream<Integer>>[] suppliers = new Supplier[] { () -> data.stream(), () -> data.parallelStream() }; in testLazy()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DLongStreamTestScenario.java103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
112 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
120 … for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { in PAR_STREAM_SPLITERATOR()
129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
136 for (long t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
145 LongStream s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
158 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
171 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
183 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DIntStreamTestScenario.java103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
112 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
120 … for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { in PAR_STREAM_SPLITERATOR()
129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
136 for (int t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
145 IntStream s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
159 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
172 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
184 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DDoubleStreamTestScenario.java103 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
112 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
120 …for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); )… in PAR_STREAM_SPLITERATOR()
129 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
136 for (double t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
145 DoubleStream s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
158 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
171 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
183 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DStreamTestScenario.java114 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
123 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
131 … for (Spliterator<U> spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { } in PAR_STREAM_SPLITERATOR()
139 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
147 for (Object t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
156 Stream<U> s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
170 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
183 for (U u : m.apply(data.parallelStream()).collect(Collectors.toList())) in PAR_STREAM_COLLECT_TO_LIST()
201 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) in PAR_STREAM_TO_STREAM_COLLECT_TO_LIST()
210 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
[all …]
DTestData.java66 S parallelStream(); in parallelStream() method
84 …ew AbstractTestData.RefTestData<>(name, collection, Collection::stream, Collection::parallelStream, in ofCollection()
261 public S parallelStream() { in parallelStream() method in TestData.AbstractTestData
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DLongStreamTestScenario.java106 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
115 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
123 … for (Spliterator.OfLong spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { in PAR_STREAM_SPLITERATOR()
132 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
139 for (long t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
148 LongStream s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
161 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
174 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
186 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DIntStreamTestScenario.java106 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
115 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
123 … for (Spliterator.OfInt spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { in PAR_STREAM_SPLITERATOR()
132 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
139 for (int t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
148 IntStream s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
162 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
175 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
187 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DDoubleStreamTestScenario.java107 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
116 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
124 …for (Spliterator.OfDouble spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); )… in PAR_STREAM_SPLITERATOR()
133 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
140 for (double t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
149 DoubleStream s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
162 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
175 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
187 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_FOR_EACH_CLEAR_SIZED()
DStreamTestScenario.java117 m.apply(data.parallelStream()).sequential().forEach(b); in PAR_STREAM_SEQUENTIAL_FOR_EACH()
126 m.apply(data.parallelStream()).forEachOrdered(b); in PAR_STREAM_FOR_EACH_ORDERED()
134 … for (Spliterator<U> spl = m.apply(data.parallelStream()).spliterator(); spl.tryAdvance(b); ) { } in PAR_STREAM_SPLITERATOR()
142 m.apply(data.parallelStream()).spliterator().forEachRemaining(b); in PAR_STREAM_SPLITERATOR_FOREACH()
150 for (Object t : m.apply(data.parallelStream()).toArray()) in PAR_STREAM_TO_ARRAY()
159 Stream<U> s = m.apply(data.parallelStream()); in PAR_STREAM_SPLITERATOR_STREAM_TO_ARRAY()
173 S_IN pipe1 = (S_IN) OpTestCase.chain(data.parallelStream(), in PAR_STREAM_TO_ARRAY_CLEAR_SIZED()
186 for (U u : m.apply(data.parallelStream()).collect(Collectors.toList())) in PAR_STREAM_COLLECT_TO_LIST()
204 for (U u : m.apply(data.parallelStream().sequential()).collect(Collectors.toList())) in PAR_STREAM_TO_STREAM_COLLECT_TO_LIST()
213 m.apply(data.parallelStream()).forEach(e -> { in PAR_STREAM_FOR_EACH()
[all …]
DTestData.java67 S parallelStream(); in parallelStream() method
85 …ew AbstractTestData.RefTestData<>(name, collection, Collection::stream, Collection::parallelStream, in ofCollection()
262 public S parallelStream() { in parallelStream() method in TestData.AbstractTestData
/libcore/ojluni/src/test/java/lang/StackWalker/
DAcrossThreads.java78 threads.parallelStream().forEach(t -> { in test()
82 threads.parallelStream().forEach(t -> { in test()
/libcore/ojluni/src/main/java/java/util/
DCollection.java763 default Stream<E> parallelStream() { in parallelStream() method
DAbstractMap.java914 public Stream<E> parallelStream() { return view().parallelStream(); } in parallelStream() method in AbstractMap.ViewCollection
DReverseOrderDequeView.java99 public Stream<E> parallelStream() { in parallelStream() method in ReverseOrderDequeView
/libcore/ojluni/annotations/sdk/nullability/java/util/
DCollection.annotated.java73 …c default java.util.stream.Stream<@libcore.util.NullFromTypeParam E> parallelStream() { throw new … in parallelStream() method
/libcore/ojluni/src/test/java/util/Collections/
DDelegatingIteratorForEachRemaining.java102 @Override public Stream<E> parallelStream() { return delegate.parallelStream(); } in parallelStream() method in DelegatingIteratorForEachRemaining.ForwardingSet
DUnmodifiableMapEntrySet.java163 testWithEntryConsumer(ec -> ms.get().entrySet().parallelStream().forEach(ec)); in testParallelStreamForEach()
/libcore/ojluni/src/test/java/math/BigInteger/
DPrimeTest.java118 long probablePrimes = (primes.parallelStream()) in checkPrime()

12