Method main

concurrent/CountingStream.java:11–18

(String[] args)

public class CountingStream {
  public static void main(String[] args) {
    System.out.println(
      IntStream.range(0, 10)
        .parallel()
        .mapToObj(CountingTask::new)
        .map(ct -> ct.call())
        .reduce(0, Integer::sum));
  }
}
/* Output:
1 ForkJoinPool.commonPool-worker-3 100