Why parallel stream get collected sequentially in Java 8

by

There are two different kinds of “ordering” going on here, which makes the discussion confusing.

One kind is encounter order, which is defined in the streams documentation. A good way to think about this is the spatial or left-to-right order of elements in the source collection. If the source is a List, consider the earlier elements being to the left of later elements.

There is also processing or temporal order, which isn’t defined in the documentation, but which is the time order in which elements are processed by different threads. If the elements of a list are being processed in parallel by different threads, a thread might process the rightmost element in the list before the leftmost element. But the next time it might not.

Even when computations are done in parallel, most Collectors and some terminal operations are carefully arranged so that they preserve encounter order from the source through to the destination, independently of the temporal order in which different threads might process each element.

Note that the forEach terminal operation does not preserve encounter order. Instead, it’s run by whatever thread happens to produce the next result. If you want something like forEach that preserves encounter order, use forEachOrdered instead.

See also the Lambda FAQ for further discussion about ordering issues.

More Related Contents:

  1. Custom thread pool in Java 8 parallel stream
  2. Should I always use a parallel stream when possible?
  3. Java 8’s streams: why parallel stream is slower?
  4. Parallel streams, collectors and thread safety
  5. Is this a bug in Files.lines(), or am I misunderstanding something about parallel streams?
  6. Stream.skip behavior with unordered terminal operation
  7. Parallel stream from a HashSet doesn’t run in parallel
  8. Why is Files.list() parallel stream performing so much slower than using Collection.parallelStream()?
  9. Nested Java 8 parallel forEach loop perform poor. Is this behavior expected?
  10. Visualization of Java Stream parallelization
  11. Get List<K> from HashMap<K, V> where V is instance of I [closed]
  12. Java 8 Distinct by property
  13. In Java streams is peek really only for debugging?
  14. Why filter() after flatMap() is “not completely” lazy in Java streams?
  15. How to force max to return ALL maximum values in a Java Stream?
  16. Copy a stream to avoid “stream has already been operated upon or closed”
  17. What is difference between Collection.stream().forEach() and Collection.forEach()?
  18. Find first element by predicate
  19. Why is a combiner needed for reduce method that converts type in java 8
  20. How can I make Cartesian product with Java 8 streams?
  21. Find maximum, minimum, sum and average of a list in Java 8
  22. Java 8 method references: provide a Supplier capable of supplying a parameterized result
  23. Java streams lazy vs fusion vs short-circuiting
  24. Collectors.summingInt() vs mapToInt().sum()
  25. How to check if a Java 8 Stream is empty?
  26. How to sum values in a Map with a stream?
  27. Is mapToDouble() really necessary for summing a List with Java 8 streams?
  28. Is it possible to cast a Stream in Java 8?
  29. ‘Optional.get()’ without ‘isPresent()’ check
  30. Most elegant way to join a Map to a String in Java 8

Leave a Comment