Подсчитайте количество последовательных идентичных объектов с помощью Java 8 Stream API - PullRequest
Новая
       9

Подсчитайте количество последовательных идентичных объектов с помощью Java 8 Stream API

0 голосов
/ 27 июня 2018

Я хочу посчитать количество идентичных объектов один за другим в потоке Java 8. Как я могу это сделать? Если у меня есть список 

3, 3, 5, 5, 5, 6, 3, 3

Я хочу, чтобы результат был 

[3-2] [5-3] [6-1] [3-2]

Моя наивная попытка без потоков Java 8: 

private static List<ValueCount> counteSameValueInRow(List<Integer> Values) {
    List<ValueCount> result = new ArrayList<ValueCount>();
    ValueCount valueCount = null;

    for (int value: Values) {
        if (valueCount == null) {
            valueCount = new ValueCount(value);
        } else if (valueCount.value == value){
            valueCount.numberof++;
        } else {
            result.add(valueCount);
            valueCount = new ValueCount(value);
        }
    }
    result.add(valueCount);
    return result;
}

Ответы [ 2 ]

0 голосов
/ 27 июня 2018

Я сделал рефакторинг, чтобы улучшить читаемость после предложения Малте Хартвига. Вот результат 

 public static void main(String[] args) {
    List<Integer> values = Arrays.asList(3, 3, 5, 5, 5, 6, 3, 3);

    BiPredicate<Integer, Integer> predicate = (value1, value2) -> value1.equals(value2);

    Supplier<BiConsumer<LinkedList<ValueCount>, Integer>> accumulator = 
        () -> (list, value) -> {
        if (list.isEmpty() || !predicate.test(list.getLast().getFirstValue(), value)) {
            list.add(new ValueCount());
        }
        list.getLast().add(value);
    };

    Supplier<BiConsumer<LinkedList<ValueCount>, LinkedList<ValueCount>>> combiner = () -> (list1, list2) -> {
        if (list1.getLast().getFirstValue().equals(list2.getFirst().getFirstValue())) {
            list1.getLast().addAll(list2.getFirst());
            list2.removeFirst();
        }
        list1.addAll(list2);
    };

    values.stream().collect(LinkedList::new, accumulator.get(), combiner.get())
            .forEach(group -> System.out.println(group));
}

private static class ValueCount {
    private List<Integer> lista = new ArrayList<>();

    public String toString() { return "[" + lista.get(0) + "-" + lista.size() + "]";}
    public void add(Integer value) { lista.add(value);}
    public Integer getFirstValue() { return lista.get(0);}
    public void addAll(ValueCount first) { lista.addAll(first.getAll());}
    private Collection<? extends Integer> getAll() { return lista;}
}
0 голосов
/ 27 июня 2018

То, что вы делаете, сравнимо с collect в потоке. Вы берете каждое число и обобщаете его в список «групп». Collectors.groupingBy() приходит на ум, но это сгруппирует числа по всему списку, то есть просто посчитает вхождения каждого числа. Используя метод Stream.collect(Supplier, BiConsumer, BiConsumer) для реализации пользовательского сбора, вы можете сделать что-то вроде этого: 

List<Integer> values = Arrays.asList(3, 3, 5, 5, 5, 6, 3, 3);

values.stream().collect(LinkedList<List<Integer>>::new, (list, value) -> {
    if (list.isEmpty() || !list.getLast().get(0).equals(value))
    {
        list.add(new ArrayList<>());
    }
    list.getLast().add(value);
}, (list1, list2) -> {
    if (list1.getLast().get(0).equals(list2.getFirst().get(0)))
    {
        list1.getLast().addAll(list2.getFirst());
        list2.removeFirst();
    }
    list1.addAll(list2);
}).forEach(group -> System.out.println("[" + group.get(0) + "-" + group.size() + "]"));

Обратите внимание, что я использовал ArrayList s для сбора дубликатов. Вы можете использовать класс ValueCount для этой цели, что сделает его более читабельным.

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

Чтобы попробовать его параллельно, замените stream() на parallelStream() и поместите sysout в лямбду третьего параметра, чтобы увидеть, когда объединяются два промежуточных результата. Обратите внимание, что параллельная обработка принесет вам пользу только в том случае, если ваш список очень большой.

...