Home
last modified time | relevance | path

Searched refs:parallel (Results 1 – 25 of 69) sorted by relevance

123

/libcore/ojluni/src/main/java/java/util/stream/
DStreamSupport.java67 public static <T> Stream<T> stream(Spliterator<T> spliterator, boolean parallel) { in stream() argument
71 parallel); in stream()
109 boolean parallel) { in stream() argument
113 parallel); in stream()
137 public static IntStream intStream(Spliterator.OfInt spliterator, boolean parallel) { in intStream() argument
140 parallel); in intStream()
177 boolean parallel) { in intStream() argument
180 parallel); in intStream()
205 boolean parallel) { in longStream() argument
208 parallel); in longStream()
[all …]
DAbstractPipeline.java151 private boolean parallel; field in AbstractPipeline
162 int sourceFlags, boolean parallel) { in AbstractPipeline() argument
171 this.parallel = parallel; in AbstractPipeline()
183 int sourceFlags, boolean parallel) { in AbstractPipeline() argument
192 this.parallel = parallel; in AbstractPipeline()
307 sourceStage.parallel = false; in sequential()
313 public final S parallel() { in parallel() method in AbstractPipeline
314 sourceStage.parallel = true; in parallel()
376 return sourceStage.parallel; in isParallel()
DStreamSpliterators.java117 boolean parallel) { in AbstractWrappingSpliterator() argument
121 this.isParallel = parallel; in AbstractWrappingSpliterator()
130 boolean parallel) { in AbstractWrappingSpliterator() argument
134 this.isParallel = parallel; in AbstractWrappingSpliterator()
272 boolean parallel) {
273 super(ph, supplier, parallel);
278 boolean parallel) {
279 super(ph, spliterator, parallel);
325 boolean parallel) { in IntWrappingSpliterator() argument
326 super(ph, supplier, parallel); in IntWrappingSpliterator()
[all …]
DDoublePipeline.java68 int sourceFlags, boolean parallel) { in DoublePipeline() argument
69 super(source, sourceFlags, parallel); in DoublePipeline()
80 int sourceFlags, boolean parallel) { in DoublePipeline() argument
81 super(source, sourceFlags, parallel); in DoublePipeline()
613 int sourceFlags, boolean parallel) {
614 super(source, sourceFlags, parallel);
627 int sourceFlags, boolean parallel) {
628 super(source, sourceFlags, parallel);
DIntPipeline.java68 int sourceFlags, boolean parallel) { in IntPipeline() argument
69 super(source, sourceFlags, parallel); in IntPipeline()
81 int sourceFlags, boolean parallel) { in IntPipeline() argument
82 super(source, sourceFlags, parallel); in IntPipeline()
606 int sourceFlags, boolean parallel) {
607 super(source, sourceFlags, parallel);
620 int sourceFlags, boolean parallel) {
621 super(source, sourceFlags, parallel);
DLongPipeline.java69 int sourceFlags, boolean parallel) { in LongPipeline() argument
70 super(source, sourceFlags, parallel); in LongPipeline()
82 int sourceFlags, boolean parallel) { in LongPipeline() argument
83 super(source, sourceFlags, parallel); in LongPipeline()
590 int sourceFlags, boolean parallel) {
591 super(source, sourceFlags, parallel);
604 int sourceFlags, boolean parallel) {
605 super(source, sourceFlags, parallel);
DReferencePipeline.java76 int sourceFlags, boolean parallel) { in ReferencePipeline() argument
77 super(source, sourceFlags, parallel); in ReferencePipeline()
89 int sourceFlags, boolean parallel) { in ReferencePipeline() argument
90 super(source, sourceFlags, parallel); in ReferencePipeline()
758 int sourceFlags, boolean parallel) {
759 super(source, sourceFlags, parallel);
771 int sourceFlags, boolean parallel) {
772 super(source, sourceFlags, parallel);
/libcore/jsr166-tests/src/test/java/jsr166/
DThreadLocalRandom8Test.java81 r.ints(size).parallel().forEach(x -> counter.increment()); in testIntsCount()
96 r.longs(size).parallel().forEach(x -> counter.increment()); in testLongsCount()
111 r.doubles(size).parallel().forEach(x -> counter.increment()); in testDoublesCount()
127 r.ints(size, lo, hi).parallel().forEach( in testBoundedInts()
146 r.longs(size, lo, hi).parallel().forEach( in testBoundedLongs()
165 r.doubles(size, lo, hi).parallel().forEach( in testBoundedDoubles()
181 r.ints().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedIntsCount()
192 r.longs().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedLongsCount()
203 r.doubles().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedDoublesCount()
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DLongPrimitiveOpsTests.java60 long sum = LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).sum(); in testParSum()
81 LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
86 List<Long> l = LongStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
119 long[] array = LongStream.range(1, 10).parallel().map(i -> i * 2).toArray(); in testToArray()
137 long[] array = Arrays.stream(content).parallel().sorted().toArray(); in testSort()
147 assertEquals(LongStream.range(0, 10).parallel().sorted().distinct().toArray(), range); in testSortDistinct()
152 assertEquals(LongStream.of(data).parallel().sorted().distinct().toArray(), expected); in testSortDistinct()
179 long[] array = Arrays.stream(content).parallel().sorted().sorted().toArray(); in testSortSort()
212 LongStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
226 long[] actual = LongStream.range(1, 100).parallel().limit(9).toArray(); in testLimit()
DIntPrimitiveOpsTests.java60 long sum = IntStream.range(1, 10).parallel().filter(i -> i % 2 == 0).sum(); in testParSum()
81 IntStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
86 List<Integer> l = IntStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
126 int[] array = IntStream.range(1, 10).parallel().map(i -> i * 2).toArray(); in testToArray()
144 int[] array = Arrays.stream(content).parallel().sorted().toArray(); in testSort()
154 assertEquals(IntStream.range(0, 10).parallel().sorted().distinct().toArray(), range); in testSortDistinct()
159 assertEquals(IntStream.of(data).parallel().sorted().distinct().toArray(), expected); in testSortDistinct()
191 int[] array = Arrays.stream(content).parallel().sorted().sorted().toArray(); in testSortSort()
224 IntStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
238 int[] actual = IntStream.range(1, 100).parallel().limit(9).toArray(); in testLimit()
DDoublePrimitiveOpsTests.java67 … double[] array = LongStream.range(1, 10).parallel().asDoubleStream().map(i -> i * 2).toArray(); in testToArray()
85 double[] array = Arrays.stream(content).parallel().sorted().toArray(); in testSort()
95 …assertEquals(LongStream.range(0, 10).asDoubleStream().parallel().sorted().distinct().toArray(), ra… in testSortDistinct()
102 assertEquals(DoubleStream.of(data).parallel().sorted().distinct().toArray(), expected); in testSortDistinct()
119 double[] array = Arrays.stream(content).parallel().sorted().sorted().toArray(); in testSortSort()
133 … double[] actual = LongStream.range(1, 100).parallel().asDoubleStream().limit(9).toArray(); in testLimit()
DStreamParSeqTest.java37 Stream<Integer> s = Arrays.asList(1, 2, 3, 4).stream().parallel(); in testParSeq()
46 s = s.parallel(); in testParSeq()
49 s = s.parallel(); in testParSeq()
DIntSliceOpTest.java67 assertCountSum(IntStream.range(0, 0).parallel().skip(0).boxed(), 0, 0); in testSkip()
68 assertCountSum(IntStream.range(0, 0).parallel().skip(4).boxed(), 0, 0); in testSkip()
69 assertCountSum(IntStream.range(1, 5).parallel().skip(4).boxed(), 0, 0); in testSkip()
70 assertCountSum(IntStream.range(1, 5).parallel().skip(2).boxed(), 2, 7); in testSkip()
71 assertCountSum(IntStream.range(1, 5).parallel().skip(0).boxed(), 4, 10); in testSkip()
90 assertCountSum(IntStream.range(0, 0).parallel().limit(4).boxed(), 0, 0); in testLimit()
91 assertCountSum(IntStream.range(1, 3).parallel().limit(4).boxed(), 2, 3); in testLimit()
92 assertCountSum(IntStream.range(1, 5).parallel().limit(4).boxed(), 4, 10); in testLimit()
93 assertCountSum(IntStream.range(1, 9).parallel().limit(4).boxed(), 4, 10); in testLimit()
206 int[] l = IntStream.range(1, 1001).parallel().skip(200).limit(200).sequential().toArray(); in testSkipParallel()
[all …]
DConcatTest.java145 …private void assertRefConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ord… in assertRefConcat() argument
147 assertEquals(result.isParallel(), parallel); in assertRefConcat() local
151 …private void assertIntConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ord… in assertIntConcat() argument
154 assertEquals(result.isParallel(), parallel); in assertIntConcat() local
159 …private void assertLongConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean or… in assertLongConcat() argument
162 assertEquals(result.isParallel(), parallel); in assertLongConcat() local
167 …private void assertDoubleConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean … in assertDoubleConcat() argument
170 assertEquals(result.isParallel(), parallel); in assertDoubleConcat() local
DMatchOpTest.java165 assertFalse(s.get().parallel().allMatch(i -> i > 3)); in testInfinite()
166 assertTrue(s.get().parallel().anyMatch(i -> i > 3)); in testInfinite()
167 assertFalse(s.get().parallel().noneMatch(i -> i > 3)); in testInfinite()
250 assertFalse(s.get().parallel().allMatch(i -> i > 3)); in testIntInfinite()
251 assertTrue(s.get().parallel().anyMatch(i -> i > 3)); in testIntInfinite()
252 assertFalse(s.get().parallel().noneMatch(i -> i > 3)); in testIntInfinite()
335 assertFalse(s.get().parallel().allMatch(i -> i > 3)); in testLongInfinite()
336 assertTrue(s.get().parallel().anyMatch(i -> i > 3)); in testLongInfinite()
337 assertFalse(s.get().parallel().noneMatch(i -> i > 3)); in testLongInfinite()
420 assertFalse(s.get().parallel().allMatch(i -> i > 3)); in testDoubleInfinite()
[all …]
DCountTest.java201 … assertEquals(supplier.get().peek(e -> ai.getAndIncrement()).parallel().count(), expectedCount); in checkStreamDoesNotConsumeElements()
210 … assertEquals(supplier.get().peek(e -> ai.getAndIncrement()).parallel().count(), expectedCount); in checkIntStreamDoesNotConsumeElements()
219 … assertEquals(supplier.get().peek(e -> ai.getAndIncrement()).parallel().count(), expectedCount); in checkLongStreamDoesNotConsumeElements()
228 … assertEquals(supplier.get().peek(e -> ai.getAndIncrement()).parallel().count(), expectedCount); in checkDoubleStreamDoesNotConsumeElements()
DSequentialOpTest.java61 …ator<Stream<Integer>>) s -> s.map(id).peek(e -> { counter.incrementAndGet(); }).parallel().map(id), in testLazy()
65 …(UnaryOperator<Stream<Integer>>) s -> s.parallel().map(id).peek(e -> { counter.incrementAndGet(); … in testLazy()
105 (UnaryOperator<Stream<Integer>>) s -> s.parallel(), in testMixedSeqPar()
/libcore/ojluni/src/test/java/util/concurrent/tck/
DThreadLocalRandom8Test.java104 r.ints(size).parallel().forEach(x -> counter.increment()); in testIntsCount()
119 r.longs(size).parallel().forEach(x -> counter.increment()); in testLongsCount()
134 r.doubles(size).parallel().forEach(x -> counter.increment()); in testDoublesCount()
150 r.ints(size, lo, hi).parallel().forEach( in testBoundedInts()
169 r.longs(size, lo, hi).parallel().forEach( in testBoundedLongs()
188 r.doubles(size, lo, hi).parallel().forEach( in testBoundedDoubles()
204 r.ints().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedIntsCount()
215 r.longs().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedLongsCount()
226 r.doubles().limit(size).parallel().forEach(x -> counter.increment()); in testUnsizedDoublesCount()
DSplittableRandomTest.java398 r.ints(size).parallel().forEach(x -> counter.increment());
413 r.longs(size).parallel().forEach(x -> counter.increment());
428 r.doubles(size).parallel().forEach(x -> counter.increment());
444 r.ints(size, lo, hi).parallel().forEach(
463 r.longs(size, lo, hi).parallel().forEach(
482 r.doubles(size, lo, hi).parallel().forEach(
498 r.ints().limit(size).parallel().forEach(x -> counter.increment());
509 r.longs().limit(size).parallel().forEach(x -> counter.increment());
520 r.doubles().limit(size).parallel().forEach(x -> counter.increment());
/libcore/ojluni/src/test/java/util/Collections/
DSyncSubMutexes.java112 @DataProvider(name = "Collections", parallel = true)
117 @DataProvider(name = "Lists", parallel = true)
122 @DataProvider(name = "Sets", parallel = true)
127 @DataProvider(name = "SortedSets", parallel = true)
132 @DataProvider(name = "NavigableSets", parallel = true)
137 @DataProvider(name = "Maps", parallel = true)
142 @DataProvider(name = "SortedMaps", parallel = true)
147 @DataProvider(name = "NavigableMaps", parallel = true)
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DTestData.java79 …n new AbstractTestData.RefTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
99 s -> s.get().parallel(), in ofSupplier()
114 …n new AbstractTestData.IntTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
129 s -> s.get().parallel(), in ofIntSupplier()
145 … new AbstractTestData.LongTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
160 s -> s.get().parallel(), in ofLongSupplier()
176 …ew AbstractTestData.DoubleTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
191 s -> s.get().parallel(), in ofDoubleSupplier()
DFlagDeclaringOp.java58 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DTestData.java80 …n new AbstractTestData.RefTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
100 s -> s.get().parallel(), in ofSupplier()
115 …n new AbstractTestData.IntTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
130 s -> s.get().parallel(), in ofIntSupplier()
146 … new AbstractTestData.LongTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
161 s -> s.get().parallel(), in ofLongSupplier()
177 …ew AbstractTestData.DoubleTestData<>(name, array, Arrays::stream, a -> Arrays.stream(a).parallel(), in ofArray()
192 s -> s.get().parallel(), in ofDoubleSupplier()
/libcore/ojluni/src/test/java/util/DoubleStreamSums/
DCompensatedSums.java89 jdkParallelStreamError += square(DoubleStream.of(rand).parallel().sum() - sum[0]); in testCompensatedSums()
92 …goodParallelStreamError += square(computeFinalSum(DoubleStream.of(rand).parallel().collect(doubleS… in testCompensatedSums()
95 …badParallelStreamError += square(computeFinalSum(DoubleStream.of(rand).parallel().collect(doubleSu… in testCompensatedSums()
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
DFlagOpTest.java71 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
264 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { in opWrapSink() argument
265 assertFlags(flags, parallel); in opWrapSink()
269 protected void assertFlags(int flags, boolean parallel) { in assertFlags() argument
270 if (parallel) { in assertFlags()

123