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