A pipeline such as:

  ThreadLocalRandom.current().ints().boxed().parallel().distinct().findAny();

will not terminate since distinct() is a barrier for an unordered input.

In such cases it is possible for the distinct operation to be lazy and use a distinct wrapping spliterator, which internally uses a ConcurrentHashMap to track distinct elements.