Stream parallel() / sequential() question. (original) (raw)
Boaz Nahum boaznahum at gmail.com
Thu Apr 4 06:21:36 PDT 2013
- Previous message: Collector's accumulator
- Next message: Stream parallel() / sequential() question.
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]
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 {
@Override
public void accept(Integer integer) {
threads.put(Thread.currentThread(), true);
}
public void report() {
System.out.println("Name +'" + name + "': " + threads.size() +" Thread(s)"); } }
- Previous message: Collector's accumulator
- Next message: Stream parallel() / sequential() question.
- Messages sorted by: [ date ] [ thread ] [ subject ] [ author ]