Как реализовать стек итерацию с использованием Java 8 Поток

Question

У меня есть Stack<Object> и следующий кусок кода:

while(!stack.isEmpty()){ 
    Object object = stack.pop(); 
    // do some operation on object 
} 

Как это итерация может быть реализована с использованием Java 8 поток так, чтобы он петлями, пока стек не пуст, и в каждая итерация стека должна быть уменьшена, выбирая один элемент сверху?

Answer 1

В Java 9, будет представлять собой 3-Arg версии Stream.iterate (как for цикла - начальное значение лямбды для определение конца входного текста, лямбда для определения следующего входа), которые могли бы сделать это, хотя бы немного напряженными:

if (!stack.isEmpty()) { 
    Stream.iterate(stack.pop(), 
        e -> !stack.isEmpty(), 
        e -> stack.pop()) 
      ... 
} 

Answer 2

Невозможно использовать поток стека, поскольку сначала он будет первым в первом порядке, а второй, поскольку он основан на итераторе, выкинет ConcurrentModificationException. Тем не менее возможно, но, конечно, не рекомендуется, если по сравнению с простым циклом:

IntStream.range(0, s.size()).forEach(i -> stack.pop()); 

Answer 3

в случае, если вы не хотите ждать the Java 9 solution, вот поток завода, который работает под Java 8.

public static <T> Stream<T> pop(Stack<T> stack) { 
    return StreamSupport.stream(new Spliterators.AbstractSpliterator<T>(
     stack.size(), Spliterator.ORDERED|Spliterator.SIZED) { 
      public boolean tryAdvance(Consumer<? super T> action) { 
       if(stack.isEmpty()) return false; 
       action.accept(stack.pop()); 
       return true; 
      } 
    }, false); 
} 

Обратите внимание, что это указывает начальный размер стека, принимая его как должное, что подразумевает, что вы не должны менять промежуточный стек (модификация источника потока в промежутке - это плохая идея в любом случае). С другой стороны, это сделает некоторые операции Stream более эффективными, чем вариант итерации.

Теперь общее предупреждение, которое применяется к обоим вариантам. Источники потока, которые были изменены из-за текущей операции Stream, например, выбирая элементы, которые потребляет Stream, могут оставить источник в непредсказуемом состоянии. Операции короткого замыкания могут не потреблять все элементы и в сочетании с параллельными потоками, они все равно могут потреблять больше элементов, чем это необходимо для работы терминала.

Так аналогично BufferedReader.lines()

После выполнения операции терминала потока нет никаких гарантий того, что читатель будет в определенном положении, из которого читать следующий символ или строку.

Вы не должны делать какие-либо предположения относительно содержимого Stack после потребления элементов таким образом.