| /libcore/ojluni/src/main/java/java/util/stream/ |
| D | StreamSupport.java | 67 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 …]
|
| D | AbstractPipeline.java | 151 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()
373 return sourceStage.parallel; in isParallel()
|
| D | StreamSpliterators.java | 117 boolean parallel) { in AbstractWrappingSpliterator() argument
121 this.isParallel = parallel; in AbstractWrappingSpliterator()
130 boolean parallel) { in AbstractWrappingSpliterator() argument
134 this.isParallel = parallel; in AbstractWrappingSpliterator()
274 boolean parallel) {
275 super(ph, supplier, parallel);
280 boolean parallel) {
281 super(ph, spliterator, parallel);
327 boolean parallel) { in IntWrappingSpliterator() argument
328 super(ph, supplier, parallel); in IntWrappingSpliterator()
[all …]
|
| D | IntPipeline.java | 68 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()
545 int sourceFlags, boolean parallel) {
546 super(source, sourceFlags, parallel);
559 int sourceFlags, boolean parallel) {
560 super(source, sourceFlags, parallel);
|
| D | DoublePipeline.java | 68 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()
547 int sourceFlags, boolean parallel) {
548 super(source, sourceFlags, parallel);
561 int sourceFlags, boolean parallel) {
562 super(source, sourceFlags, parallel);
|
| D | LongPipeline.java | 69 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()
528 int sourceFlags, boolean parallel) {
529 super(source, sourceFlags, parallel);
542 int sourceFlags, boolean parallel) {
543 super(source, sourceFlags, parallel);
|
| D | ReferencePipeline.java | 72 int sourceFlags, boolean parallel) { in ReferencePipeline() argument
73 super(source, sourceFlags, parallel); in ReferencePipeline()
85 int sourceFlags, boolean parallel) { in ReferencePipeline() argument
86 super(source, sourceFlags, parallel); in ReferencePipeline()
570 int sourceFlags, boolean parallel) {
571 super(source, sourceFlags, parallel);
583 int sourceFlags, boolean parallel) {
584 super(source, sourceFlags, parallel);
|
| D | BaseStream.java | 117 S parallel(); in parallel() method
|
| /libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/ |
| D | IntPrimitiveOpsTests.java | 52 long sum = IntStream.range(1, 10).parallel().filter(i -> i % 2 == 0).sum(); in testParSum()
73 IntStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
78 List<Integer> l = IntStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
95 int[] array = IntStream.range(1, 10).parallel().map(i -> i * 2).toArray(); in testToArray()
113 int[] array = Arrays.stream(content).parallel().sorted().toArray(); in testSort()
131 int[] array = Arrays.stream(content).parallel().sorted().sorted().toArray(); in testSortSort()
164 IntStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
178 int[] actual = IntStream.range(1, 100).parallel().limit(9).toArray(); in testLimit()
|
| D | LongPrimitiveOpsTests.java | 52 long sum = LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).sum(); in testParSum()
73 LongStream.range(1, 10).parallel().filter(i -> i % 2 == 0).forEach(ai::addAndGet); in testParForEach()
78 List<Long> l = LongStream.range(1, 10).parallel().boxed().collect(Collectors.toList()); in testBox()
95 long[] array = LongStream.range(1, 10).parallel().map(i -> i * 2).toArray(); in testToArray()
113 long[] array = Arrays.stream(content).parallel().sorted().toArray(); in testSort()
131 long[] array = Arrays.stream(content).parallel().sorted().sorted().toArray(); in testSortSort()
164 LongStream.range(1, 1000).parallel().sequential().forEach(consumer); in testSequential()
178 long[] actual = LongStream.range(1, 100).parallel().limit(9).toArray(); in testLimit()
|
| D | StreamParSeqTest.java | 37 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()
|
| D | DoublePrimitiveOpsTests.java | 52 … double[] array = LongStream.range(1, 10).parallel().asDoubleStream().map(i -> i * 2).toArray(); in testToArray()
70 double[] array = Arrays.stream(content).parallel().sorted().toArray(); in testSort()
88 double[] array = Arrays.stream(content).parallel().sorted().sorted().toArray(); in testSortSort()
102 … double[] actual = LongStream.range(1, 100).parallel().asDoubleStream().limit(9).toArray(); in testLimit()
|
| D | IntSliceOpTest.java | 65 assertCountSum(IntStream.range(0, 0).parallel().skip(0).boxed(), 0, 0); in testSkip()
66 assertCountSum(IntStream.range(0, 0).parallel().skip(4).boxed(), 0, 0); in testSkip()
67 assertCountSum(IntStream.range(1, 5).parallel().skip(4).boxed(), 0, 0); in testSkip()
68 assertCountSum(IntStream.range(1, 5).parallel().skip(2).boxed(), 2, 7); in testSkip()
69 assertCountSum(IntStream.range(1, 5).parallel().skip(0).boxed(), 4, 10); in testSkip()
88 assertCountSum(IntStream.range(0, 0).parallel().limit(4).boxed(), 0, 0); in testLimit()
89 assertCountSum(IntStream.range(1, 3).parallel().limit(4).boxed(), 2, 3); in testLimit()
90 assertCountSum(IntStream.range(1, 5).parallel().limit(4).boxed(), 4, 10); in testLimit()
91 assertCountSum(IntStream.range(1, 9).parallel().limit(4).boxed(), 4, 10); in testLimit()
201 int[] l = IntStream.range(1, 1001).parallel().skip(200).limit(200).sequential().toArray(); in testSkipParallel()
[all …]
|
| D | ConcatTest.java | 145 …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
|
| D | MatchOpTest.java | 165 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 …]
|
| D | SequentialOpTest.java | 61 …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()
|
| D | StreamSpliteratorTest.java | 255 s -> s.parallel(), in testSplitting()
257 s -> s.map(LambdaTestHelpers.identity()).parallel() in testSplitting()
349 s -> s.parallel(), in testIntSplitting()
351 s -> s.map(i -> i).parallel() in testIntSplitting()
442 s -> s.parallel(), in testLongSplitting()
444 s -> s.map(i -> i).parallel() in testLongSplitting()
535 s -> s.parallel(), in testDoubleSplitting()
537 s -> s.map(i -> i).parallel() in testDoubleSplitting()
|
| /libcore/jsr166-tests/src/test/java/jsr166/ |
| D | ThreadLocalRandom8Test.java | 81 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/bootlib/java/util/stream/ |
| D | TestData.java | 79 …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()
|
| D | FlagDeclaringOp.java | 58 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
|
| D | StatelessTestOp.java | 71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink);
|
| D | CollectorOps.java | 64 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { in opWrapSink() argument
|
| /libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/ |
| D | TestData.java | 80 …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()
|
| D | FlagDeclaringOp.java | 61 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
|
| /libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/ |
| D | FlagOpTest.java | 71 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()
|