6

I have the following:

LinkedList<Integer> ints = new LinkedList(); //fill it with some ints Stream<Integer> stream = ints.stream(); //process the stream in some way 

My question is if it's guaranteed that the order of processing of the stream is as of the underlying LinkedList? I read the documentation but there was no any info about the ordering.

In my case it's critically to preserve the order.

18
  • 3
    The stream will be ordered, which guarantees a result with properly ordered elements, also known as encounter order. This has nothing to do with the processing order. See stackoverflow.com/a/29218074/2711488 Commented Jul 8, 2016 at 8:37
  • 1
    If you say List<X> result=ints.stream().map(func).collect(Collectors.toList());, the result list will have the elements in a matching order. This does not say anything about the order, in which the mapping function is evaluated, though. This applies to both, sequential and parallel streams. Commented Jul 8, 2016 at 8:42
  • 3
    @JB Nizet: there is no guaranty about the processing order, even for sequential streams. On the other hand, there are guarantees regarding the encounter order, even for parallel streams. Commented Jul 8, 2016 at 8:44
  • 1
    Note that this requirement about the order of processing is a big sign of something wrong in your design. It probably means that the mapping function is not a pure function, or has side effects, or is not idempotent. Why do you care the the first element is mapped before the second one? All that should matter is that the result is ordered as you want to. Commented Jul 8, 2016 at 8:45
  • 2
    @JB Nizet: of course, I assumed that you know. But I wanted to emphasize that while the documentation does not say explicitly that we don’t have such a guaranty, a contradicting statement has been deliberately removed, telling us that the authors wanted to avoid the impression of having such a guaranty. Commented Jul 8, 2016 at 8:57

2 Answers 2

2

From the documentation:

Streams may or may not have a defined encounter order. Whether or not a stream has an encounter order depends on the source and the intermediate operations. Certain stream sources (such as List or arrays) are intrinsically ordered, whereas others (such as HashSet) are not. Some intermediate operations, such as sorted(), may impose an encounter order on an otherwise unordered stream, and others may render an ordered stream unordered, such as BaseStream.unordered(). Further, some terminal operations may ignore encounter order, such as forEach().

If a stream is ordered, most operations are constrained to operate on the elements in their encounter order; if the source of a stream is a List containing [1, 2, 3], then the result of executing map(x -> x*2) must be [2, 4, 6]. However, if the source has no defined encounter order, then any permutation of the values [2, 4, 6] would be a valid result.

For sequential streams, the presence or absence of an encounter order does not affect performance, only determinism. If a stream is ordered, repeated execution of identical stream pipelines on an identical source will produce an identical result; if it is not ordered, repeated execution might produce different results.

For parallel streams, relaxing the ordering constraint can sometimes enable more efficient execution...

Also, as you mentioned that processing order matters for you see here:

Stream pipeline results may be nondeterministic or incorrect if the behavioral parameters to the stream operations are stateful...

The best approach is to avoid stateful behavioral parameters to stream operations entirely; there is usually a way to restructure the stream pipeline to avoid statefulness.

See also the answer to this question: How to ensure order of processing in java8 streams?

In short, it looks like you can preserve the order, if you use sequential streams (streams that are executed in one thread) and if you are careful with operations like forEach(). However it probably is not a good idea.

Sign up to request clarification or add additional context in comments.

Comments

1

Depends on the processing you are applying to the stream... especially using parallel()

import java.util.LinkedList; import java.util.function.Consumer; import java.util.stream.Stream; public class Streaming { public static void main(String[] args) { LinkedList<Integer> ints = new LinkedList(); for(int i = 0 ; i < 100; i++) { ints.add(i); } Stream<Integer> stream = ints.stream(); // will not be ordered stream.parallel().forEach(new Consumer<Integer>() { @Override public void accept(Integer t) { System.out.println(t); } }); stream = ints.stream(); // will be ordered stream.parallel().forEachOrdered(new Consumer<Integer>() { @Override public void accept(Integer t) { System.out.println(t); } }); } } 

3 Comments

Any reason for using anonymous inner classes in Java 8 code? I mean, especially for this use case?
Eclipse will generate them when you press Command+Space. It won't generate the Lambdas. :/
@ifly6: So, instead of pressing Command+Space, you have to type t - >, in other words, press three keys instead of two. The effort for inserting the actual print statement is exactly the same.

Start asking to get answers

Find the answer to your question by asking.

Ask question

Explore related questions

See similar questions with these tags.