Эквивалент foldLeft Scala в Java 8

Question

Что такое эквивалент Scala's great foldLeft в Java 8?

У меня возникло искушение подумать, что это было reduce, но у сокращения должно быть что-то похожее на то, что он уменьшает.

Пример:

import java.util.List; 

public class Foo { 

    // this method works pretty well 
    public int sum(List<Integer> numbers) { 
     return numbers.stream() 
         .reduce(0, (acc, n) -> (acc + n)); 
    } 

    // this method makes the file not compile 
    public String concatenate(List<Character> chars) { 
     return chars.stream() 
        .reduce(new StringBuilder(""), (acc, c) -> acc.append(c)).toString(); 
    } 
} 

Проблема в приведенном выше коде является acc umulator: new StringBuilder("")

Таким образом, кто-то может мне точку в правильном эквивалент foldLeft/исправить мой код?

Answer 1

Update:

Вот первая попытка получить код исправлено:

public static String concatenate(List<Character> chars) { 
     return chars 
       .stream() 
       .reduce(new StringBuilder(), 
           StringBuilder::append, 
           StringBuilder::append).toString(); 
    } 

Он использует следующие reduce method:

<U> U reduce(U identity, 
       BiFunction<U, ? super T, U> accumulator, 
       BinaryOperator<U> combiner); 

Это может показаться странным, но если вы посмотрите в javadocs есть хорошее объяснение, которое может помочь вам быстро понять детали. Снижение эквивалентно следующий код:

U result = identity; 
for (T element : this stream) 
    result = accumulator.apply(result, element) 
return result; 

Для более подробного описания работы, пожалуйста, проверьте this source.

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

Как указано в комментариях ниже правильный вариант используется сокращение следующим образом:

return chars.stream().collect(
    StringBuilder::new, 
    StringBuilder::append, 
    StringBuilder::append).toString(); 

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

Answer 2

Метод, который вы ищете, это java.util.Stream.reduce, в частности перегрузка с тремя параметрами, идентификацией, аккумулятором и двоичной функцией. Это правильный эквивалент Scala's foldLeft.

Однако вы не разрешено использовать в Java reduce таким образом, а также не в Scala foldLeft по этому вопросу. Вместо этого используйте collect.

Answer 3

В API потока Java 8 нет эквивалента foldLeft. Как отмечают другие, reduce(identity, accumulator, combiner) подходит к концу, но он не эквивалентен foldLeft, потому что для этого требуется получить тип B, чтобы объединиться с ним и быть ассоциативным (другими словами, быть моноидальным), свойство, которое не каждый тип имеет.

Существует также запрос на повышение для этого: add Stream.foldLeft() terminal operation

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

val arithOps = List(('+', 1), ('*', 4), ('-', 2), ('/', 5)) 
val fun: (Int, (Char, Int)) => Int = { 
    case (x, ('+', y)) => x + y 
    case (x, ('-', y)) => x - y 
    case (x, ('*', y)) => x * y 
    case (x, ('/', y)) => x/y 
} 
val number = 2 
arithOps.foldLeft(number)(fun) // ((2 + 1) * 4 - 2)/5 

Если вы попытались написать reduce(2, fun, combine), какую функцию объединителя вы могли бы передать, которая объединяет два числа? Добавление двух чисел вместе явно не решает проблему. Кроме того, значение 2 явно не является идентификатором .

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