350 |
|
long size = 0; |
351 |
|
for (int reps = 0; reps < REPS; ++reps) { |
352 |
|
counter.reset(); |
353 |
< |
r.ints(size).parallel().forEach(x -> {counter.increment();}); |
353 |
> |
r.ints(size).parallel().forEach(x -> counter.increment()); |
354 |
|
assertEquals(size, counter.sum()); |
355 |
|
size += 524959; |
356 |
|
} |
365 |
|
long size = 0; |
366 |
|
for (int reps = 0; reps < REPS; ++reps) { |
367 |
|
counter.reset(); |
368 |
< |
r.longs(size).parallel().forEach(x -> {counter.increment();}); |
368 |
> |
r.longs(size).parallel().forEach(x -> counter.increment()); |
369 |
|
assertEquals(size, counter.sum()); |
370 |
|
size += 524959; |
371 |
|
} |
380 |
|
long size = 0; |
381 |
|
for (int reps = 0; reps < REPS; ++reps) { |
382 |
|
counter.reset(); |
383 |
< |
r.doubles(size).parallel().forEach(x -> {counter.increment();}); |
383 |
> |
r.doubles(size).parallel().forEach(x -> counter.increment()); |
384 |
|
assertEquals(size, counter.sum()); |
385 |
|
size += 524959; |
386 |
|
} |
447 |
|
LongAdder counter = new LongAdder(); |
448 |
|
SplittableRandom r = new SplittableRandom(); |
449 |
|
long size = 100; |
450 |
< |
r.ints().limit(size).parallel().forEach(x -> {counter.increment();}); |
450 |
> |
r.ints().limit(size).parallel().forEach(x -> counter.increment()); |
451 |
|
assertEquals(size, counter.sum()); |
452 |
|
} |
453 |
|
|
458 |
|
LongAdder counter = new LongAdder(); |
459 |
|
SplittableRandom r = new SplittableRandom(); |
460 |
|
long size = 100; |
461 |
< |
r.longs().limit(size).parallel().forEach(x -> {counter.increment();}); |
461 |
> |
r.longs().limit(size).parallel().forEach(x -> counter.increment()); |
462 |
|
assertEquals(size, counter.sum()); |
463 |
|
} |
464 |
|
|
469 |
|
LongAdder counter = new LongAdder(); |
470 |
|
SplittableRandom r = new SplittableRandom(); |
471 |
|
long size = 100; |
472 |
< |
r.doubles().limit(size).parallel().forEach(x -> {counter.increment();}); |
472 |
> |
r.doubles().limit(size).parallel().forEach(x -> counter.increment()); |
473 |
|
assertEquals(size, counter.sum()); |
474 |
|
} |
475 |
|
|
480 |
|
LongAdder counter = new LongAdder(); |
481 |
|
SplittableRandom r = new SplittableRandom(); |
482 |
|
long size = 100; |
483 |
< |
r.ints().limit(size).forEach(x -> {counter.increment();}); |
483 |
> |
r.ints().limit(size).forEach(x -> counter.increment()); |
484 |
|
assertEquals(size, counter.sum()); |
485 |
|
} |
486 |
|
|
491 |
|
LongAdder counter = new LongAdder(); |
492 |
|
SplittableRandom r = new SplittableRandom(); |
493 |
|
long size = 100; |
494 |
< |
r.longs().limit(size).forEach(x -> {counter.increment();}); |
494 |
> |
r.longs().limit(size).forEach(x -> counter.increment()); |
495 |
|
assertEquals(size, counter.sum()); |
496 |
|
} |
497 |
|
|
502 |
|
LongAdder counter = new LongAdder(); |
503 |
|
SplittableRandom r = new SplittableRandom(); |
504 |
|
long size = 100; |
505 |
< |
r.doubles().limit(size).forEach(x -> {counter.increment();}); |
505 |
> |
r.doubles().limit(size).forEach(x -> counter.increment()); |
506 |
|
assertEquals(size, counter.sum()); |
507 |
|
} |
508 |
|
|