Searched defs:parallel (Results 1 - 25 of 25) sorted by relevance

/libcore/ojluni/src/main/java/java/util/stream/
H A DBaseStream.java37 * sequential and parallel aggregate operations. The following example
86 * would execute in parallel. Calling this method after invoking an
89 * @return {@code true} if this stream would execute in parallel if executed
106 * Returns an equivalent stream that is parallel. May return
107 * itself, either because the stream was already parallel, or because
108 * the underlying stream state was modified to be parallel.
113 * @return a parallel stream
115 S parallel(); method in interface:BaseStream
H A DStreamSupport.java46 * Creates a new sequential or parallel {@code Stream} from a
62 * @param parallel if {@code true} then the returned stream is a parallel
65 * @return a new sequential or parallel {@code Stream}
67 public static <T> Stream<T> stream(Spliterator<T> spliterator, boolean parallel) { argument
71 parallel);
75 * Creates a new sequential or parallel {@code Stream} from a
101 * @param parallel if {@code true} then the returned stream is a parallel
104 * @return a new sequential or parallel {
107 stream(Supplier<? extends Spliterator<T>> supplier, int characteristics, boolean parallel) argument
137 intStream(Spliterator.OfInt spliterator, boolean parallel) argument
175 intStream(Supplier<? extends Spliterator.OfInt> supplier, int characteristics, boolean parallel) argument
204 longStream(Spliterator.OfLong spliterator, boolean parallel) argument
243 longStream(Supplier<? extends Spliterator.OfLong> supplier, int characteristics, boolean parallel) argument
272 doubleStream(Spliterator.OfDouble spliterator, boolean parallel) argument
311 doubleStream(Supplier<? extends Spliterator.OfDouble> supplier, int characteristics, boolean parallel) argument
[all...]
H A DAbstractPipeline.java57 * <p>For sequential streams, and parallel streams without
59 * operations</a>, parallel streams, pipeline evaluation is done in a single
60 * pass that "jams" all the operations together. For parallel streams with
106 * and the stream source if sequential, or the previous stateful if parallel.
147 * True if pipeline is parallel, otherwise the pipeline is sequential; only
150 private boolean parallel; field in class:AbstractPipeline
158 * @param parallel True if the pipeline is parallel
161 int sourceFlags, boolean parallel) {
170 this.parallel
160 AbstractPipeline(Supplier<? extends Spliterator<?>> source, int sourceFlags, boolean parallel) argument
181 AbstractPipeline(Spliterator<?> source, int sourceFlags, boolean parallel) argument
311 public final S parallel() { method in class:AbstractPipeline
[all...]
H A DDoubleStream.java51 * A sequence of primitive double-valued elements supporting sequential and parallel
201 * <p>For parallel stream pipelines, the action may be called at
233 * stream pipelines, it can be quite expensive on ordered parallel pipelines,
239 * speedups of {@code limit()} in parallel pipelines, if the semantics of
242 * {@code limit()} in parallel pipelines, switching to sequential execution
262 * stream pipelines, it can be quite expensive on ordered parallel pipelines,
268 * speedups of {@code skip()} in parallel pipelines, if the semantics of
271 * {@code skip()} in parallel pipelines, switching to sequential execution
286 * <p>For parallel stream pipelines, this operation does <em>not</em>
437 * parallel executio
708 DoubleStream parallel(); method in interface:DoubleStream
[all...]
H A DDoublePipeline.java67 int sourceFlags, boolean parallel) {
68 super(source, sourceFlags, parallel);
79 int sourceFlags, boolean parallel) {
80 super(source, sourceFlags, parallel);
527 * @param parallel {@code true} if the pipeline is parallel
530 int sourceFlags, boolean parallel) {
531 super(source, sourceFlags, parallel);
540 * @param parallel {@code true} if the pipeline is parallel
66 DoublePipeline(Supplier<? extends Spliterator<Double>> source, int sourceFlags, boolean parallel) argument
78 DoublePipeline(Spliterator<Double> source, int sourceFlags, boolean parallel) argument
529 Head(Supplier<? extends Spliterator<Double>> source, int sourceFlags, boolean parallel) argument
542 Head(Spliterator<Double> source, int sourceFlags, boolean parallel) argument
[all...]
H A DIntPipeline.java64 * @param parallel {@code true} if the pipeline is parallel
67 int sourceFlags, boolean parallel) {
68 super(source, sourceFlags, parallel);
77 * @param parallel {@code true} if the pipeline is parallel
80 int sourceFlags, boolean parallel) {
81 super(source, sourceFlags, parallel);
524 * @param parallel {@code true} if the pipeline is parallel
66 IntPipeline(Supplier<? extends Spliterator<Integer>> source, int sourceFlags, boolean parallel) argument
79 IntPipeline(Spliterator<Integer> source, int sourceFlags, boolean parallel) argument
526 Head(Supplier<? extends Spliterator<Integer>> source, int sourceFlags, boolean parallel) argument
539 Head(Spliterator<Integer> source, int sourceFlags, boolean parallel) argument
[all...]
H A DIntStream.java49 * A sequence of primitive int-valued elements supporting sequential and parallel
196 * <p>For parallel stream pipelines, the action may be called at
228 * stream pipelines, it can be quite expensive on ordered parallel pipelines,
234 * speedups of {@code limit()} in parallel pipelines, if the semantics of
237 * {@code limit()} in parallel pipelines, switching to sequential execution
257 * stream pipelines, it can be quite expensive on ordered parallel pipelines,
263 * speedups of {@code skip()} in parallel pipelines, if the semantics of
266 * {@code skip()} in parallel pipelines, switching to sequential execution
281 * <p>For parallel stream pipelines, this operation does <em>not</em>
431 * parallel executio
677 IntStream parallel(); method in interface:IntStream
[all...]
H A DLongPipeline.java65 * @param parallel {@code true} if the pipeline is parallel
68 int sourceFlags, boolean parallel) {
69 super(source, sourceFlags, parallel);
78 * @param parallel {@code true} if the pipeline is parallel
81 int sourceFlags, boolean parallel) {
82 super(source, sourceFlags, parallel);
507 * @param parallel {@code true} if the pipeline is parallel
67 LongPipeline(Supplier<? extends Spliterator<Long>> source, int sourceFlags, boolean parallel) argument
80 LongPipeline(Spliterator<Long> source, int sourceFlags, boolean parallel) argument
509 Head(Supplier<? extends Spliterator<Long>> source, int sourceFlags, boolean parallel) argument
522 Head(Spliterator<Long> source, int sourceFlags, boolean parallel) argument
[all...]
H A DLongStream.java53 * A sequence of primitive long-valued elements supporting sequential and parallel
200 * <p>For parallel stream pipelines, the action may be called at
232 * stream pipelines, it can be quite expensive on ordered parallel pipelines,
238 * speedups of {@code limit()} in parallel pipelines, if the semantics of
241 * {@code limit()} in parallel pipelines, switching to sequential execution
261 * stream pipelines, it can be quite expensive on ordered parallel pipelines,
267 * speedups of {@code skip()} in parallel pipelines, if the semantics of
270 * {@code skip()} in parallel pipelines, switching to sequential execution
285 * <p>For parallel stream pipelines, this operation does <em>not</em>
435 * parallel executio
669 LongStream parallel(); method in interface:LongStream
[all...]
H A DReferencePipeline.java68 * @param parallel {@code true} if the pipeline is parallel
71 int sourceFlags, boolean parallel) {
72 super(source, sourceFlags, parallel);
81 * @param parallel {@code true} if the pipeline is parallel
84 int sourceFlags, boolean parallel) {
85 super(source, sourceFlags, parallel);
552 int sourceFlags, boolean parallel) {
553 super(source, sourceFlags, parallel);
70 ReferencePipeline(Supplier<? extends Spliterator<?>> source, int sourceFlags, boolean parallel) argument
83 ReferencePipeline(Spliterator<?> source, int sourceFlags, boolean parallel) argument
551 Head(Supplier<? extends Spliterator<?>> source, int sourceFlags, boolean parallel) argument
563 Head(Spliterator<?> source, int sourceFlags, boolean parallel) argument
[all...]
H A DStreamSpliterators.java117 boolean parallel) {
121 this.isParallel = parallel;
130 boolean parallel) {
134 this.isParallel = parallel;
274 boolean parallel) {
275 super(ph, supplier, parallel);
280 boolean parallel) {
281 super(ph, spliterator, parallel);
327 boolean parallel) {
328 super(ph, supplier, parallel);
115 AbstractWrappingSpliterator(PipelineHelper<P_OUT> ph, Supplier<Spliterator<P_IN>> spliteratorSupplier, boolean parallel) argument
128 AbstractWrappingSpliterator(PipelineHelper<P_OUT> ph, Spliterator<P_IN> spliterator, boolean parallel) argument
272 WrappingSpliterator(PipelineHelper<P_OUT> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument
278 WrappingSpliterator(PipelineHelper<P_OUT> ph, Spliterator<P_IN> spliterator, boolean parallel) argument
325 IntWrappingSpliterator(PipelineHelper<Integer> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument
331 IntWrappingSpliterator(PipelineHelper<Integer> ph, Spliterator<P_IN> spliterator, boolean parallel) argument
383 LongWrappingSpliterator(PipelineHelper<Long> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument
389 LongWrappingSpliterator(PipelineHelper<Long> ph, Spliterator<P_IN> spliterator, boolean parallel) argument
441 DoubleWrappingSpliterator(PipelineHelper<Double> ph, Supplier<Spliterator<P_IN>> supplier, boolean parallel) argument
447 DoubleWrappingSpliterator(PipelineHelper<Double> ph, Spliterator<P_IN> spliterator, boolean parallel) argument
[all...]
/libcore/ojluni/src/test/java/util/stream/bootlib/java/util/stream/
H A DFlagDeclaringOp.java58 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { argument
H A DStatelessTestOp.java71 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink); argument
H A DStatefulTestOp.java127 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink); argument
H A DTestFlagExpectedOp.java104 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
H A DCollectorOps.java64 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { argument
H A DOpTestCase.java83 * @param isParallel true if the pipeline is parallel
584 AbstractPipeline createPipeline(StreamShape shape, Spliterator s, int flags, boolean parallel) { argument
586 case REFERENCE: return new ReferencePipeline.Head<>(s, flags, parallel);
587 case INT_VALUE: return new IntPipeline.Head(s, flags, parallel);
588 case LONG_VALUE: return new LongPipeline.Head(s, flags, parallel);
589 case DOUBLE_VALUE: return new DoublePipeline.Head(s, flags, parallel);
648 public Sink<T> opWrapSink(int flags, boolean parallel, Sink<T> sink) { argument
/libcore/ojluni/src/test/java/util/stream/testlib/org/openjdk/testlib/java/util/stream/
H A DFlagDeclaringOp.java61 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { argument
H A DStatelessTestOp.java81 Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_OUT> sink); argument
H A DTestFlagExpectedOp.java105 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
H A DCollectorOps.java65 public Sink<E_IN> opWrapSink(int flags, boolean parallel, Sink<E_IN> sink) { argument
H A DStatefulTestOp.java128 Sink<E> opWrapSink(int flags, boolean parallel, Sink<E> sink); argument
H A DOpTestCase.java84 * @param isParallel true if the pipeline is parallel
585 AbstractPipeline createPipeline(StreamShape shape, Spliterator s, int flags, boolean parallel) { argument
587 case REFERENCE: return new ReferencePipeline.Head<>(s, flags, parallel);
588 case INT_VALUE: return new IntPipeline.Head(s, flags, parallel);
589 case LONG_VALUE: return new LongPipeline.Head(s, flags, parallel);
590 case DOUBLE_VALUE: return new DoublePipeline.Head(s, flags, parallel);
649 public Sink<T> opWrapSink(int flags, boolean parallel, Sink<T> sink) { argument
/libcore/ojluni/src/test/java/util/stream/boottest/java/util/stream/
H A DFlagOpTest.java71 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { argument
264 public Sink<T> opWrapSink(int flags, boolean parallel, Sink upstream) { argument
265 assertFlags(flags, parallel);
269 protected void assertFlags(int flags, boolean parallel) { argument
270 if (parallel) {
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
H A DConcatTest.java145 private void assertRefConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument
147 assertEquals(result.isParallel(), parallel);
151 private void assertIntConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument
154 assertEquals(result.isParallel(), parallel);
159 private void assertLongConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument
162 assertEquals(result.isParallel(), parallel);
167 private void assertDoubleConcat(Stream<Integer> s1, Stream<Integer> s2, boolean parallel, boolean ordered) { argument
170 assertEquals(result.isParallel(), parallel);
178 // parallel + parallel
[all...]

Completed in 252 milliseconds