Home
last modified time | relevance | path

Searched refs:parallel (Results 1 – 25 of 54) 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()
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 …]
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()
549 int sourceFlags, boolean parallel) {
550 super(source, sourceFlags, parallel);
563 int sourceFlags, boolean parallel) {
564 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()
530 int sourceFlags, boolean parallel) {
531 super(source, sourceFlags, parallel);
544 int sourceFlags, boolean parallel) {
545 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()
547 int sourceFlags, boolean parallel) {
548 super(source, sourceFlags, parallel);
561 int sourceFlags, boolean parallel) {
562 super(source, sourceFlags, parallel);
DReferencePipeline.java72 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()
572 int sourceFlags, boolean parallel) {
573 super(source, sourceFlags, parallel);
585 int sourceFlags, boolean parallel) {
586 super(source, sourceFlags, parallel);
/libcore/ojluni/src/test/java/util/stream/test/org/openjdk/tests/java/util/stream/
DLongPrimitiveOpsTests.java52 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()
DIntPrimitiveOpsTests.java52 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()
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.java65 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 …]
DDoublePrimitiveOpsTests.java52 … 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()
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 …]
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()
DStreamSpliteratorTest.java255 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/
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/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.java397 r.ints(size).parallel().forEach(x -> counter.increment());
412 r.longs(size).parallel().forEach(x -> counter.increment());
427 r.doubles(size).parallel().forEach(x -> counter.increment());
443 r.ints(size, lo, hi).parallel().forEach(
462 r.longs(size, lo, hi).parallel().forEach(
481 r.doubles(size, lo, hi).parallel().forEach(
497 r.ints().limit(size).parallel().forEach(x -> counter.increment());
508 r.longs().limit(size).parallel().forEach(x -> counter.increment());
519 r.doubles().limit(size).parallel().forEach(x -> counter.increment());
/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()
DDefaultMethodStreams.java367 public Stream<T> parallel() { in parallel() method in DefaultMethodStreams.DefaultMethodRefStream
368 return s.parallel(); in parallel()
558 public IntStream parallel() { in parallel() method in DefaultMethodStreams.DefaultMethodIntStream
559 return s.parallel(); in parallel()
759 public LongStream parallel() { in parallel() method in DefaultMethodStreams.DefaultMethodLongStream
760 return s.parallel(); in parallel()
952 public DoubleStream parallel() { in parallel() method in DefaultMethodStreams.DefaultMethodDoubleStream
953 return s.parallel(); in parallel()
DFlagDeclaringOp.java61 public Sink<T> opWrapSink(int flags, boolean parallel, Sink sink) { in opWrapSink() argument
/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