Stream parallel() / sequential() question.

Boaz Nahum boaznahum at gmail.com
Thu Apr 4 06:21:36 PDT 2013


When I invoked parallel() or sequential() how backward it goes ?

Let me explain, I wrote a simple Consumer that report how many different
threads used to run it:

source.
            parallel().peek(new ThreadReporter("Segement 1 parallel")).
            sequential().peek(new ThreadReporter("Segement 2 sequential")).
            parallel().peek(new ThreadReporter("Segement 3 parallel")).
            sequential().peek(new ThreadReporter("Segement 4
sequential")).forEach((t) -> {});



 private static class ThreadReporter implements Consumer<Integer> {


        @Override
        public void accept(Integer integer) {
            threads.put(Thread.currentThread(), true);
        }

        public void report() {
            System.out.println("Name +'" + name + "': " + threads.size() +
" Thread(s)");
        }
    }


More information about the lambda-dev mailing list