Home
last modified time | relevance | path

Searched refs:isParallel (Results 1 – 25 of 31) sorted by relevance

12

/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DStreamParSeqTest.java38 assertTrue(s.isParallel()); in testParSeq()
41 assertFalse(s.isParallel()); in testParSeq()
44 assertFalse(s.isParallel()); in testParSeq()
47 assertTrue(s.isParallel()); in testParSeq()
50 assertTrue(s.isParallel()); in testParSeq()
DConcatTest.java113 assertTrue(s1p.isParallel()); in checkPrerequisites()
114 assertTrue(s2p.isParallel()); in checkPrerequisites()
115 assertFalse(s1s.isParallel()); in checkPrerequisites()
116 assertFalse(s2s.isParallel()); in checkPrerequisites()
147 assertEquals(result.isParallel(), parallel); in assertRefConcat()
154 assertEquals(result.isParallel(), parallel); in assertIntConcat()
162 assertEquals(result.isParallel(), parallel); in assertLongConcat()
170 assertEquals(result.isParallel(), parallel); in assertDoubleConcat()
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
DStatelessTestOp.java38 return op.opWrapSink(flags, isParallel(), sink); in chain()
44 return op.opWrapSink(flags, isParallel(), sink); in chain()
51 return op.opWrapSink(flags, isParallel(), sink); in chain()
58 return op.opWrapSink(flags, isParallel(), sink); in chain()
DLongStreamTestScenario.java50 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
198 private boolean isParallel; field in LongStreamTestScenario
202 LongStreamTestScenario(boolean isParallel) { in LongStreamTestScenario() argument
203 this(isParallel, true); in LongStreamTestScenario()
206 LongStreamTestScenario(boolean isParallel, boolean isOrdered) { in LongStreamTestScenario() argument
207 this.isParallel = isParallel; in LongStreamTestScenario()
215 public boolean isParallel() { in isParallel() method in LongStreamTestScenario
216 return isParallel; in isParallel()
DIntStreamTestScenario.java50 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
199 private final boolean isParallel; field in IntStreamTestScenario
203 IntStreamTestScenario(boolean isParallel) { in IntStreamTestScenario() argument
204 this(isParallel, true); in IntStreamTestScenario()
207 IntStreamTestScenario(boolean isParallel, boolean isOrdered) { in IntStreamTestScenario() argument
208 this.isParallel = isParallel; in IntStreamTestScenario()
216 public boolean isParallel() { in isParallel() method in IntStreamTestScenario
217 return isParallel; in isParallel()
DDoubleStreamTestScenario.java50 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
198 private boolean isParallel; field in DoubleStreamTestScenario
202 DoubleStreamTestScenario(boolean isParallel) { in DoubleStreamTestScenario() argument
203 this(isParallel, true); in DoubleStreamTestScenario()
206 DoubleStreamTestScenario(boolean isParallel, boolean isOrdered) { in DoubleStreamTestScenario() argument
207 this.isParallel = isParallel; in DoubleStreamTestScenario()
215 public boolean isParallel() { in isParallel() method in DoubleStreamTestScenario
216 return isParallel; in isParallel()
DStreamTestScenario.java49 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
237 private final boolean isParallel; field in StreamTestScenario
241 StreamTestScenario(boolean isParallel) { in StreamTestScenario() argument
242 this(isParallel, true); in StreamTestScenario()
245 StreamTestScenario(boolean isParallel, boolean isOrdered) { in StreamTestScenario() argument
246 this.isParallel = isParallel; in StreamTestScenario()
254 public boolean isParallel() { in isParallel() method in StreamTestScenario
255 return isParallel; in isParallel()
DStatefulTestOp.java41 return op.opWrapSink(flags, isParallel(), sink); in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
81 return op.opWrapSink(flags, isParallel(), sink); in chain()
101 return op.opWrapSink(flags, isParallel(), sink); in chain()
DOpTestCase.java85 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); in assertResult() argument
93 boolean isParallel(); in isParallel() method
397 …ltAsserter.assertResult(result, refResult, isStreamOrdered && test.isOrdered(), test.isParallel()); in exercise()
489 private final boolean isParallel; field in OpTestCase.TerminalTestScenario
491 TerminalTestScenario(boolean requiresSingleStageSource, boolean isParallel) { in TerminalTestScenario() argument
493 this.isParallel = isParallel; in TerminalTestScenario()
503 return isParallel; in requiresParallelSource()
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
DStatelessTestOp.java47 return op.opWrapSink(flags, isParallel(), sink); in chain()
54 return op.opWrapSink(flags, isParallel(), sink); in chain()
61 return op.opWrapSink(flags, isParallel(), sink); in chain()
68 return op.opWrapSink(flags, isParallel(), sink); in chain()
DLongStreamTestScenario.java53 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
201 private boolean isParallel; field in LongStreamTestScenario
205 LongStreamTestScenario(boolean isParallel) { in LongStreamTestScenario() argument
206 this(isParallel, true); in LongStreamTestScenario()
209 LongStreamTestScenario(boolean isParallel, boolean isOrdered) { in LongStreamTestScenario() argument
210 this.isParallel = isParallel; in LongStreamTestScenario()
218 public boolean isParallel() { in isParallel() method in LongStreamTestScenario
219 return isParallel; in isParallel()
DIntStreamTestScenario.java53 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
202 private final boolean isParallel; field in IntStreamTestScenario
206 IntStreamTestScenario(boolean isParallel) { in IntStreamTestScenario() argument
207 this(isParallel, true); in IntStreamTestScenario()
210 IntStreamTestScenario(boolean isParallel, boolean isOrdered) { in IntStreamTestScenario() argument
211 this.isParallel = isParallel; in IntStreamTestScenario()
219 public boolean isParallel() { in isParallel() method in IntStreamTestScenario
220 return isParallel; in isParallel()
DDoubleStreamTestScenario.java54 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
202 private boolean isParallel; field in DoubleStreamTestScenario
206 DoubleStreamTestScenario(boolean isParallel) { in DoubleStreamTestScenario() argument
207 this(isParallel, true); in DoubleStreamTestScenario()
210 DoubleStreamTestScenario(boolean isParallel, boolean isOrdered) { in DoubleStreamTestScenario() argument
211 this.isParallel = isParallel; in DoubleStreamTestScenario()
219 public boolean isParallel() { in isParallel() method in DoubleStreamTestScenario
220 return isParallel; in isParallel()
DStreamTestScenario.java52 if (s.isParallel()) { in STREAM_FOR_EACH_WITH_CLOSE()
240 private final boolean isParallel; field in StreamTestScenario
244 StreamTestScenario(boolean isParallel) { in StreamTestScenario() argument
245 this(isParallel, true); in StreamTestScenario()
248 StreamTestScenario(boolean isParallel, boolean isOrdered) { in StreamTestScenario() argument
249 this.isParallel = isParallel; in StreamTestScenario()
257 public boolean isParallel() { in isParallel() method in StreamTestScenario
258 return isParallel; in isParallel()
DStatefulTestOp.java42 return op.opWrapSink(flags, isParallel(), sink); in chain()
62 return op.opWrapSink(flags, isParallel(), sink); in chain()
82 return op.opWrapSink(flags, isParallel(), sink); in chain()
102 return op.opWrapSink(flags, isParallel(), sink); in chain()
DDefaultMethodStreams.java357 public boolean isParallel() { in isParallel() method in DefaultMethodStreams.DefaultMethodRefStream
358 return s.isParallel(); in isParallel()
573 public boolean isParallel() { in isParallel() method in DefaultMethodStreams.DefaultMethodIntStream
574 return s.isParallel(); in isParallel()
774 public boolean isParallel() { in isParallel() method in DefaultMethodStreams.DefaultMethodLongStream
775 return s.isParallel(); in isParallel()
967 public boolean isParallel() { in isParallel() method in DefaultMethodStreams.DefaultMethodDoubleStream
968 return s.isParallel(); in isParallel()
DOpTestCase.java86 void assertResult(R actual, R expected, boolean isOrdered, boolean isParallel); in assertResult() argument
94 boolean isParallel(); in isParallel() method
398 …ltAsserter.assertResult(result, refResult, isStreamOrdered && test.isOrdered(), test.isParallel()); in exercise()
490 private final boolean isParallel; field in OpTestCase.TerminalTestScenario
492 TerminalTestScenario(boolean requiresSingleStageSource, boolean isParallel) { in TerminalTestScenario() argument
494 this.isParallel = isParallel; in TerminalTestScenario()
504 return isParallel; in requiresParallelSource()
/libcore/ojluni/src/main/java/java/util/stream/
DAbstractPipeline.java234 return isParallel() in evaluate()
254 if (isParallel() && previousStage != null && opIsStateful()) { in evaluateToArrayNode()
370 return wrap(this, () -> sourceSpliterator(0), isParallel()); in spliterator()
375 public final boolean isParallel() { in isParallel() method in AbstractPipeline
416 if (isParallel() && sourceStage.sourceAnyStateful) { in sourceSpliterator()
482 if (size != -1 && StreamOpFlag.SIZE_ADJUSTING.isKnown(flags) && !isParallel()) { in exactOutputSizeIfKnown()
565 return wrap(this, () -> sourceSpliterator, isParallel()); in wrapSpliterator()
575 if (isParallel()) { in evaluate()
628 boolean isParallel); in wrap() argument
DDoubleStream.java382 isParallel()).onClose(this::close); in takeWhile()
449 isParallel()).onClose(this::close); in dropWhile()
1160 DoubleStream stream = StreamSupport.doubleStream(split, a.isParallel() || b.isParallel()); in concat()
DIntStream.java379 isParallel()).onClose(this::close); in takeWhile()
445 isParallel()).onClose(this::close); in dropWhile()
1153 IntStream stream = StreamSupport.intStream(split, a.isParallel() || b.isParallel()); in concat()
DLongStream.java380 isParallel()).onClose(this::close); in takeWhile()
447 isParallel()).onClose(this::close); in dropWhile()
1157 LongStream stream = StreamSupport.longStream(split, a.isParallel() || b.isParallel()); in concat()
DStream.java765 isParallel()).onClose(this::close);
831 isParallel()).onClose(this::close);
1619 Stream<T> stream = StreamSupport.stream(split, a.isParallel() || b.isParallel());
DBaseStream.java101 boolean isParallel(); in isParallel() method
DStreamSpliterators.java70 final boolean isParallel; field in StreamSpliterators.AbstractWrappingSpliterator
121 this.isParallel = parallel; in AbstractWrappingSpliterator()
134 this.isParallel = parallel; in AbstractWrappingSpliterator()
189 if (isParallel && buffer == null && !finished) {
284 return new WrappingSpliterator<>(ph, s, isParallel);
337 return new IntWrappingSpliterator<>(ph, s, isParallel); in wrap()
395 return new LongWrappingSpliterator<>(ph, s, isParallel); in wrap()
453 return new DoubleWrappingSpliterator<>(ph, s, isParallel); in wrap()
/libcore/luni/src/test/java/libcore/java/util/stream/
DLongStreamTest.java45 assertFalse("By default stream should be sequential", stream.isParallel()); in ofArraysWithDifferentSizes()

12