| 27 |
|
* @run main IteratorMicroBenchmark iterations=1 size=8 warmup=0 |
| 28 |
|
*/ |
| 29 |
|
|
| 30 |
+ |
import static java.util.stream.Collectors.summingInt; |
| 31 |
+ |
|
| 32 |
|
import java.lang.ref.WeakReference; |
| 33 |
|
import java.util.ArrayDeque; |
| 34 |
|
import java.util.Arrays; |
| 367 |
|
sum[0] = 0; |
| 368 |
|
for (Integer o : x.toArray(empty)) |
| 369 |
|
sum[0] += o; |
| 370 |
< |
check.sum(sum[0]);}}}); |
| 370 |
> |
check.sum(sum[0]);}}}, |
| 371 |
> |
new Job(klazz + " .stream().collect") { |
| 372 |
> |
public void work() throws Throwable { |
| 373 |
> |
for (int i = 0; i < iterations; i++) { |
| 374 |
> |
check.sum(x.stream() |
| 375 |
> |
.collect(summingInt(e -> e)));}}}, |
| 376 |
> |
new Job(klazz + " .parallelStream().collect") { |
| 377 |
> |
public void work() throws Throwable { |
| 378 |
> |
for (int i = 0; i < iterations; i++) { |
| 379 |
> |
check.sum(x.parallelStream() |
| 380 |
> |
.collect(summingInt(e -> e)));}}}); |
| 381 |
|
} |
| 382 |
|
|
| 383 |
|
List<Job> dequeJobs(Deque<Integer> x) { |
